ExecutorService的shutdown()不会等到所有线程都完成

Question

我有一个代码,其中4个线程同时运行.我想等到所有这4个线程都完成.只有在那之后继续app流程.

我尝试了两种方法:

1. Thread#join(),这种方法按预期工作.之后的代码join()仅在所有线程完成后执行.
2. ExecutorService#shutdown(),这种技术允许执行代码,shutdown()即使并非所有线程都完成也会执行.

代码示例:

ExecutorService service = Executors.newFixedThreadPool(cpuCoresNum);

for (int i = 0; i < cpuCoresNum; i++) {

    service.submit(() -> {
        try {
            foo(); // some long execution function
        } catch (Exception e) {
            e.printStackTrace();
        }
    });
}

service.shutdown();

System.out.println("We're done! All threads are finished!");

我的问题:

• 为什么submit(),shutdown()不要等到所有线程都完成并打印«我们已经完成了!所有线程都已完成!»电话结束后service.shutdown();？

Answer 1

答案可以在ExecutorService.shutdown()Javadoc中找到:

此方法不会等待先前提交的任务完成执行.使用awaitTermination来做到这一点.

如果您想等待线程完成工作,您有以下选择:

• 获取Future实例返回submit()并调用get()每个Future实例
• 打完电话后shutdown对service通话awaitTermination上service,直到它返回true
• 而不是调用submit在service你添加Runnable实例到java.util.List,并通过此列表中invokeAll呼吁方法service