Junit 4 测试中使用定时任务操作

难度：测试中执行线程操作

package com.hfepc.job.dataCollection.test;

import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.CountDownLatch;

import javax.annotation.Resource;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.pentaho.di.job.Job;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.transaction.TransactionConfiguration;
import org.springframework.transaction.annotation.Transactional;

import com.hfepc.service.dataCollection.IDataCollectionService;
import com.hfepc.service.zkinsp.MySpringJUnit4ClassRunner;

@SuppressWarnings("unused")
@RunWith(MySpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath*:spring-context.xml",
        "classpath*:spring-servlet.xml", "classpath*:cxf-client.xml" })
@ActiveProfiles("development")
@Transactional
@TransactionConfiguration(transactionManager = "transactionManager", defaultRollback = false)
public class DataCollectionTest extends Job {

    private final Logger log = LoggerFactory
            .getLogger(DataCollectionTest.class);

    @Resource(name = "IDataCollectionService")
    private IDataCollectionService IDataCollectionService;

    private final int i = 3;
    /*
     * 线程计数器
     *     将线程数量初始化
     *     每执行完成一条线程，调用countDown()使计数器减1
     *     主线程调用方法await()使其等待，当计数器为0时才被执行
     */
    private final CountDownLatch latch = new CountDownLatch(i);

    @Test
    public void createTest() {
            Timer timer;
            timer = new Timer();
            timer.schedule(new TimerTaskTest03(), 0, 60000);
            //三个参数 
            //第一个执行内容：内容是定时任务的执行内容，通过实现抽象类来完成这个动作  
            //第二个参数内容：是在第多少时间之后开始执行定时任务内容，该参数不能小于0 
            //第三个参数内容：是在两个任务之间的执行时间间隔，该参数不能小于等于0
            try {
                latch.await(); // 主线程等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            } 
 70 
    private class TimerTaskTest03 extends TimerTask {

        @Override
        public void run() {
            Date date1 = new Date(this.scheduledExecutionTime());
           String date = DateUtils.format(DateUtils.getCurDate(),
                   "yyyy/MM/dd"); 
 99             log.error("本次执行该线程的时间为：" + date1);
            log.info("时间：" + date);
            String sql = "SELECT A.[Date] AS 'date_sta',A.barcode1 AS 'barcode1_sta',A.barcode2 AS 'barcode2_sta',A.HeightNum1Range AS 'HeightNum1Range',A.HeightNum2Range AS 'HeightNum2Range',A.HeightNum3Range AS 'HeightNum3Range',A.HeightData AS 'HeightData',A.HeightDL AS 'HeightDL',A.Num AS 'Num',A.CCDFlag AS 'CCDFlag',A.barcode3 AS 'barcode3',A.PressData AS 'PressData',B.SpurtData AS 'SpurtData',B.[Date] AS 'date_glu',B.CCDODRange AS 'CCDODRange',B.CCDODValue AS 'CCDODValue',B.CCDODFlag AS 'CCDODFlag',B.CCDConcentricityRange AS 'CCDConcentricityRange',B.CCDConcentricityValue AS 'CCDConcentricityValue',B.CCDConcentricityFlag AS 'CCDConcentricityFlag',B.barcode2 AS 'barcode2_glu',B.Static AS 'Static',B.SheetIron AS 'SheetIron',B.VerticalityFlag AS 'VerticalityFlag',B.TorsionData AS 'TorsionData' FROM[dbo].[StaticComponentsProductionData] A LEFT JOIN [dbo].[GlueDispenserProductionData] B ON A.barcode1 = B.barcode1 WHERE A.[Date] LIKE '"
                    + date + "%'";
            List<Map<String, Object>> rows = IDataCollectionService
                    .readSQLData(sql);
            log.info("返回标签：" + rows.size());
            log.info("返回标签：" + (String) rows.get(0).get("barcode2_sta"));
        }
    }

}