Spring @Scheduler使用cron表達式時的執行問題詳解

前言

Spring Scheduler里有兩個概念：任務（Task）和運行任務的框架（TaskExecutor/TaskScheduler）。TaskExecutor顧名思義，是任務的執行器，允許我們異步執行多個任務。TaskScheduler是任務調度器，來運行未來的定時任務。觸發器Trigger可以決定定時任務是否該運行了，最常用的觸發器是CronTrigger。Spring內置了多種類型的TaskExecutor和TaskScheduler，方便用戶根據不同業務場景選擇。

本文主要介紹了關于Spring @Scheduler使用cron表達式執行問題的相關內容，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧

主要想弄清使用Spring @Scheduler cron表達式時的兩個問題：

• 同一定時任務，第二次觸發時間到了，第一次還沒有執行完成時會執行嗎？
• 不同的定時任務，相互之間是否有影響？

結論寫在前面：

• 同一定時任務，第二次觸發時間到了，第一次還沒有執行完成時會執行嗎？不會，會等前一次執行完成才執行下一次
• 不同的定時任務，相互之間是否有影響？取決于可用的定時任務線程數，如果線程數足夠則不會影響；如果可用定時任務線程數少于要執行定時任務數量，未能獲取到線程的自然要等到有空閑線程時才能執行。

下面是實驗過程。。。。。

使用Spring @Scheduler 時，默認只有一個線程，針對上面的問題，設計了3個實驗：

1. 設置Scheduler為多線程，設置一個線程5秒執行一次，方法體為 sleep8秒
2. 使用Scheduler默認的單線程，設置兩個線程都是5秒執行一次，一個 sleep8秒，一個不sleep
3. 設置Scheduler為多線程，設置兩個線程都是5秒執行一次，一個 sleep8秒，一個不sleep

實驗一

設置Scheduler為多線程，設置一個線程5秒執行一次，方法體為 sleep8秒：

 @Scheduled(cron = "*/5 * * * * *")
 public void test1() throws InterruptedException {
 log.info("test1, 5秒執行一次，每次執行sleep 8s");
 Thread.sleep(8000L);
 }

結果：

2017-10-11 17:49:45 scheduler-1 test1, 5秒執行一次，每次執行sleep 8
2017-10-11 17:49:55 scheduler-1 test1, 5秒執行一次，每次執行sleep 8
2017-10-11 17:50:05 scheduler-1 test1, 5秒執行一次，每次執行sleep 8
2017-10-11 17:50:15 scheduler-2 test1, 5秒執行一次，每次執行sleep 8
2017-10-11 17:50:25 scheduler-2 test1, 5秒執行一次，每次執行sleep 8
2017-10-11 17:50:35 scheduler-1 test1, 5秒執行一次，每次執行sleep 8

結論：

@Scheduled使用cron表達式，設置為多線程時，同一任務前一次沒有執行完成，不會執行下一次

實驗二

使用Scheduler默認的單線程，設置兩個線程都是5秒執行一次，一個 sleep8秒，一個不sleep

如果test2每8秒執行一次，則為串行

 @Scheduled(cron = "*/5 * * * * *")
 public void test1() throws InterruptedException {
 System.out.println("test1, 5秒執行一次，每次執行sleep 8s");
 Thread.sleep(8000L);
 }

 @Scheduled(cron = "*/5 * * * * *")
 public void test2() {
 System.out.println("test2, 5秒執行一次，不sleep");
 }

執行結果：

2017-10-11 17:17:35 test2, 5秒執行一次，不sleep
2017-10-11 17:17:35 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 17:17:43 test2, 5秒執行一次，不sleep
2017-10-11 17:17:45 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 17:17:53 test2, 5秒執行一次，不sleep
2017-10-11 17:17:55 test2, 5秒執行一次，不sleep
2017-10-11 17:17:55 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 17:18:03 test2, 5秒執行一次，不sleep
2017-10-11 17:18:05 test2, 5秒執行一次，不sleep
2017-10-11 17:18:05 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 17:18:13 test2, 5秒執行一次，不sleep
2017-10-11 17:18:15 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 17:18:23 test2, 5秒執行一次，不sleep
2017-10-11 17:18:25 test1, 5秒執行一次，每次執行sleep 8s

對比期望執行時間：

結論：

@Scheduled使用cron表達式 ，配置為一個線程時，不同定時任務是串行執行，且上次沒有執行完時不會執行下次

實驗三

設置Scheduler為多線程，設置兩個線程都是5秒執行一次，一個 sleep8秒，一個不sleep

 @Scheduled(cron = "*/5 * * * * *")
 public void test1() throws InterruptedException {
  log.info("test1, 5秒執行一次，每次執行sleep 8s");
  Thread.sleep(8000L);
 }

 @Scheduled(cron = "*/5 * * * * *")
 public void test2() {
  log.info("test2, 5秒執行一次，不sleep");
 }

結果：

2017-10-11 18:12:40 scheduler-2 test2, 5秒執行一次，不sleep
2017-10-11 18:12:40 scheduler-1 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 18:12:45 scheduler-2 test2, 5秒執行一次，不sleep
2017-10-11 18:12:50 scheduler-1 test1, 5秒執行一次，每次執行sleep 8s
2017-10-11 18:12:50 scheduler-2 test2, 5秒執行一次，不sleep
2017-10-11 18:12:55 scheduler-2 test2, 5秒執行一次，不sleep
2017-10-11 18:13:00 scheduler-1 test1, 5秒執行一次，每次執行sleep 8s

對比期望執行時間：

結論：

@Scheduled使用cron表達式 ，配置為多線程時，不同定時任務不是串行執行，且上次沒有執行完時不會執行下次

設置定時任務為多線程

這里用的是spring boot：

@Configuration
public class ScheduleConfig {

 @Bean
 public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
  ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
  scheduler.setPoolSize(3);
  scheduler.setThreadNamePrefix("scheduler-");
  return scheduler;
 }
}

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對億速云的支持。