java - 如何等待ExecutorService中所有提交的任务完成而不关闭？

Question

假设我们遍历一个集合并提交要在后台运行的任务

class Processor {
    public void process(Iterable<Item> items, ExecutorService executorService) {
       for (Item item : items) {               
           doStandardProcess(item);               
           if (needSpecialProcess(item)) {
               executorService.submit(createSpecialTaskFor(item));
           }
       }
    }
}

程序流程如下:

1. 从某处接收元素
2. 创建处理器并处理它们
3. 将结果发送到某个地方

结果取决于后台处理，因此 p.3 应该等到所有任务完成。我知道可以通过 shutdown() 和 awaitTermination() 的组合来实现，但我不想关闭该服务。也可以调用 invokeAll(Listtasks)，但正如您所见，任务是在遍历过程中一个接一个地创建的。

如何在给定的限制下实现等待完成？

附注如果不清楚，另一个限制是与项目遍历并行运行后台任务，因为后台任务比基本处理操作多花费 100 倍的时间。

Answer 1

您可以存储 future :

List<Future> futures = new ArrayList<> ();
//in the for loop
futures.add(executorService.submit(createTaskFor(item)));

//after for loop + add exception handling
for (Future f : futures) f.get();
//at this point all tasks have finished