Java并發(fā)編程之CountDownLatch解析

更新時間：2023年12月20日 10:00:07 作者：Brain_L

這篇文章主要介紹了Java并發(fā)編程之CountDownLatch解析,Sync為一個實現(xiàn)了AQS的內(nèi)部類,代理CountDownLatch的獲取和釋放操作,需要所有線程等待某個條件完成后,才執(zhí)行某個動作時,可以使用CountDownLatch,需要的朋友可以參考下

Java的CountDownLatch

ReentrantLock為獨占鎖，也即排他鎖，同一時刻只能有一個線程持有鎖。現(xiàn)在來看幾種共享鎖。

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) {
            //設置資源總數(shù)
            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、獲取當前資源數(shù)
                int c = getState();
                if (c == 0)
                    return false;
                //2、釋放一個資源
                int nextc = c-1;
                //3、CAS更新資源數(shù)
                if (compareAndSetState(c, nextc))
                    return nextc == 0;
            }
        }
    }

生成CountDownLatch時需要傳入資源總數(shù)，代表所有線程總共享有這么多資源。

Sync為一個實現(xiàn)了AQS的內(nèi)部類，代理CountDownLatch的獲取和釋放操作。

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

線程調(diào)用countDown時，最終調(diào)用Sync中的tryReleaseShared，將總資源減1。

調(diào)用await時，最終調(diào)用Sync中tryAcquireShared，看資源是否全部釋放完。

需要所有線程等待某個條件完成后，才執(zhí)行某個動作時，可以使用CountDownLatch。

到此這篇關于Java并發(fā)編程之CountDownLatch解析的文章就介紹到這了,更多相關Java的CountDownLatch內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: