时间戳

首页 > 解决方案 > Executorservice Check 全部任务完成

java - Executorservice Check 全部任务完成

问题描述

我想在提交新一批任务之前检查所有执行器服务任务是否已完成，这是我的代码：

     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);

标签： java

解决方案

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);

推荐阅读