ExecutorService - 如何以非阻塞方式等待所有任务的完成

Question

我在 Java Web 服务器应用程序 中使用ExecutorService 以并行方式执行一些计算任务，然后使用awaitTermination() 调用shutdown() 以等待所有任务完成。整个计算有时可能需要几十分钟。

事情是awaitTermination() 方法阻塞主线程直到超时（或中断）但我只想启动任务并立即响应客户端和之后所有任务的竞争都会关闭服务（遵循始终关闭线程池的约定）。

所以我的问题是，有没有一种方法可以在所有任务完成后得到通知，以便我可以调用shutdown() 方法？听众什么的..

谢谢！

Answer 1

您正在尝试解决一个不存在的问题。考虑documentation of ExecutorService.shutdown()：

启动有序关闭，其中执行先前提交的任务，但不会接受新任务。 …

此方法不等待之前提交的任务完成执行。

换句话说，只需调用shutdown() 就可以满足您的所有需求

• 它完成了之前提交的所有任务
• 它启动关机
• 它不等待

唯一的障碍是你打电话给awaitTermination，尽管你不想等待，这有一个简单的解决方案：不要打电话awaitTermination。

之所以出现混淆，是因为在您的问题中，您问的是“如何在所有任务完成后通知我，以便我可以调用 shutdown() 方法”，但这与您在代码中实际执行的操作相矛盾。您正在调用awaitTermination after shutDown，因此您不是为了启动关闭而等待，而是首先启动shutdown 并等待其完成，这是@987654330 的目的@，等待关机完成。

---

一句话，提交后调用shutDown，以便在所有提交的作业完成后关闭服务，不要调用awaitTermination，除非你真的想等待终止。

Answer 2

感谢VGR 的评论，我通过创建另一个Thread 解决了我的问题，我在其中包装了我现有的代码，如下所示：

Thread thread = new Thread(() -> {
    ExecutorService service = Executors.newCachedThreadPool();

    collection.forEach(item -> service.submit(() -> {
            // some computational work
        });

    try {
        service.shutdown()
        service.awaitTermination(2, TimeUnit.HOURS);
    catch (InterruptedException iEx) {
        // handle exception
    }
});

thread.start();

return ResponseToClient();