Java 主从通信

Question

这是我需要的：

一个 Master 任务会创建一堆 Worker 任务。

一旦每个工人完成工作，它需要向主人汇报。

一旦主机收到预定义数量的响应，它就会保存这些结果。这是必需的，因为一个一个地插入结果比一次插入一堆结果要花费更多的时间并等待所有结果可能会导致 OutOfMemoryException。

我已经查看了每个调用主节点上的方法的工作人员，并将其与 wait() 和 notify() 同步，还使用 ​​ThreadPoolExecutor 和 afterExecute(..) 方法从工作人员那里获取结果，但我我仍然不确定实现我需要的最佳方法是什么。

编辑：我还应该提到这是一个 java 应用程序。

Answer 1

使用BlockingQueue，主人等待（queue.take()）工作人员放置结果（queue.put()）。