Java并发编程之CountDownLatch解析
作者：Brain_L
这篇文章主要介绍了Java并发编程之CountDownLatch解析,Sync为一个实现了AQS的内部类,代理CountDownLatch的获取和释放操作,需要所有线程等待某个条件完成后,才执行某个动作时,可以使用CountDownLatch,需要的朋友可以参考下
Java的CountDownLatch
ReentrantLock为独占锁，也即排他锁，同一时刻只能有一个线程持有锁。现在来看几种共享锁。
CountDownLatch
public CountDownLatch(int count) {
if (count < 0) throw new IllegalArgumentException("count < 0");
this.sync = new Sync(count);
}
private final Sync sync;
private static final class Sync extends AbstractQueuedSynchronizer {
private static final long serialVersionUID = 4982264981922014374L;
Sync(int count) {
//设置资源总数
setState(count);
}
int getCount() {
return getState();
}
protected int tryAcquireShared(int acquires) {
//资源
return (getState() == 0) ? 1 : -1;
}
protected boolean tryReleaseShared(int releases) {
// Decrement count; signal when transition to zero
for (;;) {
//1、获取当前资源数
int c = getState();
if (c == 0)
return false;
//2、释放一个资源
int nextc = c-1;
//3、CAS更新资源数
if (compareAndSetState(c, nextc))
return nextc == 0;
}
}
}生成CountDownLatch时需要传入资源总数，代表所有线程总共享有这么多资源。
Sync为一个实现了AQS的内部类，代理CountDownLatch的获取和释放操作。
public void await() throws InterruptedException {
sync.acquireSharedInterruptibly(1);
}
public void countDown() {
sync.releaseShared(1);
}线程调用countDown时，最终调用Sync中的tryReleaseShared，将总资源减1。
调用await时，最终调用Sync中tryAcquireShared，看资源是否全部释放完。
需要所有线程等待某个条件完成后，才执行某个动作时，可以使用CountDownLatch。
到此这篇关于Java并发编程之CountDownLatch解析的文章就介绍到这了,更多相关Java的CountDownLatch内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！