执行器服务检查所有任务都已完成

Question

在提交新一批任务之前，我想检查是否所有的executor服务任务都完成了这是我的代码：

ExecutorService executorService = Executors.newFixedThreadPool(concurrency);
for(int i=0;i<batch;i++){      

for(int j=0;j<concurrency;j++) {
executorService.submit(new DOTASK(0,loopTimes));
}

while(executorService != done){
// wait
}
System.out.println("Batch "+i+"Complete")
}
executorService.shutdown();
executorService.awaitTermination(1, TimeUnit.DAYS);

Answer 1

CountDownLatch是的一个选项

ExecutorService executorService = Executors.newFixedThreadPool(concurrency);
for(int i=0;i<batch;i++){      
CountLatchDown latch = new CountDownLatch(concurrency);
for(int j=0;j<concurrency;j++) {
executorService.submit(new DOTASK(0,loopTimes));
}
//in each DOTASK thread invoke latch.countDown()
latch.await();
System.out.println("Batch "+i+"Complete")
}
executorService.shutdown();
executorService.awaitTermination(1, TimeUnit.DAYS);