Java线程池执行器服务关闭未按预期工作

Question

目前，我正在使用一个围绕脚本共享的执行器服务的全局实例。我的想法是调用并将任务添加到池中，以便线程进行工作，当所有线程都完成时，然后写入输出文件以获取结果。

下面是一个小视图：主线程调用t0、t1、t2、t3，t0调用t4、t5。其他线程也可以调用其他线程。

main thread calls:
     openFile()
     -> t0
          -> t4
          -> t5
          ...
     -> t1
     -> t2
     -> t3 
     ...
     shutdown()
     awaitTermination(60, MINUTES)
     writeFile()
     closeFile()

问题是shutdown()和awaitTermination()在t0、t1、t2、t3时被调用并完成，而没有等待t4和t5。因此，当t4和t5仍在完成任务时，输出被写入。我使用与其他实例相同的实例执行t4和t5，认为它会将其添加到池中，awaitTermination()会等待它们(以及由其他线程调用的其他线程)完成。

我该怎么做呢？

Answer 1

在知道 t0 完成之前不要调用 shutdown - 然后您将知道 t4/t5 必须在同一执行程序服务上排队：

Future<?> t0fut = execService.submit(t0);
// deal with others t1..t3
...
t0fut.get();
execService.shutdown();
...

对t0fut.get（）的调用应该阻塞，直到t0完成，然后对execService.shutdown（）的调用不会导致错误，因为t4/t5必须在t0结束之前已经提交。