在继续之前如何等待所有callables完成执行？

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.

• 用工人数量初始化它
• 将引用传递给worker构造函数中的latch
• 当工人完成后,打电话 countDown
• 调用await主线程,它将阻塞,直到工人完成.

与使用执行程序服务上的方法相比,这是一种更通用的解决方案.

Answer 2

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