java - 如何在继续之前等待所有可调用对象完成执行？

Question

我有以下代码散列：

public class MyCallable implements Callable<Long> {
    @Override
    public Long call() throws Exception {
        // Do stuff...
    }
}

public class MyController {
    private ExecutorService executor = Executos.newCachedTreadPool();

    public Long concurrentDoStuff() {
        List<MyCallable> workers = makeWorkers();

        List<Long> allResults = new ArrayList<Long>();
        for(MyCallable worker : workers) {
            Future<Long> workerResults = executor.submit(worker);

            try {
                allResults.add(workerResults.get());
            } catch(InterruptedException ie) {
                // Handle...
            } catch(ExecutionException ee) {
                // Handle...
            }
        }

        // Question: how do I pause here and wait for all workers to finish?
    }
}

在for循环之后，我想等待所有工作人员完成后再继续。最好/最安全/最有效的方法是什么？提前致谢！

Answer 1

使用CountDownLatch。

• 用工人的数量初始化它
• 在工作构造函数中传递对闩锁的引用
• 工作人员完成后，调用countDown
• 调用await主线程，它将阻塞，直到工作人员完成。

这是一个比在 executor 服务上使用方法更通用的解决方案。

Answer 2

您必须使用 关闭执行器shutDown，然后等到所有作业都已处理完毕awaitTermination。

Answer 3

您可以致电：

executor.shutdown();
executor.awaitTermination(Long.MAX_VALUE , TimeUnit.NANOSECONDS);

这将（几乎）无限期地等待任务完成。

Answer 4

有一个方便的方法。

ExecutorService.invokeAll(List<Callable> callables);

它将返回List<Future>对象，以便您可以获取所有单个call()方法的返回对象。

ExecutorService您可以通过调用获取实例Executors.new....()