CountDownLatch

CountDownLatch 也称为闭锁。使用共享锁的原理用来解决

实现

CountDownLatch 的接口如图所示。

CountDownLatch

1
2
3
4
5
6
public void await() throws InterruptedException {
    sync.acquireSharedInterruptibly(1);
}
public void countDown() {
    sync.releaseShared(1);
}

与 ReentrantLock 一样，其也有一个内部类 Sync，继承了 AbstractQueueSynchronizer类。主要接口方法全权委托 Sync 去实现。

CountDownLatch 的构造函数如下所示：

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

而 Sync 的构造函数如下：

1
2
3
Sync(int count) {
    setState(count);
}

可以看到，Sync 是将 AQS 内部的 state 变量作为一个计数变量来实现的。

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

调用 await 方法的时候就去获取共享锁，如果 state 变量的值不为 0，则线程排到等待的阻塞队列中，直到被唤醒。

（未完。。。）