在继续执行 ExecutorService 之前如何确保所有任务都已完成？

ExecutorService - 等待任务完成的解决方案

当处理大量需要并发执行的计算任务时，它是重要的是要有一个机制来等待所有任务完成。这确保只有在所有任务完成后才能执行后续操作。

在您的示例中，您尝试使用 ExecutorService.wait() 来实现此目的，您遇到了 IllegalMonitorStateException。出现此错误是因为 wait() 应该在等待对象的固有锁时使用，这在这种情况下不适用。

最简单的解决方案是利用 ExecutorService.invokeAll()。此方法采用 Callable 任务的集合，并行执行它们，并返回 Future 对象的列表。每个 Future 代表特定任务的结果。默认情况下，invokeAll() 将阻塞，直到所有任务完成后才返回 Future 对象列表。

以下是修改代码的方法：

ExecutorService es = Executors.newFixedThreadPool(2);
List<Callable<Object>> tasks = new ArrayList<>();

for (DataTable singleTable : uniquePhrases) {
    tasks.add(Executors.callable(new ComputeDTask(singleTable)));
}

List<Future<Object>> results = es.invokeAll(tasks);

在此更新的代码中，ExecutorService .invokeAll() 将等待所有任务完成，让您可以自信地继续后续操作。

以上是在继续执行 ExecutorService 之前如何确保所有任务都已完成？的详细内容。更多信息请关注PHP中文网其他相关文章！