Java多線Condition條件變量正確使用方法詳解

更新時(shí)間：2023年09月24日 09:43:46 作者：呆小魚(yú)LQ

這篇文章主要為大家,介紹了Java多線Condition條件變量正確使用方法詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

前言

本篇文章的代碼示例已放到 github 上，Git地址為：advance（記錄每一個(gè)學(xué)習(xí)過(guò)程），大家在項(xiàng)目介紹的引用目錄里面即可找到對(duì)應(yīng)文章的一個(gè)代碼路徑。

大家有任何問(wèn)題，歡迎大家在評(píng)論區(qū)留言，我會(huì)在看到后一一進(jìn)行回復(fù)。

背景

在介紹 Condtion 的使用場(chǎng)景之前，我們先來(lái)考慮這樣的場(chǎng)景：

當(dāng)我們?cè)趫?zhí)行某個(gè)方法之前，我們獲得了這個(gè)方法的鎖，但是在執(zhí)行過(guò)程中我們發(fā)現(xiàn)某個(gè)條件不滿足，想讓方法暫停一會(huì)兒，等條件滿足后再讓這個(gè)方法繼續(xù)執(zhí)行。

針對(duì)上面的問(wèn)題，我們可以利用Object.wait()和notify()寫(xiě)出下面這樣的代碼：

public synchronized void doSomething(){
    //執(zhí)行方法
    if(條件不滿足){
        //線程等待
        Object.wait();
    }
    //條件此時(shí)滿足，對(duì)象被喚醒，繼續(xù)執(zhí)行方法
}

但是，由于Object.wait()和notify()過(guò)于底層，并且無(wú)法區(qū)分是由于等待超時(shí)后喚醒還是被其他線程喚醒的問(wèn)題，引入在JDK1.5后引入了java.util.concurrent.locks.Condition接口。

使用場(chǎng)景

Condition接口作為Object.wait()/notify()的替代品，當(dāng)我們給某個(gè)方法加鎖后，發(fā)現(xiàn)某個(gè)條件不滿足，想讓方法暫停一會(huì)兒，等條件滿足后再讓這個(gè)方法繼續(xù)執(zhí)行。這種時(shí)候，我們就可以使用Condition接口。

常用方法

創(chuàng)建一個(gè)condition實(shí)例

為了讓這個(gè)鎖更方便獲得，實(shí)例代碼里面我將這個(gè)鎖設(shè)為靜態(tài)的

//定義一個(gè)鎖
public static final Lock reentrantLock = new ReentrantLock();
//定義屬于這個(gè)鎖的條件變量
public static final Condition condition = reentrantLock.newCondition();

線程等待

void await() throws InterruptedException;

線程非阻塞等待

boolean await(long time, TimeUnit unit)

喚醒某個(gè)線程

condition.signal();

喚醒所有線程

condition.signalAll();

使用示例

定義一個(gè)全局的標(biāo)志位

public class GlobalSymbol {
    /**
     * 定義全局標(biāo)志位
     */
    public static AtomicBoolean globalFlag = new AtomicBoolean(false);
}

主線程

public class Main {
    //定義一個(gè)鎖
    public static final Lock reentrantLock = new ReentrantLock();
    //定義屬于這個(gè)鎖的條件變量
    public static final Condition condition = reentrantLock.newCondition();
    public static void main(String[] args) {
        //先啟動(dòng)一下線程
        Thread thread = new Thread(new OtherThread());
        thread.start();
        //先加鎖
        reentrantLock.lock();
        try {
            System.out.println("線程加鎖成功，正在執(zhí)行相關(guān)代碼");
            while (!GlobalSymbol.globalFlag.get()){
                System.out.println("現(xiàn)在條件還不滿足，先等待");
                condition.await();
            }
            System.out.println("線程被喚醒，執(zhí)行后續(xù)代碼");
        }
        catch (Exception e){
            System.out.println("加鎖解鎖邏輯出現(xiàn)異常");
        }
        finally {
            //在finally中釋放鎖
            reentrantLock.unlock();
        }
        System.out.println("程序結(jié)束");
    }
}

子線程（用于喚醒主線程）

public class OtherThread implements Runnable{
    @Override
    public void run() {
        try {
            for (int i = 10; i > 0; i--){
                System.out.println("標(biāo)志位將在" + i + "秒后置為true");
                TimeUnit.SECONDS.sleep(1);
            }
            GlobalSymbol.globalFlag.set(true);
            //對(duì)被阻塞的線程進(jìn)行喚醒（必須獲得對(duì)應(yīng)的鎖后，才能執(zhí)行喚醒的操作）
            Main.reentrantLock.lock();
            Main.condition.signalAll();
            Main.reentrantLock.unlock();
        }
        catch (Exception e){
            System.out.println("線程執(zhí)行失敗");
        }
    }
}

運(yùn)行結(jié)果

注意事項(xiàng)

加鎖操作lock()一般放在try語(yǔ)句的外面，且緊接著try語(yǔ)句；
解鎖操作unlock()一般放在finally語(yǔ)句中，避免報(bào)錯(cuò)后造成鎖泄漏；
調(diào)用signalAll()進(jìn)行喚醒時(shí)，一定要持有對(duì)應(yīng)的鎖才能調(diào)用該方法，直接調(diào)用該方法會(huì)拋異常。

以上就是Java多線condition條件變量正確使用方法詳解的詳細(xì)內(nèi)容，更多關(guān)于Java多線程condition條件變量的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: