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

Question

我有一个4个线程同时运行的代码。我想等到所有这4个线程都完成。并且只有在那之后才能继续应用程序流程。

我尝试了两种方法:

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

感谢@Adam Siemion的建议，以下是最终代码：

ExecutorService service = Executors.newFixedThreadPool(cpuCoresNum);

int itNum = 1;

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

    int treadID = itNum++;

    service.submit(() -> {
        Thread.currentThread().setName("Thread_#" + treadID);
        try {
            foo();
        } catch (Exception e) {
            e.printStackTrace();
        }
    });
}

// wait until all threads will be finished
service.shutdown();
try {
    service.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
    e.printStackTrace();
}

Answer 2

匿名用户

来自ExecutorService的oracle文档页面的推荐方式：

 void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); // Disable new tasks from being submitted
   try {
     // Wait a while for existing tasks to terminate
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }

< code>shutdown():启动有序关闭，执行以前提交的任务，但不接受新任务。

关机现在（）：尝试停止所有正在执行的任务，暂停等待任务的处理，并返回等待执行的任务的列表。

在上面的示例中，如果任务需要花费更多的时间来完成，则可以将if条件更改为while条件

替换

if (!pool.awaitTermination(60, TimeUnit.SECONDS))

具有

 while(!pool.awaitTermination(60, TimeUnit.SECONDS)) {
     Thread.sleep(60000);
 }  

Answer 3

答案在< code > executorservice . shut down() Javadoc:

此方法不等待先前提交的任务完成执行。使用< code>awaitTermination来完成此操作。

如果要等待线程完成工作，可以使用以下选项：

• 获取submit（）返回的Future，并对每个Future实例调用get（）
• 在服务上调用关机后，调用service，直到返回true
• 不要在服务上调用submit，而是将可运行的实例添加到java.util中。列出，并将此列表传递给服务上调用的invokeAll方法