等待所有线程完成后再关闭执行器

Question

这是我的代码段。

ExecutorService executor = Executors.newFixedThreadPool(ThreadPoolSize);
while(conditionTrue)
{
ClassImplementingRunnable c = new ClassImplementingRunnable();
executor.submit(c);
}

现在做完之后

executor.shutdown();

我要在这里实现的是，我要等待线程池中的所有线程完成执行，然后关闭执行器。

但是我想这不是这里正在发生的事情。主线程似乎正在执行关闭，它只是关闭了所有内容。

在我的线程池大小为2之前，我做了以下事情，而且似乎可行。

ClassImplementingRunnable c1 = new ClassImplementingRunnable();
executor.submit(c1);
ClassImplementingRunnable c2 = new ClassImplementingRunnable();
executor.submit(c2);
Future f1 = executor.submit(c1);
Future f2 = executor.submit(c2);
while(!f1.done || !f2.done)
{}
executor.submit();

我如何在线程池中使用更多线程？谢谢。

Answer 1

您通常使用以下成语：

executor.shutdown();
executor.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);

• shutdown 只是说执行者不会接受新工作。
• awaitTermination等待直到所有已提交的任务完成它们的工作（或者直到达到超时-Integer.MAX_VALUE不会发生-您可能要使用一个较低的值）。