主要想弄清使用Spring @Scheduler cron表達式時的兩個問題:java
結論寫在前面:spring
下面是實驗過程。。。。。多線程
使用Spring @Scheduler 時,默認只有一個線程,針對上面的問題,設計了3個實驗:線程
設置Scheduler爲多線程,設置一個線程5秒執行一次,方法體爲 sleep8秒:設計
@Scheduled(cron = "*/5 * * * * *") public void test1() throws InterruptedException { log.info("test1, 5秒執行一次,每次執行sleep 8s"); Thread.sleep(8000L); }
結果:code
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 8io
結論:table
@Scheduled使用cron表達式,設置爲多線程時,同一任務前一次沒有執行完成,不會執行下一次class
使用Scheduler默認的單線程,設置兩個線程都是5秒執行一次,一個 sleep8秒,一個不sleepthread
@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
對比指望執行時間:
執行次數 | task | 指望執行時間 | 實際執行時間 |
---|---|---|---|
1 | task1 | 17:17:35 | 17:17:35 |
1 | task2 | 17:17:35 | 17:17:35 |
2 | task1 | 17:17:40 | 17:17:43 |
2 | task2 | 17:17:40 | 17:17:45 |
結論:
@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
對比指望執行時間:
執行次數 | task | 指望執行時間 | 實際執行時間 |
---|---|---|---|
1 | task1 | 18:12:40 | 18:12:40 |
1 | task2 | 18:12:40 | 18:12:40 |
2 | task1 | 18:12:45 | 18:12:50 |
2 | task2 | 18:12:45 | 18:12:45 |
結論:
@Scheduled使用cron表達式 ,配置爲多線程時,不一樣定時任務不是串行執行,且上次沒有執行完時不會執行下次
這裏用的是spring boot:
@Configuration public class ScheduleConfig { @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler(); scheduler.setPoolSize(3); scheduler.setThreadNamePrefix("scheduler-"); return scheduler; } }