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

對比期望執行時間:

執行次數 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;
    }

}


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM