利用 ExecutorService 时,开发人员可能需要暂停执行,直到所有分配的任务完成。本次调查探讨了实现这一目标的最简单方法。
问题:
执行大量计算任务,每个核心一个,并暂停执行直至完成。当前实现利用 ExecutorService.execute() 和 es.wait(),但面临 IllegalMonitorStateException。
答案:
使用 ExecutorService.invokeAll(),一个简单的解决方案只需一行即可完成所需的功能code:
List<Callable<Object>> todo = new ArrayList<Callable<Object>>(singleTable.size()); for (DataTable singleTable: uniquePhrases) { todo.add(Executors.callable(new ComputeDTask(singleTable))); } List<Future<Object>> answers = es.invokeAll(todo);
invokeAll() 暂停执行,直到所有任务完成,无需手动关闭和awaitTermination()。此方法与跨多个执行的可重用 ExecutorService 实例保持一致。
要进一步探索相关主题,请参阅以下参考资料:
以上是如何使用ExecutorService高效等待任务完成?的详细内容。更多信息请关注PHP中文网其他相关文章!