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

更新時間：2023年09月24日 09:43:46 作者：呆小魚LQ

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

前言

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

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

背景

在介紹 Condtion 的使用場景之前，我們先來考慮這樣的場景：

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

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

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

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

使用場景

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

常用方法

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

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

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

線程等待

void await() throws InterruptedException;

線程非阻塞等待

boolean await(long time, TimeUnit unit)

喚醒某個線程

condition.signal();

喚醒所有線程

condition.signalAll();

使用示例

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

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

主線程

public class Main {
    //定義一個鎖
    public static final Lock reentrantLock = new ReentrantLock();
    //定義屬于這個鎖的條件變量
    public static final Condition condition = reentrantLock.newCondition();
    public static void main(String[] args) {
        //先啟動一下線程
        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);
            //對被阻塞的線程進(jìn)行喚醒（必須獲得對應(yīng)的鎖后，才能執(zhí)行喚醒的操作）
            Main.reentrantLock.lock();
            Main.condition.signalAll();
            Main.reentrantLock.unlock();
        }
        catch (Exception e){
            System.out.println("線程執(zhí)行失敗");
        }
    }
}