溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

Java 中怎么實現(xiàn)一個定時任務(wù)

發(fā)布時間:2021-08-09 15:22:32 來源:億速云 閱讀:169 作者:Leah 欄目:編程語言

Java 中怎么實現(xiàn)一個定時任務(wù),針對這個問題,這篇文章詳細介紹了相對應(yīng)的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

實現(xiàn)邏輯:

新開一個線程,添加一個 for/ while 死循環(huán),然后在死循環(huán)里面添加一個 sleep 休眠邏輯,讓程序每隔 N  秒休眠再執(zhí)行一次,這樣就達到了一個簡單定時任務(wù)的效果。

實現(xiàn)代碼如下:

/**  * 休眠實現(xiàn)定時任務(wù)  * 來源公眾號:Java技術(shù)棧  */ private static void sleepTask() {     new Thread(() -> {         while (true) {             System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");              try {                 // 每隔3秒執(zhí)行一次                 Thread.sleep(3000);             } catch (InterruptedException e) {                 e.printStackTrace();             }         }     }).start(); }

這種方式比較傻瓜化了,只能按固定頻率運行,不能指定具體運行的時間。

另外,上面的箭頭語法,棧長使用了 JDK 8 中的 Lambda 表達式,這里就不再撰述了。

2、Timer

來看下 JDK 自帶的 java.util.Timer 類:

Java 中怎么實現(xiàn)一個定時任務(wù)

JDK 1.3 就內(nèi)置了 java.util.Timer 類,可以用來調(diào)度 java.util.TimerTask 任務(wù)。

Java 中怎么實現(xiàn)一個定時任務(wù)

幾個重要的方法:

  • schedule:開始調(diào)度任務(wù),提供了幾個包裝方法;

  • cancle:終止任務(wù)調(diào)度,取消當前調(diào)度的所有任務(wù),正在運行的任務(wù)不受影響;

  • purge:從任務(wù)隊列中移除所有已取消的任務(wù);

另外,java.util.TimerTask 就是實現(xiàn)了 Runnable 接口,具體任務(wù)邏輯則是在 run 方法里去實現(xiàn)。

Java 中怎么實現(xiàn)一個定時任務(wù)

實現(xiàn)代碼如下:

/**  * timer定時任務(wù)  * 來源公眾號:Java技術(shù)棧  */ private static void timerTask() throws InterruptedException {     Timer timer = new Timer();      TimerTask timerTask = new TimerTask() {         @Override         public void run() {             System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");         }     };      // 第一次任務(wù)延遲時間     long delay = 2000;      // 任務(wù)執(zhí)行頻率     long period = 3 * 1000;      // 開始調(diào)度     timer.schedule(timerTask, delay, period);          // 指定首次運行時間 // timer.schedule(timerTask, DateUtils.addSeconds(new Date(), 5), period);      Thread.sleep(20000);      // 終止并移除任務(wù)     timer.cancel();     timer.purge(); }

這種實現(xiàn)方式比較簡單,可以指定首次執(zhí)行的延遲時間、首次執(zhí)行的具體日期時間,以及執(zhí)行頻率,能滿足日常需要。

另外,需要注意的是,Timer 是線程安全的,因為背后是單線程在執(zhí)行所有任務(wù)。

Timer 也會有一些缺陷:

  • Timer 是單線程的,假如有任務(wù) A,B,C,任務(wù) A 如果執(zhí)行時間比較長,那么就會影響任務(wù) B,C 的啟動和執(zhí)行時間,如果 B,C  執(zhí)行時間也比較長,那就會相互影響;

  • Timer 不會捕獲異常,如果 A,B,C 任何一個任務(wù)在執(zhí)行過程中發(fā)生異常,就會導(dǎo)致 TImer 整個定時任務(wù)停止工作;

  • Timer 是基于絕對時間調(diào)度的,而不是基于相對時間,所以它對系統(tǒng)時間的改變非常敏感;

所以,如果在使用 Timer 的過程中要注意這些缺陷,雖然可以用,但不推薦。

3、ScheduledExecutorService

因 Timer 有一些缺陷,所以不太建議使用 Timer,推薦使用 ScheduledExecutorService:

Java 中怎么實現(xiàn)一個定時任務(wù)

ScheduledExecutorService 即是 Timer 的替代者,JDK 1.5 并發(fā)包引入,是基于線程池設(shè)計的定時任務(wù)類:

java.util.concurrent.Executors.newScheduledThreadPool

Java 中怎么實現(xiàn)一個定時任務(wù)

上了線程池,每個調(diào)度任務(wù)都會分配到線程池中的某一個線程去執(zhí)行,任務(wù)就是并發(fā)調(diào)度執(zhí)行的,任務(wù)之間互不影響。

幾個重要的調(diào)度方法:

Java 中怎么實現(xiàn)一個定時任務(wù)

  • schedule:只執(zhí)行一次調(diào)度;

  • scheduleAtFixedRate:按固定頻率調(diào)度,如果執(zhí)行時間過長,下一次調(diào)度會延遲,不會同時執(zhí)行;

  • scheduleWithFixedDelay:延遲調(diào)度,上一次執(zhí)行完再加上延遲時間后執(zhí)行;

另外,可以看出,任務(wù)是支持 Runnable 和 Callable 調(diào)度的。

實現(xiàn)代碼如下:

/**  * 線程池定時任務(wù)  * 來源公眾號:Java技術(shù)棧  */ public static void poolTask(){     ScheduledExecutorService pool = Executors.newScheduledThreadPool(10);      pool.scheduleAtFixedRate(() -> {         System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");     }, 2000, 3000, TimeUnit.MILLISECONDS); }

關(guān)于Java 中怎么實現(xiàn)一個定時任務(wù)問題的解答就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識。

向AI問一下細節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI