java - 多个线程向后续进程注入(inject)数据

Question

我有一个使用 Java 制作的项目。

我有一个复杂的处理过程，比如我从一个进程创建了 10 个不同的线程，然后该进程等待其他线程完成处理。现在创建的线程执行一些数据库处理，然后最终生成输出。但这里的问题是，一直在等待的进程再次需要处理在创建的线程中创建的所有数据，某种聚合结果。

我几乎不知道需要做什么。

问候

Answer 1

您可以使用 java.util.concurrent.ConcurrentLinkedQueue。让每个线程在完成后将其结果放入队列。主线程只监视队列并在结果进来时处理它们。

另一种选择是使用 Futures。而不是线程，只需为每个进程使用 Futures。主线程将在等待每个 future 完成其处理时阻塞。