Java并发编程之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 stjavascriptatic 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; signaDHgBlzjzxl when transiwww.devze.comtion 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);
    }

线程DHgBlzjzx调用countDown时，最终调用Sync中的tryReleaseShared，将总资源减1。

调用await时，最终调用Syn编程客栈c中tryAcquireShared，看资源是否全部释放完。

需要所有线程等待某个条件完成后，才执行某个动作时，可以使用CountDownLatch。

到此这篇关于Java并发编程之CountDownLatch解析的文章就介绍到这了,更多相关Java的CountDownLatch内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！