java - 当所有任务完成时，执行器服务如何发出信号？

Question

我读了这个post

我想用所有任务结果填充一个数组

但我只想在所有 Future 都有值时(也就是所有任务都有结果)才调用某个方法。

有没有办法写这样的屏障？

Answer 1

对于执行器服务，您需要将其关闭并等待其终止。

executorService.shutdown();
executorService.awaitTermination(1,TimeUnit.HOUR);

关闭不会立即停止执行器，但会阻止它执行新任务并允许完成已提交的任务。

awaitTermination 会阻塞调用线程，直到处理完执行器中的整个任务队列为止。

另一种方法是使用 ExecutorCompletionService 来代替，并根据提交的任务数量调用 take() 次数。每个 take 都会阻塞，直到一个 future 完成(或者失败)。