任務(wù)調(diào)度框架
事件驅(qū)動調(diào)度算法
時鐘驅(qū)動調(diào)度算法
程序中按照一定時間重復(fù)執(zhí)行的某個操作 抽象為一個任務(wù)
很多任務(wù) 考慮并發(fā)等就需要調(diào)度
只要將任務(wù)加入到調(diào)度器就可以按照觸發(fā)器規(guī)定執(zhí)行
一:Quartz
1.Quartz 任務(wù)調(diào)度的核心元素是 scheduler, trigger 和 job,
其中 trigger 和 job 是任務(wù)調(diào)度的元數(shù)據(jù)踢械,
scheduler 是實際執(zhí)行調(diào)度的控制器庶艾。
- 關(guān)于調(diào)度器scheduler
由調(diào)度器工廠創(chuàng)建
可以通過配置文件配置調(diào)度器相關(guān)屬性信息
Scheduler有兩個重要組件:ThreadPool和JobStore
JobStore是來存儲運行時信息的韩脏,包括Trigger福压,Scheduler,JobDetail较性,業(yè)務(wù)鎖等等
注意:Job和Trigger需要存儲下來才可以被使用
3.關(guān)于觸發(fā)器trigger
名和組
開始時間和結(jié)束時間
SimpleTrigger的屬性包括:開始時間呵晚、結(jié)束時間、重復(fù)次數(shù)以及重復(fù)的間隔
CronTirgger:Cron表達(dá)式
明確觸發(fā)時機(jī)
4.關(guān)于任務(wù)Job
Job接口實現(xiàn)
Job&JobDetail的關(guān)系:JobDetail封裝要執(zhí)行的Job的Class對象和JobDataMap
明確任務(wù)內(nèi)容
5.Job和trigger的對應(yīng)關(guān)系
一個Job可以對應(yīng)多個trigger
一個trigger只能對應(yīng)一個Job
6.將任務(wù)和觸發(fā)器添加到調(diào)度器
將任務(wù)添加到觸發(fā)器必盖,再將觸發(fā)器加到調(diào)度器
二:Timer任務(wù)調(diào)度(java.util.Timer) ---單線程任務(wù)調(diào)度
eg:Timer timer = new Timer();
long delay1 = 1 * 1000;
long period1 = 1000;
// 從現(xiàn)在開始 1 秒鐘之后拌牲,每隔 1 秒鐘執(zhí)行一次 job1
//TimerTest extends TimerTask
timer.schedule(new TimerTest("job1"), delay1, period1);
Timer 的設(shè)計核心
是一個 TaskList 和一個 TaskThread。
Timer 將接收到的任務(wù)丟到自己的 TaskList 中歌粥,
TaskList 按照 Task 的最初執(zhí)行時間進(jìn)行排序塌忽。
TimerThread 在創(chuàng)建 Timer 時會啟動成為一個守護(hù)線程。
這個線程會輪詢所有任務(wù)失驶,找到一個最近要執(zhí)行的任務(wù)土居,然后休眠,
當(dāng)?shù)竭_(dá)最近要執(zhí)行任務(wù)的開始時間點嬉探,TimerThread 被喚醒并執(zhí)行該任務(wù)擦耀。之后 TimerThread 更新最近一個要執(zhí)行的任務(wù),繼續(xù)休眠涩堤。
Timer 的優(yōu)點
在于簡單易用眷蜓,但由于所有任務(wù)都是由同一個線程來調(diào)度,
因此所有任務(wù)都是串行執(zhí)行的胎围,同一時間只能有一個任務(wù)在執(zhí)行吁系,
前一個任務(wù)的延遲或異常都將會影響到之后的任務(wù)
對于簡單的基于起始時間點與時間間隔的任務(wù)調(diào)度,使用 Timer 就足夠了
(沒有周期參數(shù)表示執(zhí)行一次)
三:ScheduledExecutor:java.util.concurrent包中---多線程任務(wù)調(diào)度
基于線程池設(shè)計的 ScheduledExecutor白魂。
其設(shè)計思想是汽纤,每一個被調(diào)度的任務(wù)都會由線程池中一個線程去執(zhí)行,
因此任務(wù)是并發(fā)執(zhí)行的碧聪,相互之間不會受到干擾冒版。需要注意的是,
只有當(dāng)任務(wù)的執(zhí)行時間到來時逞姿,ScheduedExecutor 才會真正啟動一個線程辞嗡,
其余時間 ScheduledExecutor 都是在輪詢?nèi)蝿?wù)的狀態(tài)捆等。
【ScheduledExecutorService】 中兩種最常用的調(diào)度方法
ScheduleAtFixedRate 和 ScheduleWithFixedDelay
ScheduleAtFixedRate 是基于固定時間間隔進(jìn)行任務(wù)調(diào)度:
initialDelay, initialDelay+period, initialDelay+2period, …
ScheduleWithFixedDelay 取決于每次任務(wù)執(zhí)行的時間長短,
是基于不固定時間間隔進(jìn)行任務(wù)調(diào)度
initialDelay, initialDelay+executeTime+delay, initialDelay+2executeTime+2*delay
如果需要【同時調(diào)度多個任務(wù)】续室,基于線程池的 ScheduledTimer 是更為合適的選擇