Springboot定時(shí)任務(wù)Scheduled重復(fù)執(zhí)行操作
今天用scheduled寫定時(shí)任務(wù)的時(shí)候發(fā)現(xiàn)定時(shí)任務(wù)一秒重復(fù)執(zhí)行一次,而我的cron表達(dá)式為 * 0/2 * * * * 。
在源碼調(diào)試的過(guò)程中,發(fā)現(xiàn)是我的定時(shí)任務(wù)執(zhí)行過(guò)程太短導(dǎo)致的。
于是我另外寫了個(gè)簡(jiǎn)單的定時(shí)任務(wù)
@Component public class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("測(cè)試開(kāi)始"); System.out.println("測(cè)試結(jié)束"); } }
上述任務(wù)在啟動(dòng)之后一直執(zhí)行。
然后我在任務(wù)后面加入線程睡眠1分鐘。
@Component public class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("測(cè)試開(kāi)始"); System.out.println("測(cè)試結(jié)束"); try { Thread.sleep(60000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("睡眠結(jié)束"); } }
上述任務(wù)執(zhí)行一次就沒(méi)有再執(zhí)行了。
所以我繼續(xù)深入查看源碼,發(fā)現(xiàn)問(wèn)題在于CronSequenceGenerator.class的next方法。
public Date next(Date date) { Calendar calendar = new GregorianCalendar(); calendar.setTimeZone(this.timeZone); calendar.setTime(date); //1.設(shè)置下次執(zhí)行時(shí)間的毫秒為0,如上次任務(wù)執(zhí)行過(guò)程不足1秒,則calendar的時(shí)間會(huì)被設(shè)置成上次任務(wù)的執(zhí)行時(shí)間 calendar.set(14, 0); long originalTimestamp = calendar.getTimeInMillis(); this.doNext(calendar, calendar.get(1)); //2.由于有上面一步,執(zhí)行時(shí)間太短,會(huì)導(dǎo)致下述條件為true if(calendar.getTimeInMillis() == originalTimestamp) { //3.calendar在原來(lái)的時(shí)間上增加1秒 calendar.add(13, 1); //CronSequenceGenerator的doNext算法從指定時(shí)間開(kāi)始(包括指定時(shí)間)查找符合cron表達(dá)式規(guī)則下一個(gè)匹配的時(shí)間 //注意第一個(gè)匹配符是*,由于增加了1秒,依然符合cron="* 0/2 * * * *",所以下一個(gè)執(zhí)行時(shí)間就是在原來(lái)的基礎(chǔ)上增加了一秒 this.doNext(calendar, calendar.get(1)); } return calendar.getTime(); }
請(qǐng)查看代碼中的注釋,由于任務(wù)執(zhí)行時(shí)間太短了,代碼會(huì)進(jìn)入if語(yǔ)句,并設(shè)置執(zhí)行時(shí)間在原來(lái)的基礎(chǔ)上增加一秒。
但由于增加一秒后的時(shí)間戳依然符合cron表達(dá)式,于是在執(zhí)行完代碼后一秒,任務(wù)又開(kāi)始執(zhí)行了。
解決辦法:
程序執(zhí)行時(shí)間太短沒(méi)有關(guān)系,只要cron表達(dá)式秒的匹配符不設(shè)置為*就可以了。
cron表達(dá)式可以設(shè)置為"0 0/2 * * * *",這樣在執(zhí)行到next方法中的doNext方法時(shí)就會(huì)發(fā)現(xiàn)時(shí)間增加1秒不符合cron表達(dá)式了,從而去尋找下一個(gè)合適的執(zhí)行時(shí)間。
補(bǔ)充知識(shí):SpringBoot 定時(shí)器/定時(shí)任務(wù):在一個(gè)指定的周期時(shí)間內(nèi),執(zhí)行某一項(xiàng)任務(wù)。
說(shuō)多都是累,直接上代碼:
實(shí)現(xiàn)方式有三種(可能還有更多的實(shí)現(xiàn),這三種只是樓主目前所知道的):
1、靜態(tài)定時(shí)器,無(wú)法修改周期
@Configuration("myScheduled") @EnableScheduling public class ScheduledDemo{ //每10秒執(zhí)行一次 @Scheduled(cron="0/10 * * * * ?") public void timmer(){ System.out.println("執(zhí)行任務(wù)"); } }
2、動(dòng)態(tài)定時(shí)器
//通過(guò)setCron 方法修改 任務(wù)周期 @Component("myScheduled") public class ScheduledDemo implements SchedulingConfigurer{ //默認(rèn)的任務(wù)周期為 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("執(zhí)行任務(wù)"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { return new CronTrigger(cron).nextExecutionTime(triggerContext); } }); } public void setCron(String cron) { this.cron = cron; } }
3、動(dòng)態(tài)定時(shí)器:多線程定時(shí)任務(wù)執(zhí)行,可以設(shè)置執(zhí)行線程池?cái)?shù)(默認(rèn)一個(gè)線程)
@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("執(zhí)行任務(wù)"); } }, 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 的參數(shù)說(shuō)明,詳細(xì)說(shuō)明直接網(wǎng)上搜吧!
大概說(shuō)明:秒 分 時(shí) 日 月 星期 年(可省略)
/ 后面表示周期
- 表示范圍
星期一般用 ? ,為了防止和 日 混淆,如果星期有值,則日用 ?
“0/10 * * * * ?”表示每10秒
“0 0/10 * * * ?”表示每10分
以上這篇Springboot定時(shí)任務(wù)Scheduled重復(fù)執(zhí)行操作就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
springmvc+shiro+maven 實(shí)現(xiàn)登錄認(rèn)證與權(quán)限授權(quán)管理
Shiro 是一個(gè) Apache 下的一開(kāi)源項(xiàng)目項(xiàng)目,旨在簡(jiǎn)化身份驗(yàn)證和授權(quán),下面通過(guò)實(shí)例代碼給大家分享springmvc+shiro+maven 實(shí)現(xiàn)登錄認(rèn)證與權(quán)限授權(quán)管理,感興趣的朋友一起看看吧2017-09-09SpringBoot集成SpirePDF實(shí)現(xiàn)文本替換功能
SpirePDF是一個(gè)用于.NET平臺(tái)的高級(jí)PDF文檔處理庫(kù),它提供了一套完整的API,允許開(kāi)發(fā)者創(chuàng)建、編輯、轉(zhuǎn)換、合并、分割和解析PDF文件本文給大家介紹了SpringBoot集成SpirePDF實(shí)現(xiàn)文本替換功能,需要的朋友可以參考下2024-09-09java 中HashMap、HashSet、TreeMap、TreeSet判斷元素相同的幾種方法比較
這篇文章主要介紹了從源碼的角度淺析HashMap、TreeMap元素的存儲(chǔ)和獲取元素的邏輯;從Map與Set之間的關(guān)系淺析常用的Set中元素的存儲(chǔ)和判斷是否重復(fù)的邏輯,需要的朋友可以參考下2017-01-01Mybatis-plus在項(xiàng)目中的簡(jiǎn)單應(yīng)用
Mybatis-plus是Spring框架中OOM的一大利器,其簡(jiǎn)單易用參考官網(wǎng)文檔即可很快上手,本文主要介紹了邏輯刪除,自動(dòng)填充,分頁(yè)插件等的簡(jiǎn)單使用,感興趣的可以了解一下2021-07-07利用java反射機(jī)制調(diào)用類的私有方法(推薦)
下面小編就為大家?guī)?lái)一篇利用java反射機(jī)制調(diào)用類的私有方法(推薦)。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-08-08SpringBoot+Mybatis-Plus實(shí)現(xiàn)mysql讀寫分離方案的示例代碼
這篇文章主要介紹了SpringBoot+Mybatis-Plus實(shí)現(xiàn)mysql讀寫分離方案的示例代碼,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03Springboot?集成spring?cache緩存的解決方案
這篇文章主要介紹了Springboot?集成spring?cache緩存,使用緩存最關(guān)鍵的一點(diǎn)就是保證緩存與數(shù)據(jù)庫(kù)的數(shù)據(jù)一致性,本文給大家介紹最常用的緩存操作模式,對(duì)Springboot?集成spring?cache緩存操作流程感興趣的朋友一起看看吧2022-06-06

JPA中@JoinColumn的name和referencedColumnName屬性的區(qū)別及說(shuō)明