今天用scheduled寫定時任務的時候發現定時任務一秒重復執行一次，而我的cron表達式為 * 0/2 * * * * 。
在源碼調試的過程中，發現是我的定時任務執行過程太短導致的。
于是我另外寫了個簡單的定時任務
|
1
2
3
4
5
6
7
8
|
@Componentpublic class TestJob { public void test() { System.out.println("測試開始"); System.out.println("測試結束"); }} |
上述任務在啟動之后一直執行。
然后我在任務后面加入線程睡眠1分鐘。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@Componentpublic 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方法。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
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、靜態定時器，無法修改周期
|
1
2
3
4
5
6
7
8
9
|
@Configuration("myScheduled")@EnableSchedulingpublic class ScheduledDemo{ //每10秒執行一次 @Scheduled(cron="0/10 * * * * ?") public void timmer(){ System.out.println("執行任務"); }} |
2、動態定時器
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
//通過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、動態定時器：多線程定時任務執行，可以設置執行線程池數（默認一個線程）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
@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重復執行操作就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/has330338724/article/details/80812438
