這篇文章主要介紹“JUC的CountDownLatch如何實現(xiàn)”，在日常操作中，相信很多人在JUC的CountDownLatch如何實現(xiàn)問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”JUC的CountDownLatch如何實現(xiàn)”的疑惑有所幫助！接下來，請跟著小編一起來學(xué)習(xí)吧！

創(chuàng)新互聯(lián)公司為您提適合企業(yè)的網(wǎng)站設(shè)計?讓您的網(wǎng)站在搜索引擎具有高度排名，讓您的網(wǎng)站具備超強的網(wǎng)絡(luò)競爭力！結(jié)合企業(yè)自身，進(jìn)行網(wǎng)站設(shè)計及把握，最后結(jié)合企業(yè)文化和具體宗旨等，才能創(chuàng)作出一份性化解決方案。從網(wǎng)站策劃到成都做網(wǎng)站、網(wǎng)站制作， 我們的網(wǎng)頁設(shè)計師為您提供的解決方案。

CountDownLatch 是一個同步輔助工具，用于阻塞當(dāng)前一個或多個線程以等待其它線程中的操作完成。在構(gòu)造 CountDownLatch 對象時，我們需要指定一個非負(fù)的 count 值，一般情況下，調(diào)用 CountDownLatch#await 方法的線程需要阻塞等待該 count 值變?yōu)?0 時才能夠繼續(xù)往下執(zhí)行。

CountDownLatch 實現(xiàn)內(nèi)幕

CountDownLatch 在實現(xiàn)上同樣依賴于 AQS 組件，在 CountDownLatch 的內(nèi)部定義了一個 Sync 內(nèi)部類，該類繼承自 AbstractQueuedSynchronizer，并復(fù)用 AQS 的 state 字段以記錄 count 值的變化。CountDownLatch 的核心方法均委托 Sync 進(jìn)行處理，實現(xiàn)如下：

public class CountDownLatch {

    private final Sync sync;

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

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

    public boolean await(long timeout, TimeUnit unit) throws InterruptedException {
        return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout));
    }

    public void countDown() {
        sync.releaseShared(1);
    }

    public long getCount() {
        return sync.getCount();
    }

}

下面我們主要分析一下 CountDownLatch#await 和 CountDownLatch#countDown 方法的實現(xiàn)。

首先來看一下 CountDownLatch#await 方法，該方法用于阻塞當(dāng)前線程，直到 count 值變?yōu)?0，或者被其它線程中斷。具體實現(xiàn)上，CountDownLatch 直接將請求委托給 AQS 的 AbstractQueuedSynchronizer#acquireSharedInterruptibly 方法進(jìn)行處理，所以我們下面主要來看一下 CountDownLatch 針對模板方法 AbstractQueuedSynchronizer#tryAcquireShared 的實現(xiàn)，如下：

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

實現(xiàn)上非常簡單，獲取并判定狀態(tài)值是否為 0，如果是則說明當(dāng)前線程獲取資源成功，能夠繼續(xù)往下執(zhí)行，否則說明當(dāng)前線程獲取資源失敗，需要被添加到同步隊列阻塞等待。CountDownLatch 還為 CountDownLatch#await 方法定義了超時版本 CountDownLatch#await(long, TimeUnit)。

繼續(xù)來看一下 CountDownLatch#countDown 方法，該方法用于將 count 值減 1，如果發(fā)現(xiàn) count 值變?yōu)?0，則喚醒阻塞等待的線程。具體實現(xiàn)上，CountDownLatch 同樣直接將請求委托給 AQS 的 AbstractQueuedSynchronizer#releaseShared 方法進(jìn)行處理，所以我們下面主要來看一下 CountDownLatch 針對模板方法 AbstractQueuedSynchronizer#tryReleaseShared 的實現(xiàn)，如下：

protected boolean tryReleaseShared(int releases) {
    // Decrement count; signal when transition to zero
    for (; ; ) {
        // 獲取 state 狀態(tài)值
        int c = getState();
        // 如果已經(jīng)為 0 則說明沒有資源可以釋放，直接返回 false，避免 state 變?yōu)樨?fù)值
        if (c == 0) {
            return false;
        }
        // 資源數(shù)減 1
        int nextc = c - 1;
        if (compareAndSetState(c, nextc)) {
            // 如果為 0，則說明資源全部釋放完畢，此時需要喚醒等待的線程
            return nextc == 0;
        }
    }
}

具體實現(xiàn)如代碼注釋，比較簡單。需要注意的一點就是上面步驟中的判 0 操作，剛開始看的時候可能覺得有點多余，但是這一步的主要作用在于保證 state 值不會變?yōu)樨?fù)值。當(dāng)前 count 值變?yōu)?0 時，上述方法會返回 true，接下去 AQS 會執(zhí)行喚醒之前因為 count 值不為 0 而被打入同步隊列的線程。

到此，關(guān)于“JUC的CountDownLatch如何實現(xiàn)”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

分享名稱：JUC的CountDownLatch如何實現(xiàn)
網(wǎng)站路徑：http://jinyejixie.com/article30/gdpcpo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站改版、標(biāo)簽優(yōu)化、網(wǎng)站收錄、電子商務(wù)、商城網(wǎng)站、定制網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)