如何在不关闭执行器的情况下等待ThreadPoolExecutor中的所有任务完成？

Question

我不能使用shutdown()，awaitTermination()因为有可能在等待时将新任务添加到ThreadPoolExecutor中。

因此，我正在寻找一种方法，等待ThreadPoolExecutor清空队列并完成所有任务，而又不阻止在此之前添加新任务。

如果有什么不同，这适用于Android。

谢谢

更新 ：几周后，我再次进行了修改，发现在这种情况下，修改后的CountDownLatch对我而言效果更好。我会保留答案，因为它更适用于我的要求。

Answer 1

如果您想知道何时完成某项任务或某批任务，可以使用ExecutorService.submit(Runnable)。调用此方法将返回一个Future对象，该对象可以放置在Collection其中，然后您的主线程将在调用Future.get()每个对象时进行迭代。这将导致您的主线程停止执行，直到ExecutorService已处理完所有Runnable任务。

Collection<Future<?>> futures = new LinkedList<Future<?>>();
futures.add(executorService.submit(myRunnable));
for (Future<?> future:futures) {
    future.get();
}