22. 并发终结之CompletionService

CompletionService：可以使得先完成的任务先被取出，减少了不必要的等待时间。
ExecutorCompletionService：CompletionService的唯一实现，内部数据结构加了一个BlockingQueue来保存已经完成的Future对象，只有当这个Future对象状态是结束的时候，才会加入到这个Queue中，take()方法其实就是Producer-Consumer中的Consumer。它会从Queue中取出Future对象，如果Queue是空的，就会阻塞在那里，直到有完成的Future对象加入到Queue中。

// 创建线程池
ExecutorService pool = Executors.newFixedThreadPool(POOL_SIZE);
CompletionService<Integer> cService = new ExecutorCompletionService<>(pool);

// 向里面扔任务
for (int i = 0; i < TOTAL_TASK; i++) {
    //这边不是直接通过线程池来提交任务，而是通过CompletionService来提交
    cService.submit(new WorkTask("ExecTask" + i));  
}

// 检查线程池任务执行结果
for (int i = 0; i < TOTAL_TASK; i++) {
     //同样也是从CompletionService来取出结果，因为CompletionService内部实现通过一个BlockingQueue来保存已经完成的结果。
    int sleptTime = cService.take().get();
    System.out.println(" slept "+sleptTime+" ms ...");
    count.addAndGet(sleptTime);
}