CountDownLatch详解

功能描述

一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。
常见用法
多个人等一个信号后继续执行操作。例如5个运动员，等一个发令员的枪响。
一个人等多个人的信号。旅游团等所有人签到完成才开始出发。
我们最常见见到使用的地方是zk获取连接的时候

       final CountDownLatch countDownLatch=new CountDownLatch(1); ZooKeeper zooKeeper=new ZooKeeper(zk_url, time_out, new Watcher() { public void process(WatchedEvent watchedEvent) { Event.KeeperState state = watchedEvent.getState(); Event.EventType type = watchedEvent.getType(); if(Event.KeeperState.SyncConnected==state){ if(Event.EventType.None==type){ //调用此方法测计数减一 countDownLatch.countDown(); } } } }); //阻碍当前线程进行,除非计数归零 countDownLatch.await();

这里了也可以看到很明确的使用方法，countDown直到0，await的线程才会继续执行。

原理

CountDownLatch内部使用了共享锁。如果这里还不知道共享和独占的区别，可以看前面的aqs速读。
获取锁成功的方法很简单

        protected int tryAcquireShared(int acquires) {return (getState() == 0) ? 1 : -1;}

共享锁有个约定，返回有三种情况。

0为获取锁且没有其他资源
正数获取锁并且还有其他资源
负数获取锁资源失败

共享锁在tryAcquireShared返回大于0的值的时候，会唤醒其他停顿状态加锁线程。由于没有对state的增加操作，所以当state变成0的时候，所有尝试加锁的线程都会被唤醒。

        protected boolean tryReleaseShared(int releases) {// Decrement count; signal when transition to zerofor (;;) {int c = getState();if (c == 0)return false;int nextc = c-1;if (compareAndSetState(c, nextc))return nextc == 0;}}

释放锁的操作，就是把state的值减一，当只有state变成0的时候，才返回true，tryReleaseShared返回true的时候会触发唤醒其他加锁线程的操作。
通过上面的过程，我们可以看到CountDownLatch中的共享锁的加锁和释放锁的过程，下面看看是如何和CountDownLatch结合的。

    public CountDownLatch(int count) {if (count < 0) throw new IllegalArgumentException("count < 0");this.sync = new Sync(count);}

CountDownLatch的构造里会初始化共享锁，并且设置state的值。

    public void countDown() {sync.releaseShared(1);}

countDown是释放锁，最终会调用到tryReleaseShared。

    public void await() throws InterruptedException {sync.acquireSharedInterruptibly(1);}

await是加锁，最终会调用到 tryAcquireShared。
CountDownLatch就是一个不断释放锁的过程。

常见问题

CountDownLatch是不能够重用的
根据上面的解析，大家也发现，共享锁加锁的操作并不会增加state的值。CountDownLatch中state一旦变成0就没有提供其他方式增长回去了。

所以CountDownLatch是一次性消耗品，用完就得换新的。这样设计也是比较正常的，对状态的要求比较严格，例如都开车了你再告诉司机，这次加了5个人，车都开了一半了，不会考虑再回去。随意修改约束值会带来很多逻辑上的问题。

CountDownLatch无限等待
countDown没有被调用，那么await就会一直等下去。countDown常见没有被调用的情况：异常中断，线程池拒绝策略。

可以使用

public boolean await(long timeout, TimeUnit unit)

根据业务情况，增加一个最大等待时间。使用这种方式，需要对失败的各种情况作出业务上的对应处理，否则就出现各种数据不正确的问题。也可以对countDown的线程做好异常处理，最好使用另外一个线程池来处理这些线程。这种情况就需要对业务不能停顿时间特别长，导致线程池的资源被耗光的情况做处理。如果是想通过new Thread避免，就需要考虑线程突然暴涨的问题。