如文档中所述,您不能重复使用
ExecutorService已关闭的。我建议您不要使用任何
变通方法 ,因为(a)它们可能无法在所有情况下都按预期工作;(b)您可以使用标准类来实现所需的目标。
你必须
实例化一个新的
ExecutorService
;要么不终止
ExecutorService
。
第一个解决方案很容易实现,因此我不再赘述。
第二,由于您要在所有提交的任务完成后执行一个动作,因此您可以查看
ExecutorCompletionService并使用它。它包装了一个
ExecutorService将执行线程管理的对象,但是可运行对象将被包装为一个内容,这些内容将告诉
ExecutorCompletionService它们何时完成操作,因此它可以向您报告:
ExecutorService executor = ...;ExecutorCompletionService ecs = new ExecutorCompletionService(executor);for (int i = 0; i < totalTasks; i++) { ... ecs.submit(...); ...}for (int i = 0; i < totalTasks; i++) { ecs.take();}类
take()上的方法
ExecutorCompletionService将阻塞,直到任务完成(正常或突然)。它将返回
Future,因此您可以根据需要检查结果。
希望这对您有所帮助,因为我不完全了解您的问题。



