Java多線程正確使用倒計(jì)時(shí)協(xié)調(diào)器CountDownLatch方法詳解

更新時(shí)間：2023年09月24日 09:17:05 作者：呆小魚LQ

這篇文章主要為大家介紹了Java多線程倒計(jì)時(shí)協(xié)調(diào)器CountDownLatch的正確使用方法詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

本篇文章的代碼示例已放到 github 上，Git地址為：advance（記錄每一個(gè)學(xué)習(xí)過(guò)程），大家把代碼下載下來(lái)之后，全局搜索一些關(guān)鍵代碼，即可找到該文章的源碼。

使用場(chǎng)景

想想一個(gè)這樣的場(chǎng)景：我要開始吃飯，需要先滿足幾個(gè)先決條件：

出去買菜
開始做飯
把做好的飯端上桌

只有滿足這幾個(gè)條件之后，我才能真正開始吃飯。同時(shí)，這里吃飯的人可能不止我一個(gè)人，或許還有我的爸爸媽媽等。

CountDownLatch可以用來(lái)實(shí)現(xiàn)一個(gè)或者多個(gè)（注意可以有多個(gè)）線程，等待其他線程完全一組特定的操作后，才開始繼續(xù)執(zhí)行的操作，這些特定的操作被稱作先決條件。

基本原理

CountDownLatch內(nèi)部有一個(gè)表示未完成的先決條件的計(jì)數(shù)器。當(dāng)某個(gè)線程執(zhí)行CountDownLatch.await()時(shí)，如果此時(shí)的計(jì)數(shù)器不為0，那么這個(gè)線程就會(huì)被阻塞掉。

每當(dāng)其他線程執(zhí)行CountDownLatch.countDown()時(shí)，這個(gè)計(jì)數(shù)器就會(huì)被減為0時(shí)，其他被阻塞的線程就會(huì)被自動(dòng)喚醒，執(zhí)行后續(xù)的操作。

常用方法

//構(gòu)造器，定義計(jì)數(shù)器的初始值
public CountDownLatch(int count)：
//阻塞式等待
public void await()
//超時(shí)自動(dòng)喚醒式等待
public boolean await(long timeout, TimeUnit unit)
//計(jì)數(shù)器減1，若此時(shí)計(jì)數(shù)器為0，則等待的那些線程會(huì)被喚醒
public void countDown()
//獲取當(dāng)前計(jì)數(shù)器的值
public long getCount()

使用示例

定義買菜的異步線程

public class MaiCaiThread implements Runnable{
    private CountDownLatch countDownLatch;
    public MaiCaiThread(CountDownLatch countDownLatch) {
        this.countDownLatch = countDownLatch;
    }
    @Override
    public void run() {
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("出門買菜回來(lái)了");
        countDownLatch.countDown();
    }
}

定義做飯的異步線程

public class ZuoFanThread implements Runnable{
    private CountDownLatch countDownLatch;
    public ZuoFanThread(CountDownLatch countDownLatch) {
        this.countDownLatch = countDownLatch;
    }
    @Override
    public void run() {
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("飯做好了");
        countDownLatch.countDown();
    }
}

定義主線程

public class Main {
    static CountDownLatch countDownLatch = new CountDownLatch(2);
    public static void main(String[] args) throws InterruptedException {
        Thread maicai = new Thread(new MaiCaiThread(countDownLatch));
        maicai.start();
        Thread zuoFanThread = new Thread(new ZuoFanThread(countDownLatch));
        zuoFanThread.start();
        System.out.println("我想吃飯了，但是飯還沒做好");
        countDownLatch.await();
        System.out.println("程序結(jié)束，我吃上飯了");
    }
}