Executor框架

• 線程池
• Executor
• Executors
• ExecutorService
• CompletionService
• Future
• Callable
• 等

Executor接口

Executor接口定義了一個(gè)方法execute（Runnable command），該方法接收一個(gè)Runnable實(shí)例俗孝，它用來(lái)執(zhí)行一個(gè)任務(wù)俗冻，任務(wù)即一個(gè)實(shí)現(xiàn)了Runnable接口的類。

ExecutorService接口

ExecutorService接口繼承自Executor接口妄荔，它提供了更豐富的實(shí)現(xiàn)多線程的方法泼菌，比如，ExecutorService提供了關(guān)閉自己的方法啦租，以及可為跟蹤一個(gè)或多個(gè)異步任務(wù)執(zhí)行狀況而生成Future的方法哗伯。
可以調(diào)用ExecutorService的shutdown（）方法來(lái)平滑地關(guān)閉ExecutorService，調(diào)用該方法后篷角，將導(dǎo)致ExecutorService停止接受任何新的任務(wù)且等待已經(jīng)提交的任務(wù)執(zhí)行完成（已經(jīng)提交的任務(wù)會(huì)分兩類：一類是已經(jīng)在執(zhí)行的焊刹，另一類是還沒(méi)有開(kāi)始執(zhí)行的），當(dāng)所有已經(jīng)提交的任務(wù)執(zhí)行完畢后將會(huì)關(guān)閉ExecutorService。因此我們一般用該接口來(lái)實(shí)現(xiàn)和管理多線程虐块。
ExecutorService的生命周期包括三種狀態(tài)：運(yùn)行俩滥、關(guān)閉、終止贺奠。創(chuàng)建后便進(jìn)入運(yùn)行狀態(tài)霜旧，當(dāng)調(diào)用了shutdown（）方法時(shí)，便進(jìn)入關(guān)閉狀態(tài)儡率，此時(shí)意味著ExecutorService不再接受新的方法挂据，但它還在執(zhí)行已經(jīng)提交了的任務(wù)，當(dāng)已經(jīng)提交了的任務(wù)執(zhí)行完后喉悴，便到達(dá)終止?fàn)顟B(tài)棱貌。如果不調(diào)用shutdown（）方法，ExecutorService會(huì)一直處在運(yùn)行狀態(tài)箕肃，不斷接收新的方法婚脱，執(zhí)行新的任務(wù)，服務(wù)端一般不需要關(guān)閉它勺像，保持一直運(yùn)行即可障贸。

Executors

Executors提供了一系列工廠方法用于創(chuàng)建線程池，返回的線程池都實(shí)現(xiàn)了ExecutorService接口吟宦。

• public static ExecutorService newFixedThreadPool(int nThreads)
  創(chuàng)建固定數(shù)目線程的線程池
  • newFixedThreadPool與CachedThreadPool差不多篮洁，也是能reuse就用，但不能隨時(shí)建新的線程殃姓。
  • 其獨(dú)特之處袁波，在任意時(shí)間點(diǎn)，最多只能有固定數(shù)目的活動(dòng)線程存在蜗侈，此時(shí)如果有新的線程要建立篷牌，只能放在另外的隊(duì)列中等待，直到當(dāng)前的線程中某個(gè)線程終止直接被移出池子踏幻。
  • 和CachedThreadPool不同枷颊，F(xiàn)ixedThreadPool沒(méi)有IDLE機(jī)制，所以FixedThreadPool多數(shù)針對(duì)一些很穩(wěn)定很固定的正規(guī)并發(fā)線程该面，多用于服務(wù)器夭苗。
  • 從方法的源代碼看，cache池和fixed池調(diào)用的是同一個(gè)底層池隔缀，只不過(guò)參數(shù)不同题造。
    • fixed池線程數(shù)固定，并且是0秒IDLE
    • cache池線程數(shù)支持0到Integer.MAX_VALUE（顯然完全沒(méi)有考慮主機(jī)的資源承受能力）猾瘸。60秒IDLE晌梨。
• public static ExecutorService newCachedThreadPool()
  創(chuàng)建一個(gè)可緩存的線程池桥嗤，調(diào)用execute將重用以前構(gòu)造的線程（如果線程可用）。如果現(xiàn)有線程沒(méi)有可用的仔蝌，則創(chuàng)建一個(gè)新線程并添加到池中。終止并從緩存中移除那些已有60秒鐘未被使用的線程荒吏。
  • 緩存型線程池敛惊，先查看池中有沒(méi)有以前建立的線程，如果有绰更，就reuse瞧挤，如果沒(méi)有，就建一個(gè)新的線程加入池中儡湾。
  • 緩存型線程池通常用于執(zhí)行一些生存期很短的異步型任務(wù)特恬，因此在一些面向連接的daemon型server中用得不多。但對(duì)于生存型短的異步任務(wù)徐钠，它是Executor的首選癌刽。
  • 能reuse的線程，必須是timeout IDLE內(nèi)的池中線程尝丐，缺省timeout是60s显拜，超過(guò)這個(gè)IDLE時(shí)長(zhǎng)，線程實(shí)例將被終止及移出池爹袁。
  • 放入CachedThreadPool的線程不必?fù)?dān)心其結(jié)束远荠，超過(guò)TIMEOUT不活動(dòng)，其會(huì)自動(dòng)被終止失息。
• public static ExecutorService newSingleThreadExecutor()
  創(chuàng)建一個(gè)單線程化的Executor譬淳。
  • 單例線程，任意時(shí)間池中只能有一個(gè)線程
  • 用的是和cache池和fixed池相同的底層池盹兢，但線程數(shù)目是1-1邻梆，0秒IDLE（無(wú)IDLE）
• public static ScheduleExecutorService newScheduledThreadPool(int corePoolSize)
  創(chuàng)建一個(gè)支持定時(shí)及周期性的任務(wù)執(zhí)行的線程池，多數(shù)情況下可用來(lái)替代Timer類蛤迎。
  • 調(diào)度型線程池
  • 這個(gè)池子里的線程可以按schedule依次delay執(zhí)行确虱，或周期執(zhí)行。

一般來(lái)說(shuō)替裆，CachedThreadPool在程序執(zhí)行過(guò)程中通常會(huì)創(chuàng)建與所需數(shù)量相同的線程校辩，然后在它回收舊線程時(shí)停止創(chuàng)建新線程，因此它是合理的Executor的首選辆童，只有當(dāng)這種方式會(huì)引發(fā)問(wèn)題時(shí)宜咒，才需要考慮用FixedThreadPool。

Executor執(zhí)行Runnable任務(wù)

通過(guò)Executors的以上四個(gè)靜態(tài)工廠方法獲得ExecutorService實(shí)例，而后調(diào)用該實(shí)例的execute（Runnable command）方法即可。一旦Runnable任務(wù)傳遞到execute（）方法膀钠，該方法便會(huì)自動(dòng)在一個(gè)線程上執(zhí)行庸诱。

Executor執(zhí)行Callable任務(wù)

在Java5之后戴质，任務(wù)分兩類：一類是實(shí)現(xiàn)了Runnable

未完待續(xù)
http://wiki.jikexueyuan.com/project/java-concurrency/executor.html