timer在JDK裡面,是很早的一個API了。具有延時的,並具有周期性的任務,在newScheduledThreadPool出來之前我們一般會用Timer和TimerTask來做,但是Timer存在一些缺陷,為什麼這麼說呢?
Timer只創建唯一的線程來執行所有Timer任務。如果一個timer任務的執行很耗時,會導致其他TimerTask的時效準確性出問題。例如一個TimerTask每10秒執行一次,而另外一個TimerTask每40ms執行一次,重複出現的任務會在後來的任務完成後快速連續的被調用4次,要么完全“丟失”4次調用。 Timer的另外一個問題在於,如果TimerTask拋出未檢查的異常會終止timer線程。這種情況下,Timer也不會重新回複線程的執行了;它錯誤的認為整個Timer都被取消了。此時已經被安排但尚未執行的TimerTask永遠不會再執行了,新的任務也不能被調度了。
這裡做了一個小的demo 來復現問題,代碼如下:
package com.hjc;import java.util.Timer;import java.util.TimerTask;/** * Created by cong on 2018/7/12. */public class TimerTest { //創建定時器對象static Timer timer = new Timer(); public static void main(String[] args) { //添加任務1,延遲500ms執行timer.schedule(new TimerTask() { @Override public void run() { System.out.println("---one Task---"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } throw new RuntimeException("error "); } }, 500); //添加任務2,延遲1000ms執行timer.schedule(new TimerTask() { @Override public void run() { for (;;) { System.out.println("---two Task---"); try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }, 1000); }}如上代碼先添加了一個任務在500ms 後執行,然後添加了第二個任務在1s 後執行,我們期望的是當第一個任務輸出---one Task--- 後等待1s 後第二個任務會輸出---two Task---,
但是執行完畢代碼後輸出結果如下所示:
例子2,
public class Shedule { private static long start; public static void main(String[] args) { TimerTask task = new TimerTask() { public void run() { System.out.println(System.currentTimeMillis()-start); try{ Thread.sleep(3000); }catch (InterruptedException e){ e.printStackTrace(); } } }; TimerTask task1 = new TimerTask() { @Override public void run() { System.out.println(System.currentTimeMillis()-start); } }; Timer timer = new Timer(); start = System.currentTimeMillis(); //啟動一個調度任務,1S鐘後執行timer.schedule(task,1000); //啟動一個調度任務,3S鐘後執行timer.schedule(task1,3000); }}上面程序我們預想是第一個任務執行後,第二個任務3S後執行的,即輸出一個1000,一個3000.
實際運行結果如下:
實際運行結果並不如我們所願。世界結果,是過了4S後才輸出第二個任務,即4001約等於4秒。那部分時間時間到哪裡去了呢?那個時間是被我們第一個任務的sleep所佔用了。
現在我們在第一個任務中去掉Thread.sleep();這一行代碼,運行是否正確了呢?運行結果如下:
可以看到確實是第一個任務過了1S後執行,第二個任務在第一個任務執行完後過3S執行了。
這就說明了Timer只創建唯一的線程來執行所有Timer任務。如果一個timer任務的執行很耗時,會導致其他TimerTask的時效準確性出問題。
Timer 實現原理分析
下面簡單介紹下Timer 的原理,如下圖是Timer 的原理模型介紹:
1.其中TaskQueue 是一個平衡二叉樹堆實現的優先級隊列,每個Timer 對象內部有唯一一個TaskQueue 隊列。用戶線程調用timer 的schedule 方法就是把TimerTask 任務添加到TaskQueue 隊列,在調用schedule 的方法時候long delay 參數用來說明該任務延遲多少時間執行。
2.TimerThread 是具體執行任務的線程,它從TaskQueue 隊列裡面獲取優先級最小的任務進行執行,需要注意的是只有執行完了當前的任務才會從隊列裡面獲取下一個任務而不管隊列裡面是否有已經到了設置的delay 時間,一個Timer 只有一個TimerThread 線程,所以可知Timer 的內部實現是一個多生產者單消費者模型。
從實現模型可以知道要探究上面的問題只需看TimerThread 的實現就可以了,TimerThread 的run 方法主要邏輯源碼如下:
public void run() { try { mainLoop(); } finally { // 有人殺死了這個線程,表現得好像Timer已取消synchronized(queue) { newTasksMayBeScheduled = false; queue.clear(); // 消除過時的引用} }} private void mainLoop() { while (true) { try { TimerTask task; boolean taskFired; //從隊列裡面獲取任務時候要加鎖synchronized(queue) { ...... } if (taskFired) task.run();//執行任務} catch(InterruptedException e) { } } }可知當任務執行過程中拋出了除InterruptedException 之外的異常後,唯一的消費線程就會因為拋出異常而終止,那麼隊列裡面的其他待執行的任務就會被清除。所以TimerTask 的run 方法內最好使用try-catch 結構catch 主可能的異常,不要把異常拋出到run 方法外。
其實要實現類似Timer 的功能使用ScheduledThreadPoolExecutor 的schedule 是比較好的選擇。 ScheduledThreadPoolExecutor 中的一個任務拋出了異常,其他任務不受影響的。
ScheduledThreadPoolExecutor 例子如下:
/** * Created by cong on 2018/7/12. */public class ScheduledThreadPoolExecutorTest { static ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1); public static void main(String[] args) { scheduledThreadPoolExecutor.schedule(new Runnable() { public void run() { System.out.println("---one Task---"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } throw new RuntimeException("error "); } }, 500, TimeUnit.MICROSECONDS); scheduledThreadPoolExecutor.schedule(new Runnable() { public void run() { for (int i =0;i<5;++i) { System.out.println("---two Task---"); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }, 1000, TimeUnit.MICROSECONDS); scheduledThreadPoolExecutor.shutdown(); }}運行結果如下:
之所以ScheduledThreadPoolExecutor 的其他任務不受拋出異常的任務的影響是因為ScheduledThreadPoolExecutor 中的ScheduledFutureTask 任務中catch 掉了異常,但是在線程池任務的run 方法內使用catch 捕獲異常並打印日誌是最佳實踐。