开发者

解决多个@Scheduled定时任务执行时个别不执行问题

开发者 https://www.devze.com 2024-08-10 13:06 出处:网络 作者: 在代码的路上奔跑
目录多个@Scheduled定时任务执行时个别不执行原因解决办法@Scheduled多定时任务,重叠执行总结多个@Scheduled定时任务执行时个别不执行
目录
  • 多个@Scheduled定时任务执行时个别不执行
    • 原因
    • 解决办法
  • @Scheduled多定时任务,重叠执行
    • 总结

      多个@Scheduled定时任务执行时个别不执行

      原因

      项目在启动时,如果没有指定线程池的大小,默认会创建核心线程数为1的默认线程池,故而当项目中出现多个@Scheduled线程时,只能一个个的执行,从而导致个别线程执行时间过长(或长期执行)时,其他定时器不能按照指定的规则进行执行。

      解决办法

      1、配置执行线程池的大小

      spring.task.scheduling.pool.size=10

      2.将定时器设置为异步线程

      /**
      异步线程
      定时器延迟1秒启动,每距上一次执行完成后间隔3秒执行一次
      */
      @Async(“taskExecutor”)
      @Scheduled(initialDelay = 1000L, fixedDelay = 3000L)
      public void test(){System.out.println(“—”+System.currentTimeMillis());//业务内容
      }

      @Scheduled多定时任务,重叠执行

      @Scheduled如果有两个定时任务,定时任务重复时,只有一个可以执行。如下

      import org.springframework.scheduling.annotation.Scheduled;
      import org.springframework.stereotype.Component;
       
      import Java.time.LocalDateTime;
       
      @Component
      public class MyScheduled {
       
          @Scheduled(cron = "0/5 * * * * ?")
          public void execute1(){
              String curName = Thread.currentThread().getName() ;
              System.ouandroidt.println("当前时间:"+LocalDateTime.now()+"  任务execute1对应的线程名: "+curName);
              try {
                  Thread.sleep(1000);
              } catch (Exception e) {
                  e.printStackTrace();
              }
       
          }
       
          @Scheduled(cron = "0/5 * * * * ?")
          public void execute2(){
       
              String curName = Thread.currentThread().getName() ;
              System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute2对应的线程名: "+curName);
              try {
                  Thread.sleep(1000);
              } catch (InterruptedException e) {
                  e.printStackTrace();
              }
          }
      }

      通过执行可以看到,打印线程名称为同一个。即如果不手动指定线程池,则默认启动单线程,进行执行定时任务。

      如果想要多个定时任务重叠执行,需要手动指定线程池,如下

      import org.springframework.context.annotation.Bean;
      import org.springframework.scheduling.TaskScheduler;
      import org.springframework.scheduling.annotation.EnableScheduling;
      import org.springframework.scheduling.annotation.Scheduled;
      import org.sprphpingframework.scheduling.concurrent.ThreadPoolTaskScheduler;
      import org.springframework.stereotype.Component;
       
      import java.time.LocalDateTime;
       
      @Component
      @EnableScheduling
      public class MyScheduled {
       
          @Bean
          public TaskScheduler taskScheduler() {
              ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
              taskScheduler.setPoolSize(50);
              return taskScheduler;
          }
       
          @Scheduled(cron = "0/5 * * * * ?")
          public void execute1(){
              String curName = Thread.currentThread().getName() ;
              System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute1对应的线程名: "+curName);
              try {
                 编程客栈 Threa编程d.sleep(1000);
              } catch (Exception e) {
                  e.printStackTrace();
              }
       
          }
       
          @Scheduled(cron = "0/5 * * * * ?")
          public void execute2(){
       
              String curName = Thread.currentTphphread().getName() ;
              System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute2对应的线程名: "+curName);
              try {
                  Thread.sleep(1000);
              } catch (InterruptedException e) {
                  e.printStackTrace();
              }
          }
      }

      此时,多个定时任务,是不通的线程执行,同时,定时任务可以重叠执行。

      总结

      以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程客栈(www.devze.com)。

      0

      精彩评论

      暂无评论...
      验证码 换一张
      取 消

      关注公众号