来自不同线程的 Java ExecuterCompletionService take.get()

Question

在 Java 中，我有一个 Web 服务，它在不同的线程上启动一些长时间运行的进程，这样我就可以在连接超时的情况下返回 http 状态。

我的问题涉及创建一个长时间运行的线程，该线程将简单地运行 ExecuterCompletionService.take.get() 以获取已完成的线程并完成对它们的处理。

如果完成服务是在主线程中创建的，是否可以在该单独的线程中运行获取完成的对象？

EG。

主线程

1. 创建完成服务
2. 接受请求并创建长时间运行的进程
3. 将 Callable 提交到完成服务
4. 如果一切顺利，返回 HTTP 状态 200

监控线程

1. 存储对在主线程中创建的完成服务的引用。
2. 运行completionservice.take.get()
3. 为已完成的任务生成报告
4. 重复

有什么我忽略的特别需要担心的吗？比如同步问题。我知道内部完成服务使用阻塞队列。

Answer 1

恕我直言，只要您保留一个用于提交多个 Callable Jobs 的 ExecutorCompletionService 实例，我认为您的方法没有问题。

在这种方法中，当服务器宕机/崩溃时，您将丢失正在运行的 Job 结果。您将使用 JVM 内存来保持 Jobs 处于活动状态。同样，这取决于请求的数量和并行运行的作业数量以及完成任务所需的时间。

如果您不需要并行运行所有请求，那么对于您的用例，JMS 将是完美的选择。为了避免长时间运行的进程请求超时，我们可以将作业放在JMS中，稍后您可以通过JMSlistener (Message Listener / MDB )使用作业并一一处理。