问题

我需要一次执行4个任务，如下所示：

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
    taskExecutor.execute(new MyTask());
}
//...wait for completion somehow

一旦完成所有内容，我怎样才能得到通知？现在我想不出比设置一些全局任务计数器更好的事情，并在每个任务结束时减少它，然后在无限循环监视这个计数器变为0;或获得一个Futures列表，并在无限循环监视器isDone中为所有这些。什么是更好的解决方案不涉及无限循环？

谢谢。

#1 热门回答(354 赞)

基本上在aExecutorService上你拨打shutdown()然后拨打awaitTermination()：

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
  taskExecutor.execute(new MyTask());
}
taskExecutor.shutdown();
try {
  taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
  ...
}

#2 热门回答(145 赞)

使用aCountDownLatch：

CountDownLatch latch = new CountDownLatch(totalNumberOfTasks);
ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
  taskExecutor.execute(new MyTask());
}

try {
  latch.await();
} catch (InterruptedException E) {
   // handle
}

并在你的任务中(包含在try / finally中)

latch.countDown();

#3 热门回答(75 赞)

ExecutorService.invokeAll()为你服务。

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
List<Callable<?>> tasks; // your tasks
// invokeAll() returns when all tasks are complete
List<Future<?>> futures = taskExecutor.invokeAll(tasks);

原文链接