1. 程式人生 > >ExecutorService和CompletionService區別

ExecutorService和CompletionService區別

任務 post 不必要 管理器 ice 結果 -c 等待 executors

ExecutorService和CompletionService區別:
ExecutorService:一直習慣自己維護一個list保存submit的callable task所返回的Future對象。在主線程中遍歷這個list並調用Future的get()方法取到Task的返回值。


CompletionService:在很多地方會看到一些代碼通過CompletionService包裝ExecutorService,然後調用其take()方法去取Future對象。


這兩者最主要的區別: 在於submit的task不一定是按照加入自己維護的list順序完成的。從list中遍歷的每個Future對象並不一定處於完成狀態,這時調用get()方法就會被阻塞住,如果系統是設計成每個線程完成後就能根據其結果繼續做後面的事,這樣對於處於list後面的但是先完成的線程就會增加了額外的等待時間。
而CompletionService的實現是維護一個保存Future對象的BlockingQueue。只有當這個Future對象狀態是結束的時候,才會加入到這個Queue中,take()方法其實就是Producer-Consumer中的Consumer。它會從Queue中取出Future對象,如果Queue是空的,就會阻塞在那裏,直到有完成的Future對象加入到Queue中。
所以,先完成的必定先被取出。這樣就減少了不必要的等待時間。
jdk 自帶線程池結果管理器:ExecutorCompletionService。它將BlockingQueue 和Executor 封裝起來。然後使用ExecutorCompletionService.submit()方法提交任務。

ExecutorService和CompletionService區別