摘自http://www.51testing.com/html/50/n-3721850.html
Timer Demo
public class ThreadTest {
public static void main(String[] args) {
TimerTask task1 = new TimerTask() {
@Override
public void run() {
System.out.println("task1 run ... ?execute time:"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
TimerTask task2 = new TimerTask() {
@Override
public void run() {
System.out.println("task2 run ... ?execute time:"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
try {
TimeUnit.SECONDS.sleep(1);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
Timer t = new Timer();
t.schedule(task1, 0,1000);
t.schedule(task2, 0,1000);
}
}
我們定義了兩個定時任務(wù)汛闸,每個定時任務(wù)的執(zhí)行周期是1秒鐘蝙茶,每秒執(zhí)行一次。
task1 執(zhí)行的時長為2秒鐘, task2 執(zhí)行的時長為1秒鐘诸老。
輸出結(jié)果
task1 run ... ?execute time:2017-10-16 23:02:40
task2 run ... ?execute time:2017-10-16 23:02:42
task1 run ... ?execute time:2017-10-16 23:02:43
task2 run ... ?execute time:2017-10-16 23:02:45
task1 run ... ?execute time:2017-10-16 23:02:46
task2 run ... ?execute time:2017-10-16 23:02:48
從結(jié)果來看隆夯,task1 每次執(zhí)行的時間間隔為3秒鐘,task2每次執(zhí)行的時間間隔也為3秒鐘。
為什么會這樣呢蹄衷?
缺陷一:
因為Timer底層是使用一個單線來實現(xiàn)多個Timer任務(wù)處理的忧额,所有任務(wù)都是由同一個線程來調(diào)度,所有任務(wù)都是串行執(zhí)行愧口,意味著同一時間只能有一個任務(wù)得到執(zhí)行睦番,而前一個任務(wù)的延遲或者異常會影響到之后的任務(wù)。
task1 執(zhí)行了兩秒耍属,然后發(fā)現(xiàn)task2也該執(zhí)行了托嚣,task2執(zhí)行了一秒,然后再執(zhí)行task1厚骗,這樣task1的時間間隔就變成3秒了示启。
Timer 源碼分析
Timer 中維護了一個TaskQueue隊列,存放TimerTask任務(wù)
Timer 定義了一個線程溯捆,用于執(zhí)行輪詢隊列中的Task任務(wù)丑搔,并執(zhí)行厦瓢。
TaskQueue結(jié)構(gòu)
TaskQueue 內(nèi)部維護了一個TimerTask數(shù)組提揍。
TimreTask數(shù)字中存放了所有的定時任務(wù)。
TimerTask[] 數(shù)組是從下標1開始存放元素的煮仇。
即將要執(zhí)行的任務(wù)永遠存放到TimerTask[1] 中劳跃,(數(shù)組中的任務(wù)順序,是不斷的調(diào)整的浙垫,每次獲取完任務(wù)后都會調(diào)整一次)刨仑。
TimerThread.mainLoop() 方法
在Timer中定義了一個內(nèi)部類 TimerThread,負責執(zhí)行隊列中的任務(wù)
主要邏輯是:
從queue中獲取將要執(zhí)行task1 (TimerTask[1]=task1, TimerTask[2]=task2).
獲取完成后夹姥,然后把queue的TimerTask[1] =task2杉武,TimerTask[2]=task1
然后執(zhí)行獲取的task.run()。
缺陷二:
因為Timer中所有的任務(wù)都是在一個線程中執(zhí)行辙售,那么如果有一個定時任務(wù)在運行時轻抱,產(chǎn)生未處理的異常,那么當前這個線程就會停止旦部,那么所有的定時任務(wù)都會停止祈搜,受到影響。
如下圖:
ScheduledExecutorService 代替 Timer
基于上述Timer的兩個致命缺陷士八,在以后的開發(fā)中盡可能使用ScheduledExecutorService(JDK1.5以后)替代Timer容燕。
ScheduledExecutorService是基于線程池的,可以開啟多個線程進行執(zhí)行多個任務(wù)婚度,每個任務(wù)開啟一個線程蘸秘,這樣就可以避免上述的兩個致命缺陷。
Timer 的 schedule 和 scheduleAtFixedRate
1.schedule:每次執(zhí)行完當前任務(wù)后,然后間隔一個period的時間再執(zhí)行下一個任務(wù)醋虏,因此執(zhí)行時間會不斷延后味抖。
比如每次的任務(wù)執(zhí)行時間為2秒,period時間為1秒灰粮,那么就相當于每3秒執(zhí)行一次任務(wù)仔涩。
scheduleAtFixedRate:每次執(zhí)行時間為上一次任務(wù)開始起向后推一個period間隔,也就是說下次執(zhí)行時間相對于上一次任務(wù)開始的時間點粘舟,因此執(zhí)行時間不會延后熔脂,但是存在任務(wù)并發(fā)執(zhí)行的問題。
并發(fā)問題:比如任務(wù)每間隔3秒執(zhí)行一次柑肴,突然有一次任務(wù)執(zhí)行了6秒鐘霞揉,因為6秒鐘可以執(zhí)行兩次任務(wù),所以下次執(zhí)行就會一下子執(zhí)行兩次該任務(wù)晰骑。