您好,登錄后才能下訂單哦!
Java 中怎么實現一個定時任務,針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
實現邏輯:
新開一個線程,添加一個 for/ while 死循環,然后在死循環里面添加一個 sleep 休眠邏輯,讓程序每隔 N 秒休眠再執行一次,這樣就達到了一個簡單定時任務的效果。
實現代碼如下:
/** * 休眠實現定時任務 * 來源公眾號:Java技術棧 */ private static void sleepTask() { new Thread(() -> { while (true) { System.out.println("hi, 歡迎關注:Java技術棧"); try { // 每隔3秒執行一次 Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); }
這種方式比較傻瓜化了,只能按固定頻率運行,不能指定具體運行的時間。
另外,上面的箭頭語法,棧長使用了 JDK 8 中的 Lambda 表達式,這里就不再撰述了。
2、Timer
來看下 JDK 自帶的 java.util.Timer 類:
JDK 1.3 就內置了 java.util.Timer 類,可以用來調度 java.util.TimerTask 任務。
幾個重要的方法:
schedule:開始調度任務,提供了幾個包裝方法;
cancle:終止任務調度,取消當前調度的所有任務,正在運行的任務不受影響;
purge:從任務隊列中移除所有已取消的任務;
另外,java.util.TimerTask 就是實現了 Runnable 接口,具體任務邏輯則是在 run 方法里去實現。
實現代碼如下:
/** * timer定時任務 * 來源公眾號:Java技術棧 */ private static void timerTask() throws InterruptedException { Timer timer = new Timer(); TimerTask timerTask = new TimerTask() { @Override public void run() { System.out.println("hi, 歡迎關注:Java技術棧"); } }; // 第一次任務延遲時間 long delay = 2000; // 任務執行頻率 long period = 3 * 1000; // 開始調度 timer.schedule(timerTask, delay, period); // 指定首次運行時間 // timer.schedule(timerTask, DateUtils.addSeconds(new Date(), 5), period); Thread.sleep(20000); // 終止并移除任務 timer.cancel(); timer.purge(); }
這種實現方式比較簡單,可以指定首次執行的延遲時間、首次執行的具體日期時間,以及執行頻率,能滿足日常需要。
另外,需要注意的是,Timer 是線程安全的,因為背后是單線程在執行所有任務。
Timer 也會有一些缺陷:
Timer 是單線程的,假如有任務 A,B,C,任務 A 如果執行時間比較長,那么就會影響任務 B,C 的啟動和執行時間,如果 B,C 執行時間也比較長,那就會相互影響;
Timer 不會捕獲異常,如果 A,B,C 任何一個任務在執行過程中發生異常,就會導致 TImer 整個定時任務停止工作;
Timer 是基于絕對時間調度的,而不是基于相對時間,所以它對系統時間的改變非常敏感;
所以,如果在使用 Timer 的過程中要注意這些缺陷,雖然可以用,但不推薦。
3、ScheduledExecutorService
因 Timer 有一些缺陷,所以不太建議使用 Timer,推薦使用 ScheduledExecutorService:
ScheduledExecutorService 即是 Timer 的替代者,JDK 1.5 并發包引入,是基于線程池設計的定時任務類:
java.util.concurrent.Executors.newScheduledThreadPool
上了線程池,每個調度任務都會分配到線程池中的某一個線程去執行,任務就是并發調度執行的,任務之間互不影響。
幾個重要的調度方法:
schedule:只執行一次調度;
scheduleAtFixedRate:按固定頻率調度,如果執行時間過長,下一次調度會延遲,不會同時執行;
scheduleWithFixedDelay:延遲調度,上一次執行完再加上延遲時間后執行;
另外,可以看出,任務是支持 Runnable 和 Callable 調度的。
實現代碼如下:
/** * 線程池定時任務 * 來源公眾號:Java技術棧 */ public static void poolTask(){ ScheduledExecutorService pool = Executors.newScheduledThreadPool(10); pool.scheduleAtFixedRate(() -> { System.out.println("hi, 歡迎關注:Java技術棧"); }, 2000, 3000, TimeUnit.MILLISECONDS); }
關于Java 中怎么實現一個定時任務問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業資訊頻道了解更多相關知識。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。