博客

CountDownLatch可以保证一组子线程执行完毕后再进行主线程的执行操作.如在服务器主线程启动前.可能需要启动并执行若干子线程.这是就可以通过CountDownLatch来进行控制.

CountDownLatch是通过一个线程个数计数器实现的同步处理操作.在初始化时可以为CountDownLatch设置一个线程执行总数,这样每当一个子线执行完毕后都执行减一的操作.当所有子线程都执行完毕后.CountDownLatch中保存的计数内容为0,则主线程恢复执行.

主要方法

public CountDownLatch(int count) 定义等待子线程数量

public void await() 主线程阻塞,等待子线程执行

public void countDown() 子线程执行完后减少等待数量

public long getCount() 获取当前等待数量

public class CounDownLatch {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(5);

        for (int i = 0; i < 5; i++) {
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"-->上车");
                //等待数量减一
                latch.countDown();
            },"客人"+i).start();
        }
        //等待
        latch.await();
        System.out.println("人员到齐.开车咯....");
    }
}

输出结果

客人0-->上车
客人2-->上车
客人1-->上车
客人3-->上车
客人4-->上车
人员到齐.开车咯....