blue的博客

public (int count);

public class CountDownLacthDemo implements Runnable {
    
    static final CountDownLatch end = new CountDownLatch(10);
    static final CountDownLacthDemo demo = new CountDownLacthDemo();
    
    
    public void run() {
        try {
            Thread.sleep(new Random().nextInt(10) * 1000);
            System.out.println("check complete");
            // 通知CountDownLatch, 一个线程已经完成工作. 倒计时器可以减1了
            end.countDown();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        for (int i=0; i<10; i++) {
            executorService.submit(demo);
        }
        // 要求主线程等待10个任务全部完成后, 主线程才能继续执行
        end.await();
        System.out.println("Fire!");
        executorService.shutdown();
    }
}