定时任务

定时任务线程池

  1. @Configuration
  2. //开启异步事件的支持
  3. @EnableAsync
  4. public class ScheduledConfig implements SchedulingConfigurer {
  6.     @Override
  7.     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
  8.         taskRegistrar.setScheduler(taskExecutor());
  9.     }
  11.     @Bean
  12.     public Executor taskExecutor() {
  13.         return Executors.newScheduledThreadPool(10); //指定线程池大小
  14.     }
  15. }

启动类添加注解

  1. @SpringBootApplication
  2. @EnableScheduling//开启定时任务
  3. public class Oms2RtocRtdsocketApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(Oms2RtocRtdsocketApplication.class, args);
  7.     }
  9. }

使用定时任务

使用注解@Schedule声明这是一个定时任务,Springboot启动会扫描到该注解并标记为定时任务

  1. @Component
  2. public class TestTask {
  3.     @Scheduled(cron="*/1 * * * * *")
  4.     public void sum2(){
  5.         System.out.println("cron 每秒 当前时间:"+new Date());
  6.     }
  7. }

使用@Asyn异步执行

这是一个异步任务的方法。如果在类上使用该注解,则该类下所有方法都是异步任务的方法；也可给某方法单独使用该注解。

  1. @Component
  2. @Async
  3. public class AsyncTask {
  5.     public void task1() throws InterruptedException{
  6.         long begin = System.currentTimeMillis();
  7.         Thread.sleep(1000L);
  8.         long end = System.currentTimeMillis();
  9.         System.out.println("任务1耗时="+(end-begin));
  10.     }
  13.     public void task2() throws InterruptedException{
  14.         long begin = System.currentTimeMillis();
  15.         Thread.sleep(2000L);
  16.         long end = System.currentTimeMillis();
  17.         System.out.println("任务2耗时="+(end-begin));
  18.     }
  21.     public void task3() throws InterruptedException{
  22.         long begin = System.currentTimeMillis();
  23.         Thread.sleep(3000L);
  24.         long end = System.currentTimeMillis();
  25.         System.out.println("任务3耗时="+(end-begin));
  26.     }
  29.     //获取异步结果
  32.     public Future<String> task4() throws InterruptedException{
  33.         long begin = System.currentTimeMillis();
  34.         Thread.sleep(2000L);
  35.         long end = System.currentTimeMillis();
  36.         System.out.println("任务4耗时="+(end-begin));
  37.         return new AsyncResult<String>("任务4");
  38.     }
  41.     public Future<String> task5() throws InterruptedException{
  42.         long begin = System.currentTimeMillis();
  43.         Thread.sleep(3000L);
  44.         long end = System.currentTimeMillis();
  45.         System.out.println("任务5耗时="+(end-begin));
  46.         return new AsyncResult<String>("任务5");
  47.     }
  49.     public Future<String> task6() throws InterruptedException{
  50.         long begin = System.currentTimeMillis();
  51.         Thread.sleep(1000L);
  52.         long end = System.currentTimeMillis();
  53.         System.out.println("任务6耗时="+(end-begin));
  54.         return new AsyncResult<String>("任务6");
  55.     }
  56. }