Java并發(fā)編程 - ScheduledThreadPoolExecutor

一陨帆、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通過:

  1. 使用自定義任務類型ScheduledFutureTask處理任務因悲,即使是那些不需要調(diào)度的任務(即使用ExecutorService execute而不是ScheduledExecutorService方法提交的任務),這些任務被視為延遲為零的延遲任務勺爱。
  2. 使用自定義隊列(DelayedWorkQueue)晃琳,它是無界DelayQueue的變體。與ThreadPoolExecutor相比琐鲁,缺乏容量約束以及corePoolSize和maximumPoolSize實際上是相同的卫旱,簡化了一些執(zhí)行機制(參見DelayedExecute)。
  3. 支持可選的run-after-shutdown運行參數(shù)围段,這將導致覆蓋關閉方法以刪除和取消關閉后不應該運行的任務顾翼,以及當任務(重新)提交與關閉重疊時不同的重新檢查邏輯。
  4. 任務修飾方法奈泪,以允許攔截和檢測适贸,這是必要的,因為子類不能覆蓋提交方法以達到此效果涝桅。不過拜姿,這些對池控制邏輯沒有任何影響。

二苹支、ScheduledThreadPoolExecutor執(zhí)行原理

延遲執(zhí)行是怎么做到的:Worer從任務隊列中取任務來執(zhí)行砾隅,隊列的頭元素肯定是延遲時間最小的任務,通過判斷延遲時間是否為0來決定任務的某次取操作是否可以取到元素债蜜,任務的延遲時間為0晴埂,則該任務可以被取出執(zhí)行。通過取隊列元素時的延遲時間檢查來決定是否可以讓任務出列寻定,從而執(zhí)行儒洛,這樣就可以達到任務延遲執(zhí)行的效果。

間隔得執(zhí)行任務如何做到:我們知道任務是放入到任務隊列中的狼速,某任務如果出隊列之后琅锻,那么該任務就不再在任務隊列當中,它就不會再次被執(zhí)行到了向胡,要想達到重復間隔地執(zhí)行一個任務恼蓬,那么就應該在任務執(zhí)行完成之后重新將它添加到隊列里,重復這個過程僵芹,就可以達到任務間隔地執(zhí)行的效果处硬。

最后編輯于
?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市拇派,隨后出現(xiàn)的幾起案子荷辕,更是在濱河造成了極大的恐慌凿跳,老刑警劉巖,帶你破解...
    沈念sama閱讀 217,509評論 6 504
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件疮方,死亡現(xiàn)場離奇詭異控嗜,居然都是意外死亡,警方通過查閱死者的電腦和手機骡显,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,806評論 3 394
  • 文/潘曉璐 我一進店門疆栏,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人蟆盐,你說我怎么就攤上這事承边。” “怎么了石挂?”我有些...
    開封第一講書人閱讀 163,875評論 0 354
  • 文/不壞的土叔 我叫張陵博助,是天一觀的道長。 經(jīng)常有香客問我痹愚,道長富岳,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,441評論 1 293
  • 正文 為了忘掉前任拯腮,我火速辦了婚禮窖式,結果婚禮上,老公的妹妹穿的比我還像新娘动壤。我一直安慰自己萝喘,他們只是感情好,可當我...
    茶點故事閱讀 67,488評論 6 392
  • 文/花漫 我一把揭開白布琼懊。 她就那樣靜靜地躺著阁簸,像睡著了一般。 火紅的嫁衣襯著肌膚如雪哼丈。 梳的紋絲不亂的頭發(fā)上启妹,一...
    開封第一講書人閱讀 51,365評論 1 302
  • 那天,我揣著相機與錄音醉旦,去河邊找鬼饶米。 笑死,一個胖子當著我的面吹牛车胡,可吹牛的內(nèi)容都是我干的檬输。 我是一名探鬼主播,決...
    沈念sama閱讀 40,190評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼匈棘,長吁一口氣:“原來是場噩夢啊……” “哼丧慈!你這毒婦竟也來了?” 一聲冷哼從身側響起羹饰,我...
    開封第一講書人閱讀 39,062評論 0 276
  • 序言:老撾萬榮一對情侶失蹤伊滋,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后队秩,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體笑旺,經(jīng)...
    沈念sama閱讀 45,500評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,706評論 3 335
  • 正文 我和宋清朗相戀三年馍资,在試婚紗的時候發(fā)現(xiàn)自己被綠了筒主。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,834評論 1 347
  • 序言:一個原本活蹦亂跳的男人離奇死亡鸟蟹,死狀恐怖乌妙,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情建钥,我是刑警寧澤藤韵,帶...
    沈念sama閱讀 35,559評論 5 345
  • 正文 年R本政府宣布,位于F島的核電站熊经,受9級特大地震影響泽艘,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜镐依,卻給世界環(huán)境...
    茶點故事閱讀 41,167評論 3 328
  • 文/蒙蒙 一匹涮、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧槐壳,春花似錦然低、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,779評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至绍哎,卻和暖如春来农,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背崇堰。 一陣腳步聲響...
    開封第一講書人閱讀 32,912評論 1 269
  • 我被黑心中介騙來泰國打工沃于, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人海诲。 一個月前我還...
    沈念sama閱讀 47,958評論 2 370
  • 正文 我出身青樓繁莹,卻偏偏與公主長得像,于是被迫代替她去往敵國和親特幔。 傳聞我的和親對象是個殘疾皇子咨演,可洞房花燭夜當晚...
    茶點故事閱讀 44,779評論 2 354