我需要一次执行一定数量的任务4，就像这样:
ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
taskExecutor.execute(new MyTask());
}
//...wait for completion somehow
当所有这些都完成后，我如何得到通知?现在我想不出比设置一些全局任务计数器更好的方法，并在每个任务结束时减少它，然后在无限循环中监视这个计数器变成0;或获取一个期货列表，并在无限循环监视器isDone为所有它们。不涉及无限循环的更好的解决方案是什么?
谢谢。
当前回答
您可以使用自己的ExecutorCompletionService子类来包装taskExecutor，并使用自己的BlockingQueue实现在每个任务完成时获得通知，并在完成的任务数量达到预期目标时执行任何回调或其他操作。
其他回答
使用CountDownLatch:
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();
Java 5及以后版本中的CyclicBarrier类就是为这类事情而设计的。
Project Loom的AutoCloseable执行器服务上的Try-with-Resources语法
Project Loom试图为Java中的并发能力添加新特性。
其中一个特性是使ExecutorService可自动关闭。这意味着每个ExecutorService实现都将提供一个close方法。这意味着我们可以使用try-with-resources语法自动关闭ExecutorService对象。
executorservice# close方法将阻塞，直到所有提交的任务都完成。使用close代替了调用shutdown & awaitterminate。
自动关闭功能有助于Project Loom将“结构化并发”引入Java。
try (
ExecutorService executorService = Executors.… ;
) {
// Submit your `Runnable`/`Callable` tasks to the executor service.
…
}
// At this point, flow-of-control blocks until all submitted tasks are done/canceled/failed.
// After this point, the executor service will have been automatically shutdown, wia `close` method called by try-with-resources syntax.
有关Project Loom的更多信息，请搜索由Ron Pressler和Project Loom团队的其他人所做的演讲和采访。关注更近期的，如Project Loom的发展。
Project Loom技术的实验版本现在已经可以使用了，它是基于早期的Java 18。
遵循以下方法之一。
遍历从ExecutorService上的submit返回的所有Future任务，并按照Kiran的建议使用Future对象上的阻塞调用get()检查状态 在ExecutorService上使用invokeAll() CountDownLatch ForkJoinPool或Executors.html#newWorkStealingPool 按照适当的顺序使用ThreadPoolExecutor的shutdown、awaitterminate、shutdownNow api
相关的SE问题:
CountDownLatch是如何在Java多线程中使用的?
如何正确关闭java ExecutorService
这只是我的个人意见。 为了克服CountDownLatch预先知道任务数量的要求，您可以使用简单的Semaphore来使用旧的方式。
ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
int numberOfTasks=0;
Semaphore s=new Semaphore(0);
while(...) {
taskExecutor.execute(new MyTask());
numberOfTasks++;
}
try {
s.aquire(numberOfTasks);
...
在任务中调用s.release()就像调用latch.countDown()一样;
