@Schedule定时任务是并行执行吗

Posted 2022-12-15 唐宋xy

@Schedule是常用的定时任务注解，一般用在需要定时执行的业务逻辑上，多用于单机任务，分布式任务使用的话，需要通过分布式锁保证数据一致性。

如果有多个@Schedule注解定义的定时任务，是并发执行还是串行执行呢？

@Schedule定义的定时任务应该也是有一个线程池，例如4大常见线程池中的ScheduleThreadPool

四大常见线程池：

1. SingleThreadPool：单线程的线程池
2. FixedThreadPool：固定线程的线程池
3. ScheduleThreadPool：定时执行的任务的线程池
4. CachedThreadPool：缓存线程数但是线程数量无限大的线程池

那么是并发执行多个定时任务还是只有一个线程串行执行定时任务呢？

如果是串行执行，那么会有严重的问题！定时任务不能按时执行，并且会有阻塞的风险

那么如何让@Schedule定义的定时任务并发多线程执行呢？

测试

在同一个类中，通过@Schedule定义多个定时任务，查看多个定时任务是否使用同一个线程执行，并且是否为并行执行

• 示例代码

@Component
public class ScheduleTest 

    @Scheduled(cron = "0/30 * * * * ?")
    public void task1() 
        System.out.println("task1 start");
        System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
    


    @Scheduled(cron = "0/30 * * * * ?")
    public void task2() 
        System.out.println("task2 start");
        System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
    

    @Scheduled(cron = "0/50 * * * * ?")
    public void task3() 
        System.out.println("task3 start");
        System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
    

• 输出

task2 start
40  scheduling-1
task1 start
40  scheduling-1
task3 start
40  scheduling-1

可以看到，三个任务使用的是同一个线程

• 再次测试

通过在某一个任务中写一个死循环，让这个任务一直再执行，然后看看其他的定时任务是否还会执行

   @Scheduled(cron = "0/30 * * * * ?")
    public void task1() 
        System.out.println("task1 start");
        System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
    


    @Scheduled(cron = "0/30 * * * * ?")
    public void task2() 
        while (true) 
            System.out.println("task2 start");
            System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
        
    

通过输出可以看到，task1的任务一直没有执行，task2的任务一直在执行

源码分析

@Schedule 注解的处理类在org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor这个类中

1. 在这个方法中，表示该bean初始化完成之后，执行的业务逻辑

2. 在finishRegistration方法最下面的this.registrar.afterPropertiesSet();方法中，表示开始调用后置处理器。

3. 后置处理器中则开始执行上面扫描到的所有的定时任务，org.springframework.scheduling.config.ScheduledTaskRegistrar#scheduleTasks

4. 通过scheduleTasks方法中可以看到，在执行时，会检查是否有自定义线程池，如果没有，那么会创建一个SingleThreadSchedulePool 作为线程池执行

   

   [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-vLHH8D3n-1651588669675)(https://cdn.jsdelivr.net/gh/chenliang15405/picture/hub/cs/image-20220503221258957.png)]

看到这里，已经很明显了，在使用的时候，没有自定义线程池，所以导致在执行任务的时候，Spring会自动创建一个线程池去执行，但是这个默认的线程池是一个核心线程为1的单线程的线程池

解决方案

• 第一种：全局配置

  这种方式相当于切面的方式，对统一的定时任务对处理，无需关注每个定时任务的线程池配置

  @Configuration
  @EnableScheduling
  public class ScheduleConfig implements SchedulingConfigurer 
  
  
      @Override
      public void configureTasks(ScheduledTaskRegistrar taskRegistrar) 
          taskRegistrar.setScheduler(Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors()));
      
  
  
  

• 第二种：自定义线程池

  这种方式可以根据业务逻辑以及定时任务的重要性，配置不同的线程池，对不同的任务对隔离，互不影响，这种方式配置的定时任务更灵活

  • 配置类

    @EnableAsync
    @Configuration
    public class AsyncScheduleConfig 
    
        @Bean("scheduleExecutor")
        public Executor myAsync() 
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            //最大线程数
            executor.setMaxPoolSize(100);
            //核心线程数
            executor.setCorePoolSize(10);
            //任务队列的大小
            executor.setQueueCapacity(10);
            //线程前缀名
            executor.setThreadNamePrefix("async-schedule-");
            //线程存活时间
            executor.setKeepAliveSeconds(60);
            /**
             * 拒绝处理策略
             * CallerRunsPolicy()：交由调用方线程运行，比如 main 线程。
             * AbortPolicy()：直接抛出异常。
             * DiscardPolicy()：直接丢弃。
             * DiscardOldestPolicy()：丢弃队列中最老的任务。
             */
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
            //线程初始化
            executor.initialize();
            return executor;
        
    
    
    

  • 使用

    只需要在定时任务的注解上面加上@Async注解，并显式指明自定义的线程池名称即可

    @Component
    public class ScheduleTest 
    
        @Async("scheduleExecutor")
        @Scheduled(cron = "0/30 * * * * ?")
        public void task1() 
            System.out.println("task1 start");
            System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
        
    
        @Async("scheduleExecutor")
        @Scheduled(cron = "0/30 * * * * ?")
        public void task2() 
            System.out.println("task2 start");
            System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());
        
    
        @Async("scheduleExecutor")
        @Scheduled(cron = "0/50 * * * * ?")
        public void task3() 
            System.out.println("task3 start");
            System.out.println(Thread.currentThread().getId() + "  " + Thread.currentThread().getName());