Java ExecutorCompletionService类

「爱情、让人受尽委屈。」 2023-10-08 12:00 22阅读 0赞

## `一、为什么使用ExecutorCompletionService` ##

> 假设现在有一大批需要进行计算的任务，为了提高整批任务的执行效率，你可能会使用线程池，向线程池中不断submit异步计算任务，同时你需要保留与每个任务关联的Future，最后遍历这些Future，通过调用Future接口实现类的get方法获取整批计算任务的各个结果。  
> 虽然使用了线程池提高了整体的执行效率，但遍历这些Future，调用Future接口实现类的get方法是阻塞的，也就是和当前这个Future关联的计算任务真正执行完成的时候，get方法才返回结果，如果当前计算任务没有执行完成，而有其它Future关联的计算任务已经执行完成了，就会白白浪费很多等待的时间，所以最好是遍历的时候谁先执行完成就先获取哪个结果，这样就节省了很多持续等待的时间。  
> 而ExecutorCompletionService可以实现这样的效果，它的内部有一个先进先出的阻塞队列，用于保存已经执行完成的Future，通过调用它的take方法或poll方法可以获取到一个已经执行完成的Future，进而通过调用Future接口实现类的get方法获取最终的结果。

## `二、ExecutorCompletionService常用方法` ##

<table> 
 <thead> 
  <tr> 
   <th align="left">方法</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">Future&lt;V&gt; submit(Callable&lt;V&gt; task)</td> 
   <td align="left">提交要执行的返回值任务，并返回表示任务的未决结果的Future。</td> 
  </tr> 
  <tr> 
   <td align="left">Future&lt;V&gt; submit(Runnable task, V result)</td> 
   <td align="left">提交一个Runnable任务以执行并返回一个表示该任务的Future。</td> 
  </tr> 
  <tr> 
   <td align="left">Future&lt;V&gt; take()</td> 
   <td align="left">检索并删除表示下一个已完成任务的Future，如果尚不存在则等待。</td> 
  </tr> 
  <tr> 
   <td align="left">Future&lt;V&gt; poll()</td> 
   <td align="left">检索并删除表示下一个已完成任务的Future，或者null如果不存在则不删除。</td> 
  </tr> 
  <tr> 
   <td align="left">Future&lt;V&gt; poll(long timeout, TimeUnit unit)</td> 
   <td align="left">检索并删除表示下一个已完成任务的Future，如果有必要，则等待指定的等待时间（如果尚不存在）。</td> 
  </tr> 
 </tbody> 
</table>

## `三、示例` ##

public static void main(String[] args) throws Exception {
        
         ExecutorService executorService = Executors.newCachedThreadPool();
         CompletionService<String> completionService = new ExecutorCompletionService<>(executorService);
    
         for (int i = 0; i < 5; i++) {
        
             int total = i;
             completionService.submit(new Callable<String>() {
        
                 @Override
                 public String call() throws Exception {
        
                     return "Hello " + total + "; I am " + Thread.currentThread().getName();
                 }
             });
         }
    
         for (int j = 0; j < 5; j++) {
        
             System.out.println(completionService.take().get());
         }
         // 处理完成结束程序
         executorService.shutdownNow();
     }