透过CountDownLatch来分析AbstractQueuedSynchronizer的源码

通过CountDownLatch来分析AbstractQueuedSynchronizer的源码

CountDownLatch：计数门闩，可以用来协调多个线程的协作，使用CountDownLatch的典型场景：某项工作需要多个线程共同来完成，并且其中一个线程（往往是主线程）需要等待其他线程都已经完成了自己的工作时才能继续进行，否则要等待。下面分析CountDownLatch源码：

?

?CountDownLatch代码非常简单，关键方法已经加上了注释，CountDownLatch的核心逻辑都委托给了Sync这个静态内部类。Sync类继承了AbstractQueuedSynchronizer 。AbstractQueuedSynchronizer 为实现依赖于先进先出 (FIFO) 等待队列的阻塞锁定和相关同步器（信号量、事件，等等）提供一个框架。此类的设计目标是成为依靠单个原子 int 值来表示状态的大多数同步器的一个有用基础。通俗点说，用java的人都知道synchronized能够对一个需要确保线程安全的对象，方法实现多线程并发控制，这是在java语法层次的实现，而AbstractQueuedSynchronizer 则是在应用层次而不是语法层次（更高的层次）提供了实现多线程并发控制组件的基础框架，通过AbstractQueuedSynchronizer 
我们可以根据自己的需要设计灵活的多线程并发控制组件，CountDownLatch就是这种组件的典型代表。AbstractQueuedSynchronizer 代码比较复杂，先由浅至深的开始学习，
首先看一下其类层次结构：



?可以看出AbstractQueuedSynchronizer的子类都是静态内部类（比如CountDownLatch.Sync）,其javadoc已明确说明了具体用法：
    /**     * Acquires in shared interruptible mode.     * @param arg the acquire argument     */    private void doAcquireSharedInterruptibly(int arg)        throws InterruptedException {        final Node node = addWaiter(Node.SHARED);        try {            for (;;) {                final Node p = node.predecessor();                if (p == head) {                    int r = tryAcquireShared(arg);                    if (r >= 0) {                        setHeadAndPropagate(node, r);                        p.next = null; // help GC                        return;                    }                }                if (shouldParkAfterFailedAcquire(p, node) &&                    parkAndCheckInterrupt())                    break;            }        } catch (RuntimeException ex) {            cancelAcquire(node);            throw ex;        }        // Arrive here only if interrupted        cancelAcquire(node);        throw new InterruptedException();    }