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

时间：2023-02-14 22:21:02

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

 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"));

         }

     }

 }

相关文章