使用CompletionService結合ExecutorService批處理任務

CompletionService用于提交一組Callable任務，其take方法返回已完成的一個Callable任務對應的Future對象。

如果你向Executor提交了一個批處理任務，并且希望在它們完成后獲得結果。為此你可以將每個任務的Future保存進一個集合，然后循環這個集合調用Future的get()取出數據。幸運的是CompletionService幫你做了這件事情。

CompletionService整合了Executor和BlockingQueue的功能。你可以將Callable任務提交給它去執行，然后使用類似于隊列中的take和poll方法，在結果完整可用時獲得這個結果，像一個打包的Future。

CompletionService的take返回的future是哪個先完成就先返回哪一個，而不是根據提交順序。

例子：

 1 import java.util.Random; 2 import java.util.concurrent.Callable; 3 import java.util.concurrent.CompletionService; 4 import java.util.concurrent.ExecutionException; 5 import java.util.concurrent.ExecutorCompletionService; 6 import java.util.concurrent.ExecutorService; 7 import java.util.concurrent.Executors; 8   9 public class CallableAndFuture {10  11         public static void main(String[] args) {12               ExecutorService threadPool = Executors. newFixedThreadPool(10);13               CompletionService<Integer> completionService = new ExecutorCompletionService<Integer>(threadPool);14  15                for (int i = 0; i < 10; i++) {16                       final int seq = i;17                      System. out.println("開始提交第" + seq + "個任務");18                      completionService.submit( new Callable<Integer>() {19  20                             @Override21                             public Integer call() throws Exception {22                                   Thread. sleep(new Random().nextInt(5000));23                                    return seq;24                            }25                      });26               }27  28                for (int i = 0; i < 10; i++) {29                       try {30                             // 取出并移除表示下一個已完成任務的 Future，如果目前不存在這樣的任務，則等待。31                            Integer seq = completionService.take().get();32                            System. out.println("第" + seq + "個任務返回");33                      } catch (InterruptedException e) {34                            e.printStackTrace();35                      } catch (ExecutionException e) {36                            e.printStackTrace();37                      }38               }39        }40  41 }