CountDownLatch笔记

CountDownLatch允许一个或多个线程一直等待，直到其他线程的操作执行完后再执行；CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。

public class CountDownLatchDemo {
    static CountDownLatch countDownLatch=new CountDownLatch(3);
    public static class task implements  Runnable{
        @Override
        public void run() {
            try {
                Thread.sleep(1000);//模拟耗时
                System.out.println(Thread.currentThread().getName()+"准备完成");
                countDownLatch.countDown();//表示该任务已完成，计数器减一
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) {
        ExecutorService executorService= Executors.newFixedThreadPool(3);
        for(int i=0;i<3;i++){
            executorService.submit(new task());
        }
        try {
            countDownLatch.await();//等待子线程都完成才能执行
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("火箭发射");
    }
}
执行结果如下
pool-1-thread-3准备完成
pool-1-thread-1准备完成
pool-1-thread-2准备完成
火箭发射

解析：模拟火箭发射，必须等三个线程跑完才能执行主线程；

 

转载于:https://my.oschina.net/u/3734816/blog/3060099