定時(shí)任務(wù)怎么樣避免并發(fā)，意思是同一個(gè)任務(wù)當(dāng)?shù)谝粋€(gè)執(zhí)行完了，第二才執(zhí)行，不是一到了間隔時(shí)間，不管第一個(gè)是否執(zhí)行完成，第二個(gè)就開始執(zhí)行。

下面小弟整理的筆記

@Scheduled注解是spring boot提供的用于定時(shí)任務(wù)控制的注解，主要用于控制任務(wù)在某個(gè)指定時(shí)間執(zhí)行，或者每隔一段時(shí)間執(zhí)行，注意需要配合@EnableScheduling使用，配置@Scheduled主要有三種配置執(zhí)行時(shí)間的方式：cron，fixedRate，fixedDelay

cron

cron是@Scheduled的一個(gè)參數(shù)，是一個(gè)字符串，以空格隔開，允許6或7個(gè)域，分別表示秒，分，時(shí)，日，月，周，年

表達(dá)式就不建議去記怎么玩了，點(diǎn)擊去在線生成即可

fixedRate

fixedRate表示自上一次執(zhí)行時(shí)間之后多長(zhǎng)時(shí)間執(zhí)行，以ms為單位

fixedDelay

fixedDelay與fixedRate有點(diǎn)類似，不過(guò)fixedRate是上一次開始之后計(jì)時(shí)，fixedDelay是上一次結(jié)束之后計(jì)時(shí)，也就是說(shuō)，fixedDelay表示上一次執(zhí)行完畢之后多長(zhǎng)時(shí)間執(zhí)行，單位也是ms

initialDelay

initialDelay表示首次延遲多長(zhǎng)時(shí)間后執(zhí)行，單位ms，之后按照其他屬性指定的規(guī)則執(zhí)行，需要指定別的屬性其中一個(gè)規(guī)則

下面是玩的過(guò)程 spring boot項(xiàng)目

正常玩

@Scheduled(cron = "0/10 * * * * ?")public void cs1(){System.out.println("第一個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();try {Thread.sleep(60*1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}@Scheduled(cron = "0/10 * * * * ?")public void cs2(){System.out.println("第二個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();System.out.println("第二個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}

輸出結(jié)果

可以看出是單線程環(huán)境，但是不滿足我要求，然后看到說(shuō)可以加個(gè)注解實(shí)現(xiàn)異步

其中一個(gè)方法加上@Async啟用異步

@Async@Scheduled(cron = "0/10 * * * * ?")public void cs1(){System.out.println("第一個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();try {Thread.sleep(60*1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}@Scheduled(cron = "0/10 * * * * ?")public void cs2(){System.out.println("第二個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();System.out.println("第二個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}

輸出結(jié)果

但是這樣不行，可能我上個(gè)任務(wù)數(shù)據(jù)太多都沒執(zhí)行完成，這也就會(huì)導(dǎo)致數(shù)據(jù)重復(fù)消費(fèi)了，不科學(xué)，繼續(xù)找

網(wǎng)上找了一下，好多地方都推薦這兩個(gè)屬性fixedDelay 和 fixedRate，分別干啥上面寫了

fixedRate走一波

@Async@Scheduled(fixedRate = 1000*10)public void cs1(){System.out.println("第一個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();try {Thread.sleep(60*1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}@Scheduled(cron = "0/10 * * * * ?")public void cs2(){System.out.println("第二個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();System.out.println("第二個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}

輸出結(jié)果

假裝有圖，結(jié)果同上，不管執(zhí)行不，到點(diǎn)就執(zhí)行

fixedDelay走一波

是否可以就看這個(gè)了，畢竟fixedDelay這個(gè)屬性表示上一次執(zhí)行完畢之后多長(zhǎng)時(shí)間執(zhí)行，看字面意思，結(jié)束了，才會(huì)執(zhí)行下一次，心心念念的走一波

@Async@Scheduled(fixedDelay = 1000*10)public void cs1(){System.out.println("第一個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();try {Thread.sleep(60*1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}@Scheduled(cron = "0/10 * * * * ?")public void cs2(){System.out.println("第二個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();System.out.println("第二個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}

見證奇跡的輸出結(jié)果

假裝有結(jié)果吧，我都不想看

結(jié)論

• spring 是單線程的，不管多少個(gè)任務(wù)都是一個(gè)線程再跑
• 某個(gè)方法使用注解 @Async，開啟異步執(zhí)行，那個(gè)其他定時(shí)任務(wù)依然遵循上個(gè)結(jié)論，使用了@Async這個(gè)注解的會(huì)多個(gè)線程執(zhí)行，不管選擇 cron，fixedRate，fixedDelay這三里的誰(shuí)都一樣

問(wèn)題

• 只有一個(gè)任務(wù)單獨(dú)執(zhí)行，其他任務(wù)依然共用一個(gè)線程
• 單獨(dú)執(zhí)行的這個(gè)任務(wù)，需要操作數(shù)據(jù)庫(kù)，所以只能一個(gè)時(shí)間只能有一個(gè)線程在執(zhí)行
• 這個(gè)定時(shí)任務(wù)，每分鐘執(zhí)行一次，大多數(shù)時(shí)候沒有數(shù)據(jù)操作
• 有數(shù)據(jù)的時(shí)候，一般執(zhí)行三到五分鐘

所以問(wèn)題來(lái)了，每分鐘執(zhí)行一次，有數(shù)據(jù)的時(shí)候，此任務(wù)沒有執(zhí)行完成，單線程的時(shí)候，會(huì)被其他定時(shí)任務(wù)阻塞，針對(duì)這個(gè)定時(shí)任務(wù)，開啟異步處理，那此任務(wù)就會(huì)在沒有執(zhí)行完成的時(shí)候，下個(gè)一分鐘間隔到來(lái)前又執(zhí)行一次

咋整！！咋整！！咋整！！！！！

上面已解決

代碼

@Async@Scheduled(cron = "0/10 * * * * ?")public void cs1(){if (i == 1){i++;System.out.println("第一個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();try {Thread.sleep(60*1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("第一個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();i--;}else {System.out.println("定時(shí)任務(wù)未執(zhí)行" + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());}}// @Async@Scheduled(cron = "0/10 * * * * ?")public void cs2(){System.out.println("第二個(gè)定時(shí)任務(wù)開始 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();System.out.println("第二個(gè)定時(shí)任務(wù)結(jié)束 : " + LocalDateTime.now().toLocalTime() +"\r\n線程 : " + Thread.currentThread().getName());System.out.println();}

輸出結(jié)果

現(xiàn)在有個(gè)小問(wèn)題

到時(shí)間之后定時(shí)任務(wù)是另外一個(gè)線程在執(zhí)行，但是我沒有弄線程池，代碼里面也并沒有Thread.sleep(60*1000)這種線程相關(guān)的代碼，那么到時(shí)候新開的線程是怎么樣的，對(duì)線程理解有點(diǎn)弱，如果按照這種寫法會(huì)不會(huì)有問(wèn)題，有問(wèn)題是什么樣的問(wèn)題

總結(jié)

以上是生活随笔為你收集整理的【问题】定时任务整理笔记附问题求大佬解答！！！！的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。