SpringBoot 定时任务Scheduled

  SpringBoot定时任务使用@EnableScheduling和@Scheduled这两个注解就能够简单实现，在集群环境下建议用Quartz等实现。

  不多说看代码具体实现

1.首先开启对Scheduled的支持

@Configuration
@EnableScheduling
public class ScheduledConfig {
}

2.使用@Scheduled注解

@Service
public class ScheduleService {

    @Scheduled(fixedDelay = 2000)
    public void scheduleTest1() throws InterruptedException {
        System.out.println("scheduleTest1 Start.>>" + new Date().toLocaleString());
        Thread.sleep(6000);
        System.out.println("scheduleTest1 End.>>" + new Date().toLocaleString());
    }

    @Scheduled(fixedRate = 2000)
    public void scheduleTest2() throws InterruptedException {
        System.out.println("scheduleTest2 Start.>>" + new Date().toLocaleString());
        Thread.sleep(6000);
        System.out.println("scheduleTest2  End.>>");
    }

    @Scheduled(cron = "0 0/1 * * * ? ")
    public void scheduleTest3() {
        System.out.println("scheduleTest3 >>>");
    }

    @Scheduled(fixedRate = 2000, initialDelay = 1000)
    public void scheduleTest4() throws InterruptedException {
        System.out.println("scheduleTest2 fixedRate Start.>>");
        Thread.sleep(6000);
        System.out.println("scheduleTest2 fixedRate End.>>");
    }

}

3.Scheduled注解中参数解释

• fixedDelay,fixedDelayString 都表式上次任务完成之后，多少毫秒后开始下一个任务
  • fixedDelay 传毫秒数
  • fixedDelayString 毫秒的String值或者java.time.Duration 类型想匹配的时间 比如PT20.345S
• fixedRate,fixedRateString 表式上次执行之后多少毫秒后开始下一个任务
  • fixedRate 传毫秒数
  • fixedRateString 毫秒的String值或者java.time.Duration 类型想匹配的时间
• initialDelay,initialDelayString 延迟多少毫秒执行
• cron 使用cron表达式来表示

4.那些坑

1. 首行启动之后他会自动查找org.springframework.scheduling.TaskScheduler的Bean或者是
   或者名为“taskScheduler”的Bean或者 java.util.concurrent.ScheduledExecutorService的Bean 如果都找不到将会以本地单线程的方式执行。你会发现定时任务会一个执行完成之后才会执行下一个。
2. 如果是简单的通过@EnableAsync 然后再方法上注解@Async后，则fixedDelay/fixedDelayString参数将失效等同于fixedRate/fixedRateString,因为方法上加@Async注解之后等同于该方法为异步方法，不会等待任务完成

5.配置多线程执行

    @Bean
    public ScheduledExecutorService scheduledExecutorService() {
        return new ScheduledThreadPoolExecutor(10);
    }

   @Bean
   public TaskScheduler taskScheduler() {
       ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
       threadPoolTaskScheduler.setPoolSize(20);
       return threadPoolTaskScheduler;
   }

@Configuration
@EnableScheduling
public class ScheduledConfig implements SchedulingConfigurer {

   @Override
   public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
       taskRegistrar.setScheduler(taskExecutor());
   }

   @Bean(destroyMethod = "shutdown")
   public Executor taskExecutor() {
       return Executors.newScheduledThreadPool(20);
   }
}

【注】代码基于SpringBoot 2.0

GitHub源码