ExecutorService awaitTermination方法未按预期执行

Question

我正在尝试用Java编写一个进程，该进程并发执行一系列任务，等待任务完成，然后将整个进程标记为完成。每个任务都有自己的信息，包括单个任务何时完成。我将使用ExecutorService作为流程，并将流程的本质归纳如下：

List<Foo> foos = getFoos();
ExecutorService executorService = Executors.newFixedThreadPool(foos.size());
for (Foo foo : foos) {
    executorService.execute(new MyRunnable(foo));
}

executorService.shutdown();

try {
    executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);
} catch (InterruptedException e) {
    // log the error.
}

completeThisProcess();

每个MyRunnable对象都有一个run方法，该方法进行webservice调用，然后将调用的结果写入数据库，包括调用完成的时间。ComplethisProcess方法只是将整个流程的状态写为complete以及流程完成的时间。

我遇到的问题是，当我在流程完成后查看数据库时，completeThisProcess方法显然能够在所有MyRunnables完成之前执行。我注意到，从completeThisProcess方法写入的时间甚至偶尔会在最后一个MyRunnable任务完成之前超过20-30秒。

我写的过程有什么明显的错误吗？也许我没有正确理解ExecutorService,但我认为awaitTermination方法应该确保所有MyRunnable实例都完成了它们的run方法（当然,假设它们无一例外地完成了）,这将导致所有子任务的完成时间早于整个流程的完成时间。

Answer 1

如果您希望等待所有线程返回，那么下面的方法是可以信任的。使您的线程类实现callable接口，而不是runnable（如果是callablerun方法将返回一些值。使它返回ThreadName。

创建一个callable对象列表，并使用invokeAll方法，该方法将等待所有线程返回。对于下面的代码，假设线程类名为MyCallable。

ExecutorService executorService = Executors.newFixedThreadPool(foos.size());
List<Callable> tasks = new ArrayList<>();
for (Foo foo : foos) {
  tasks.add(new MyCallable(foo));
 }
 executorService.invokeAll(tasks);

invokeAll返回未来对象的列表（如果您想使用它）。

或

您可以使用CountDownLatch。