CompletionService

如果你向Executor提交了一个批处理任务，并且希望在它们完成后获得结果。为此你可以保存与每个任务相关联的Future，然后不断地调用timeout为零的get，来检验Future是否完成。这样做固然可以，但却相当乏味。幸运的是，还有一个更好的方法：完成服务(Completion service)。
CompletionService整合了Executor和BlockingQueue的功能。你可以将Callable任务提交给它去执行，然后使用类似于队列中的take和poll方法，在结果完整可用时获得这个结果，像一个打包的Future。ExecutorCompletionService是实现CompletionService接口的一个类，并将计算任务委托给一个Executor。
ExecutorCompletionService的实现相当直观。它在构造函数中创建一个BlockingQueue，用它去保持完成的结果。计算完成时会调用FutureTask中的done方法。当提交一个任务后，首先把这个任务包装为一个QueueingFuture，它是FutureTask的一个子类，然后覆写done方法，将结果置入BlockingQueue中，take和poll方法委托给了BlockingQueue，poll()是非阻塞的，若目前无结果，返回一个null，take()是阻塞的，若当前无结果，则线程阻塞，直到产生一个结果。

public class Test {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executor = Executors.newCachedThreadPool();
//可以是多个CompletionService对象共用一个ExecutorService对象
CompletionService<Integer> comp = new ExecutorCompletionService<Integer>(executor);
for (int i = 0; i < 5; i++) {
comp.submit(new Task());
}
executor.shutdown();
int count = 0, index = 1;
while (count < 5) {
//取出来的是Future对象而不是Integer对象
Future<Integer> f = comp.poll();
if (f == null) {
System.out.println(index + " 没发现有完成的任务");
} else {
System.out.println(index + "产生了一个随机数: " + f.get());
count++;
}
index++;
TimeUnit.MILLISECONDS.sleep(500);
}
}
}
class Task implements Callable<Integer> {
@Override
public Integer call() throws Exception {
Random rand = new Random();
TimeUnit.SECONDS.sleep(rand.nextInt(7));
return rand.nextInt();
}
}