Springboot定時任務Scheduled重複執行操作

阿新 • • 發佈：2020-10-01

今天用scheduled寫定時任務的時候發現定時任務一秒重複執行一次，而我的cron表示式為 * 0/2 * * * * 。

在原始碼除錯的過程中，發現是我的定時任務執行過程太短導致的。

於是我另外寫了個簡單的定時任務

@Component
public class TestJob {
 @Scheduled(cron = "* 0/2 * * * *")
 public void test() {
 System.out.println("測試開始");
 System.out.println("測試結束");
 }
}

上述任務在啟動之後一直執行。

然後我在任務後面加入執行緒睡眠1分鐘。

@Component
public class TestJob {
 @Scheduled(cron = "* 0/2 * * * *")
 public void test() {
 System.out.println("測試開始");
 System.out.println("測試結束");
 try {
  Thread.sleep(60000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 System.out.println("睡眠結束");
 }
}

上述任務執行一次就沒有再執行了。

所以我繼續深入檢視原始碼，發現問題在於CronSequenceGenerator.class的next方法。

public Date next(Date date) {
    Calendar calendar = new GregorianCalendar();
    calendar.setTimeZone(this.timeZone);
    calendar.setTime(date);
   //1.設定下次執行時間的毫秒為0，如上次任務執行過程不足1秒，則calendar的時間會被設定成上次任務的執行時間
    calendar.set(14,0);
    long originalTimestamp = calendar.getTimeInMillis();
    this.doNext(calendar,calendar.get(1));
   //2.由於有上面一步，執行時間太短，會導致下述條件為true
    if(calendar.getTimeInMillis() == originalTimestamp) {
   //3.calendar在原來的時間上增加1秒
      calendar.add(13,1);
   //CronSequenceGenerator的doNext演算法從指定時間開始(包括指定時間)查詢符合cron表示式規則下一個匹配的時間
   //注意第一個匹配符是*，由於增加了1秒，依然符合cron="* 0/2 * * * *"，所以下一個執行時間就是在原來的基礎上增加了一秒
      this.doNext(calendar,calendar.get(1));
    }
    return calendar.getTime();
  }

請檢視程式碼中的註釋，由於任務執行時間太短了，程式碼會進入if語句，並設定執行時間在原來的基礎上增加一秒。

但由於增加一秒後的時間戳依然符合cron表示式，於是在執行完程式碼後一秒，任務又開始執行了。

解決辦法：

程式執行時間太短沒有關係，只要cron表示式秒的匹配符不設定為*就可以了。

cron表示式可以設定為"0 0/2 * * * *"，這樣在執行到next方法中的doNext方法時就會發現時間增加1秒不符合cron表示式了，從而去尋找下一個合適的執行時間。

補充知識：SpringBoot 定時器/定時任務：在一個指定的週期時間內，執行某一項任務。

說多都是累，直接上程式碼：

實現方式有三種(可能還有更多的實現，這三種只是樓主目前所知道的)：

1、靜態定時器，無法修改週期

@Configuration("myScheduled")
@EnableScheduling
public class ScheduledDemo{
  //每10秒執行一次
  @Scheduled(cron="0/10 * * * * ?")
  public void timmer(){
 System.out.println("執行任務");
  }
}

2、動態定時器

//通過setCron 方法修改 任務週期
@Component("myScheduled")
public class ScheduledDemo implements SchedulingConfigurer{
 //預設的任務週期為 10秒
 private String cron = "0/10 * * * * ?";
 
 @Override
 public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
 // TODO Auto-generated method stub
 taskRegistrar.addTriggerTask(new Runnable() {
 
  @Override
  public void run() {
  // TODO Auto-generated method stub
  System.out.println("執行任務");
  }
  
 },new Trigger() {
  @Override
  public Date nextExecutionTime(TriggerContext triggerContext) {
  return new CronTrigger(cron).nextExecutionTime(triggerContext);
  }
 });
 }
 
 public void setCron(String cron) {
 this.cron = cron;
 }
}

3、動態定時器：多執行緒定時任務執行，可以設定執行執行緒池數（預設一個執行緒）

@Component("myScheduled")
public class ScheduledImpl{
 private ScheduledFuture<?> future;
 
 @Autowired
 private ThreadPoolTaskScheduler threadPoolTaskScheduler;
 
 @Bean
 public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
 return new ThreadPoolTaskScheduler();
 }
 
 @Override
 public void setCron(final String cron) {
 stopCron();
 future = threadPoolTaskScheduler.schedule(new Runnable() {
  @Override
  public void run() {
  // TODO Auto-generated method stub
  System.out.println("執行任務");
  }
 },new Trigger() {
  @Override
  public Date nextExecutionTime(TriggerContext triggerContext) {
  if(cron==null || "".equals(cron)) {
   return null;
  }
  CronTrigger cronTrigger = new CronTrigger(cron);
  return cronTrigger.nextExecutionTime(triggerContext);
  }
 });
 }
 
 @Override
 public void stopCron() {
 if(future!=null) {
  future.cancel(true);
 }
 } 
}

cron 的引數說明，詳細說明直接網上搜吧！

大概說明：秒分時日月星期年（可省略）

/ 後面表示週期

- 表示範圍

星期一般用 ? ，為了防止和日混淆，如果星期有值，則日用 ?

“0/10 * * * * ?”表示每10秒

“0 0/10 * * * ?”表示每10分

以上這篇Springboot定時任務Scheduled重複執行操作就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支援我們。