一陨帆、ScheduledThreadPoolExecutor初識
ScheduledThreadPoolExecutor繼承自ThreadPoolExecutor免猾,在此基礎上增加了延遲和定期執(zhí)行任務的功能速侈。
API描述如下:
ThreadPoolExecutor,它可另行安排在給定的延遲后運行命令艳悔,或者定期執(zhí)行命令梧兼。需要多個輔助線程時萝挤,或者要求ThreadPoolExecutor具有額外的靈活性或功能時,此類要優(yōu)于Timer纸淮。
延遲任務的執(zhí)行時間不早于啟用時間平斩,但對于啟用后何時開始沒有任何實時保證。按照提交的先進先出 (FIFO) 順序來啟用那些被安排在同一執(zhí)行時間的任務咽块。
提交的任務在運行之前被取消绘面,執(zhí)行被抑制。 默認情況下侈沪,這樣一個取消的任務在工作隊列中不會自動刪除揭璃,直到其延遲時間過去。雖然這樣可以進一步檢查和監(jiān)控亭罪,但也可能導致取消任務的無限制保留瘦馍。 為避免這種情況,請將setRemoveOnCancelPolicy(boolean)設置為true 应役,這將導致任務在取消時立即從工作隊列中刪除情组。
通過scheduleAtFixedRate或scheduleWithFixedDelay的任務的執(zhí)行不重疊。 雖然不同的執(zhí)行可以通過不同的線程來執(zhí)行箩祥,先前執(zhí)行的效果happen-before那些隨后的那些的院崇。
雖然此類繼承自ThreadPoolExecutor,但是幾個繼承的調(diào)整方法對此類并無作用袍祖。特別是底瓣,因為它作為一個使用corePoolSize線程和一個無界隊列的固定大小的池,所以調(diào)整maximumPoolSize 沒有什么效果蕉陋。此外捐凭,將corePoolSize設置為零或使用allowCoreThreadTimeOut幾乎不是一個好主意,因為這可能會使池沒有線程來處理任務凳鬓,只要它們有資格運行茁肠。
擴展筆記:此類覆蓋execute和submit方法以生成內(nèi)部ScheduledFuture對象來控制每個任務的延遲和調(diào)度。若要保留功能性缩举,子類中任何進一步重寫的這些方法都必須調(diào)用超類版本官套,超類版本有效地禁用附加任務的定制。但是蚁孔,此類提供替代受保護的擴展方法 decorateTask(為 Runnable 和 Callable 各提供一種版本),可定制用于通過 execute惋嚎、submit杠氢、schedule、scheduleAtFixedRate 和 scheduleWithFixedDelay 進入的執(zhí)行命令的具體任務類型另伍。默認情況下鼻百,ScheduledThreadPoolExecutor 使用一個擴展 FutureTask 的任務類型绞旅。但是,可以使用下列形式的子類修改或替換該類型温艇。
public class CustomScheduledExecutor extends ScheduledThreadPoolExecutor {
static class CustomTask<V> implements RunnableScheduledFuture<V> { ... }
protected <V> RunnableScheduledFuture<V> decorateTask(
Runnable r, RunnableScheduledFuture<V> task) {
return new CustomTask<V>(r, task);
}
protected <V> RunnableScheduledFuture<V> decorateTask(
Callable<V> c, RunnableScheduledFuture<V> task) {
return new CustomTask<V>(c, task);
}
// ... add constructors, etc.
}
這個類使用特殊化ThreadPoolExecutor通過:
- 使用自定義任務類型ScheduledFutureTask處理任務因悲,即使是那些不需要調(diào)度的任務(即使用ExecutorService execute而不是ScheduledExecutorService方法提交的任務),這些任務被視為延遲為零的延遲任務勺爱。
- 使用自定義隊列(DelayedWorkQueue)晃琳,它是無界DelayQueue的變體。與ThreadPoolExecutor相比琐鲁,缺乏容量約束以及corePoolSize和maximumPoolSize實際上是相同的卫旱,簡化了一些執(zhí)行機制(參見DelayedExecute)。
- 支持可選的run-after-shutdown運行參數(shù)围段,這將導致覆蓋關閉方法以刪除和取消關閉后不應該運行的任務顾翼,以及當任務(重新)提交與關閉重疊時不同的重新檢查邏輯。
- 任務修飾方法奈泪,以允許攔截和檢測适贸,這是必要的,因為子類不能覆蓋提交方法以達到此效果涝桅。不過拜姿,這些對池控制邏輯沒有任何影響。
二苹支、ScheduledThreadPoolExecutor執(zhí)行原理
延遲執(zhí)行是怎么做到的:Worer從任務隊列中取任務來執(zhí)行砾隅,隊列的頭元素肯定是延遲時間最小的任務,通過判斷延遲時間是否為0來決定任務的某次取操作是否可以取到元素债蜜,任務的延遲時間為0晴埂,則該任務可以被取出執(zhí)行。通過取隊列元素時的延遲時間檢查來決定是否可以讓任務出列寻定,從而執(zhí)行儒洛,這樣就可以達到任務延遲執(zhí)行的效果。
間隔得執(zhí)行任務如何做到:我們知道任務是放入到任務隊列中的狼速,某任務如果出隊列之后琅锻,那么該任務就不再在任務隊列當中,它就不會再次被執(zhí)行到了向胡,要想達到重復間隔地執(zhí)行一個任務恼蓬,那么就應該在任務執(zhí)行完成之后重新將它添加到隊列里,重復這個過程僵芹,就可以達到任務間隔地執(zhí)行的效果处硬。