摘要：此外，有兩個(gè)常用的關(guān)閉線程池的方法第一個(gè)方法將啟動(dòng)一次順序關(guān)閉，有任務(wù)在執(zhí)行，則等待執(zhí)行完成，但不接受新的任務(wù)第二個(gè)方法將取消所有未開始的任務(wù)并且試圖中斷正在執(zhí)行的任務(wù)，返回從未開始執(zhí)行的任務(wù)的列表。
四種線程池
在Executors中提供了四種線程池：
newCachedThreadPool 可緩存線程池，對(duì)于每個(gè)線程，如果有空閑線程可用，立即讓它執(zhí)行，如果沒有，則創(chuàng)建一個(gè)新線程
newFixedThreadPool 具有固定大小的線程池，如果任務(wù)數(shù)大于空閑的線程數(shù)，則把它們放進(jìn)隊(duì)列中等待
newSingleThreadPool大小為1的線程池，任務(wù)一個(gè)接著一個(gè)完成
newScheduledThreadPool 定長線程池，可控制線程最大并發(fā)數(shù)，支持定時(shí)及周期性任務(wù)執(zhí)行，用來代替Timer
基本方法
在上文http://segmentfault.com/a/1190000003091174 中說到了callable不能直接被Thread運(yùn)行，但卻能被線程池運(yùn)行，ExecutorService提供了幾種方法運(yùn)行一個(gè)任務(wù)：
Future submit(Callable task);
Future submit(Runnable task, T result);
Future submit(Runnable task);
第一個(gè)方法可以直接提交一個(gè)Callable任務(wù),返回一個(gè)包含結(jié)果的Future,第二個(gè)方法會(huì)返回指定的result對(duì)象，第三個(gè)方法返回一個(gè)Future,可以使用這樣的對(duì)象來調(diào)用isDone,cancel,isCancelled,但是在get的時(shí)候返回null。
此外，有兩個(gè)常用的關(guān)閉線程池的方法：
void shutdown();
List shutdownNow()
第一個(gè)方法將啟動(dòng)一次順序關(guān)閉，有任務(wù)在執(zhí)行，則等待執(zhí)行完成，但不接受新的任務(wù)；
第二個(gè)方法將取消所有未開始的任務(wù)并且試圖中斷正在執(zhí)行的任務(wù)，返回從未開始執(zhí)行的任務(wù)的列表。無法保證能夠停止正在處理的活動(dòng)執(zhí)行任務(wù)，但是會(huì)盡力嘗試。例如，通過 Thread.interrupt() 來取消典型的實(shí)現(xiàn)，所以任何任務(wù)無法響應(yīng)中斷都可能永遠(yuǎn)無法終止。
控制一組任務(wù)
ExecutorService提供了invokeAny和invokeAll方法，它們是批量執(zhí)行的最常用形式，它們執(zhí)行任務(wù)collection，然后等待至少一個(gè)，或全部任務(wù)完成
/**
執(zhí)行給定的任務(wù)，當(dāng)所有任務(wù)完成時(shí)，返回保持任務(wù)狀態(tài)和結(jié)果的 Future 列表。返回列表的所有元素的 Future.isDone() 為 true。
注意，可以正常地或通過拋出異常來終止已完成任務(wù)。
**/
List> invokeAll(Collection> tasks)
throws InterruptedException
/**
執(zhí)行給定的任務(wù)，如果其中一個(gè)任務(wù)的結(jié)果。一旦正常或異常返回后，則取消尚未完成的任務(wù)。
**/
T invokeAny(Collection> tasks)
throws InterruptedException,
ExecutionException
invokeAny方法提交所有任務(wù)到一個(gè)Callable對(duì)象的集合中，并且返回某個(gè)已經(jīng)完成了的任務(wù)的結(jié)果，返回的任務(wù)是不確定的。invokeAll方法則返回所有任務(wù)的結(jié)果，可以這樣來對(duì)結(jié)果進(jìn)行處理：
List> tasks=...
List> results = executor.invokeAll(tasks);
for(Future result : results){
process(result.get());
}
...
這樣處理的一個(gè)弊端是，如果第一個(gè)任務(wù)花費(fèi)了很長時(shí)間，則不得不等待。在某些情況下，可能只需要一個(gè)任務(wù)出了結(jié)果就可以中止所有任務(wù)，這樣就得不償失。將結(jié)果按照可獲得的順序保存起來可能更好，這時(shí)需要用到ExecutorCompletionService來進(jìn)行排列：
ExecutorCompletionService service = new ExecutorCompletionService(executor);
for(Callable task:tasks){
service.submit(task);
}
for(int i = 0;i < task.size();i++){
process(service.take().get());
}
...
其中，take()方法會(huì)移除下一個(gè)已經(jīng)完成的結(jié)果（Future），如果沒有可用結(jié)果則阻塞
使用小結(jié)
在使用線程池時(shí)，大多應(yīng)該按照以下步驟：
調(diào)用Executors類中的靜態(tài)方法newCachedThreadPool或newFixedThreadPool創(chuàng)建線程池；
調(diào)用submit提交Runnable或Callable任務(wù)；
如果想取消一個(gè)任務(wù)，或者提交了Callable對(duì)象，那就要保存好返回的Future對(duì)象;
當(dāng)不再提交任務(wù)時(shí)，調(diào)用shutdown
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://www.ezyhdfw.cn/yun/64436.html
