定時任務怎么樣避免并發，意思是同一個任務當第一個執行完了，第二才執行，不是一到了間隔時間，不管第一個是否執行完成，第二個就開始執行。

下面小弟整理的筆記

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

cron

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

表達式就不建議去記怎么玩了，點擊去在線生成即可

fixedRate

fixedRate表示自上一次執行時間之后多長時間執行，以ms為單位

fixedDelay

fixedDelay與fixedRate有點類似，不過fixedRate是上一次開始之后計時，fixedDelay是上一次結束之后計時，也就是說，fixedDelay表示上一次執行完畢之后多長時間執行，單位也是ms

initialDelay

initialDelay表示首次延遲多長時間后執行，單位ms，之后按照其他屬性指定的規則執行，需要指定別的屬性其中一個規則

下面是玩的過程 spring boot項目

正常玩

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

輸出結果

可以看出是單線程環境，但是不滿足我要求，然后看到說可以加個注解實現異步

其中一個方法加上@Async啟用異步

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

輸出結果

但是這樣不行，可能我上個任務數據太多都沒執行完成，這也就會導致數據重復消費了，不科學，繼續找

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

fixedRate走一波

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

輸出結果

假裝有圖，結果同上，不管執行不，到點就執行

fixedDelay走一波

是否可以就看這個了，畢竟fixedDelay這個屬性表示上一次執行完畢之后多長時間執行，看字面意思，結束了，才會執行下一次，心心念念的走一波

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

見證奇跡的輸出結果

假裝有結果吧，我都不想看

結論

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

問題

• 只有一個任務單獨執行，其他任務依然共用一個線程
• 單獨執行的這個任務，需要操作數據庫，所以只能一個時間只能有一個線程在執行
• 這個定時任務，每分鐘執行一次，大多數時候沒有數據操作
• 有數據的時候，一般執行三到五分鐘

所以問題來了，每分鐘執行一次，有數據的時候，此任務沒有執行完成，單線程的時候，會被其他定時任務阻塞，針對這個定時任務，開啟異步處理，那此任務就會在沒有執行完成的時候，下個一分鐘間隔到來前又執行一次

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

上面已解決

代碼

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

輸出結果

現在有個小問題

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。