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