當前位置：首頁 > 科技 > 軟件

被問到ReentrantLock你真的能答好嗎？

來源：責編：時間：2023-10-26 17:10:11 258觀看

導讀一、先了解一下我們知道實現一把鎖要有如下幾個邏輯：鎖的標識線程搶鎖的邏輯線程掛起的邏輯線程存儲邏輯線程釋放鎖的邏輯線程喚醒的邏輯我們在講解AQS的時候說過AQS基本負責了實現鎖的全部邏輯，唯獨線程搶鎖和線程釋放

一、先了解一下

我們知道實現一把鎖要有如下幾個邏輯：

鎖的標識
線程搶鎖的邏輯
線程掛起的邏輯
線程存儲邏輯
線程釋放鎖的邏輯
線程喚醒的邏輯

我們在講解AQS的時候說過AQS基本負責了實現鎖的全部邏輯，唯獨線程搶鎖和線程釋放鎖的邏輯是交給子類來實現了，而ReentrantLock作為最常用的獨占鎖，其內部就是包含了AQS的子類實現了線程搶鎖和釋放鎖的邏輯。

我們在使用ReentrantLock的時候一般只會使用如下方法：

 ReentrantLock lock=new ReentrantLock(); lock.lock(); lock.unlock(); lock.tryLock(); Condition condition=lock.newCondition(); condition.await(); condition.signal(); condition.signalAll();

二、技術架構

如果我們自己來實現一個鎖，那么如何設計呢？

根據AQS的邏輯，我們寫一個子類sync,這個類一定會調用父類的acquire方法進行上鎖，同時重寫tryAcquire方法實現自己搶鎖邏輯，也一定會調用release方法進行解鎖，同時重寫tryRelease方法實現釋放鎖邏輯。

那么ReentrantLock是怎么實現的呢？

ReentrantLock的實現的類架構如下，ReentrantLock對外提供作為一把鎖應該具備的api，比如lock加鎖，unlock解鎖等等，而它內部真正的實現是通過靜態內部類sync實現，sync是AQS的子類，是真正的鎖，因為這把鎖需要支持公平和非公平的特性，所以sync又有兩個子類FairSync和NonfairSync分別實現公平鎖和非公平鎖。

因為是否公平說的是搶鎖的時候是否公平，那兩個子類就要在上鎖方法acquire的調用和搶鎖方法tryAcquire的重寫上做文章。

公平鎖做了什么文章？

 static final class FairSync extends Sync {          final void lock() {            acquire(1);        }        protected final boolean tryAcquire(int acquires) {            final Thread current = Thread.currentThread();            int c = getState();            if (c == 0) {                if (!hasQueuedPredecessors() &&                    compareAndSetState(0, acquires)) {                    setExclusiveOwnerThread(current);                    return true;                }            }            else if (current == getExclusiveOwnerThread()) {                int nextc = c + acquires;                if (nextc < 0)                    throw new Error("Maximum lock count exceeded");                setState(nextc);                return true;            }            return false;        }    }

公平鎖比較簡單，直接調用了父級類AQS的acquire方法，因為AQS的鎖默認就是公平的排隊策略。

重寫tryAcquire方法的邏輯為：

判斷當前鎖是否被占用，即state是否為0
如果當前鎖沒有被占用，然后會判斷等待隊列中是否有線程在阻塞等待，如果有，那就終止搶鎖，如果沒有，就通過cas搶鎖，搶到鎖返回true,沒有搶到鎖返回false。
如果當前鎖已經被占用，然后判斷占用鎖的線程是不是自己，如果是，就會將state加1，表示重入,返回true。如果不是自己那就是代表沒有搶到鎖，返回false。

公平就公平在老老實實排隊。

非公平鎖做了什么文章？

  static final class NonfairSync extends Sync {              final void lock() {            if (compareAndSetState(0, 1))                setExclusiveOwnerThread(Thread.currentThread());            else                acquire(1);        }        protected final boolean tryAcquire(int acquires) {            return nonfairTryAcquire(acquires);        }    }        //nonfairTryAcquire代碼在父類sync里面     final boolean nonfairTryAcquire(int acquires) {            final Thread current = Thread.currentThread();            int c = getState();            if (c == 0) {                if (compareAndSetState(0, acquires)) {                    setExclusiveOwnerThread(current);                    return true;                }            }            else if (current == getExclusiveOwnerThread()) {                int nextc = c + acquires;                if (nextc < 0) // overflow                    throw new Error("Maximum lock count exceeded");                setState(nextc);                return true;            }            return false;        }

非公平鎖也很簡單，沒有直接調用了父級類AQS的acquire方法，而是先通過cas搶鎖，它不管等待隊列中有沒有其他線程在排隊，直接搶鎖，這就體現了不公平。

它重寫tryAcquire方法的邏輯為：

判斷當前鎖是否被占用，即state是否為0
如果當前鎖沒有被占用，就直接通過cas搶鎖（不管等待隊列中有沒有線程在排隊），搶到鎖返回true,沒有搶到鎖返回false。
如果當前鎖已經被占用，然后判斷占用鎖的線程是不是自己，如果是，就會將state加1，表示重入,返回true。如果不是自己那就是代表沒有搶到鎖，返回false。

公平鎖和非公平分別重寫了tryAcquire方法，來滿足公平和非公平的特性。那么tryAcquire方法也是需要子類重寫的，因為它和是否公平無關，因此tryAcquire方法被抽象到sync類中重寫。

sync類中protected final boolean tryRelease(int releases) {            int c = getState() - releases;            if (Thread.currentThread() != getExclusiveOwnerThread())                throw new IllegalMonitorStateException();            boolean free = false;            if (c == 0) {                free = true;                setExclusiveOwnerThread(null);            }            setState(c);            return free;        }

釋放鎖的邏輯如下:

獲取state的值，然后減1
如果state為0，代表鎖已經釋放，清空aqs中的持有鎖的線程字段的值
如果state不為0，說明當前線程重入了，還需要再次釋放鎖
將state寫回

釋放鎖往往和搶鎖邏輯是對應的，每個子類搶鎖邏輯不同的話，釋放鎖的邏輯也會對應不同。

三、具體實現

接下來我們通過ReentrantLock的使用看下它的源碼實現：

class X {            private final ReentrantLock lock = new ReentrantLock();            Condition condition1=lock.newCondition();            Condition condition2=lock.newCondition();            public void m() {                lock.lock();                try {                    if(條件1){                        condition1.await();                    }                    if(條件2){                        condition2.await();                    }                } catch (InterruptedException e) {                } finally {                    condition1.signal();                    condition2.signal();                    lock.unlock();                }            }        }

1.先看這個方法：lock.lock()

ReentrantLock類public void lock() {        sync.lock();    }

  NonfairSync 類中  final void lock() {    if (compareAndSetState(0, 1))    setExclusiveOwnerThread(Thread.currentThread());    else      acquire(1);  }

  FairSync 類中  final void lock() {      acquire(1);  }

公平鎖和非公平鎖中都實現了lock方法，公平鎖直接調用AQS的acquire，而非公平鎖先搶鎖，搶不到鎖再調用AQS的acquire方法進行上鎖

進入acquire方法后的邏輯我們就都知道了。

2.再看這個方法lock.unlock()

public void unlock() {        sync.release(1);}

unlock方法內直接調用了AQS的Release方法進行解鎖的邏輯，進入release方法后邏輯我們都已經知道了，這里不再往下跟。

3.最后看這個方法lock.tryLock()

這個方法中直接調用了sync中的nonfairTryAcquire方法，這個就是非公平鎖實現的TryAcquire方法，只是名字改了而已。

tryLock方法的意思是嘗試搶鎖，是給程序員調用的嘗試搶鎖方法，如果搶鎖成功返回true，搶鎖失敗返回false，當拿到搶鎖失敗的信號后，程序員可以做一些自己的策略。

如果沒有tryLock方法，而是直接調用lock方法，就會走到acquire方法中，Acquire方法中也會調用TryAcquire方法，只不過在這里如果獲取不到鎖就會入隊阻塞了，就沒有程序員參與的可能了。

4.lock.newCondition();

在AQS那篇我們說過Condition是AQS中的條件隊列，可以按條件將一批線程由不可喚醒變為可喚醒。

ReentrantLock類 public Condition newCondition() {        return sync.newCondition(); }

sync靜態內部類final ConditionObject newCondition() {            return new ConditionObject();}

sync提供了創建Condition對象的方法，意味著ReentrantLock也擁有Condition的能力。

四、ReentrantLock和synchronized對比

我們下面說的ReentrantLock其實就是說AQS,因為它的同步實現主要在AQS里面。

1.實現方面

ReentrantLock是jdk級別實現的，其源碼在jdk源碼中可以查看，沒有脫離java。
synchronized是jvm級別實現的，synchronized只是java端的一個關鍵字，具體邏輯實現都在jvm中。

2.性能方面

優化前的synchronized性能很差，主要表現在兩個方面：

因為大多數情況下對于資源的爭奪并沒有那么激烈，甚至于某個時刻可能只有一個線程在工作，在這種沒有競爭或者競爭壓力很小的情況下，如果每個線程都要進行用戶態到內核態的切換其實是很耗時的。
jdk1.6對synchronized底層實現做了優化，優化后，在單線程以及并發不是很高的情況下通過無鎖偏向和自旋鎖的方式避免用戶態到內核態的切換，因此性能提高了，優化后的synchronized和ReentrantLock性能差不多了。

ReentrantLock是在jdk實現的，它申請互斥量就是對鎖標識state的爭奪，它是通過cas方式實現。在java端實現。

對于爭奪不到資源的線程依然要阻塞掛起，但凡阻塞掛起都要依賴于操作系統底層，這一步的用戶態到內核態的切換是避免不了的。

因此在單線程進入代碼塊的時候，效率是很高的，因此我們說ReentrantLock性能高于原始的synchronized：

申請互斥量：synchronized的鎖其實就是爭奪Monitor鎖的擁有權，這個爭奪過程是通過操作系統底層的互斥原語Mutex實現的，這個過程會有用戶態到內核態的切換。
線程阻塞掛起：沒能搶到到Monitor鎖擁有權的線程要阻塞掛起，阻塞掛起這個動作也是依靠操作系統實現的，這個過程也需要用戶態到內核態的切換。

3.特性方面

兩個都是常用的典型的獨占鎖。

ReentrantLock可重入，可中斷，支持公平和非公平鎖，可嘗試獲取鎖，可以支持分組將線程由不可喚醒變為可喚醒。
synchronized可重入，不可中斷，非公平鎖，不可嘗試獲取鎖，只支持一個或者全部線程由不可喚醒到可喚醒。

4.使用方面

synchronized不需要手動釋放鎖，ReentrantLock需要手動釋放鎖，需要考慮異常對釋放鎖的影響避免異常導致線程一直持有鎖。

以下是兩個鎖的使用方式：

class X {            private final ReentrantLock lock = new ReentrantLock();            Condition condition1=lock.newCondition();            Condition condition2=lock.newCondition();            public void m() {                lock.lock();                try {                    if(1==2){                        condition1.await();                    }                    if(1==3){                        condition2.await();                    }                } catch (InterruptedException e) {                } finally {                    condition1.signal();                    condition2.signal();                    lock.unlock();                }            }        }

   class X {            private final testtest sync=new testtest();;            public void m() throws InterruptedException {                synchronized(sync){                    if(1==2){                        sync.wait();                    }                    sync.notify();                    sync.notifyAll();                }            }        }

對比代碼及特性說明：

兩個鎖都是依賴一個對象：lock和sync
condition和wait方法具有同樣的效果，進入condition和wait的線程將陷入等待（不可喚醒狀態），只有被分別調用signal和notify方法線程才會重新變為可喚醒狀態，請注意是可喚醒，而不是被喚醒。
可喚醒是說具備了競爭資源的資格，資源空閑后，synchronized中會在可喚醒狀態的線程中隨機挑選一個線程去拿鎖，而ReentrantLock中不可喚醒的線程變為可喚醒狀態，其實就是將條件隊列中的線程搬到等待隊列中排隊，只有隊頭的才會去嘗試拿鎖。
ReentrantLock分批將線程由不可喚醒變為可喚醒也在這段代碼中體現了，代碼中按照不同的條件將線程放入不同的condition，每個condition就是一個組，釋放的時候也可以按照不同的條件進行釋放。而synchronized中進入wait的線程不能分組，釋放也只能隨機釋放一個或者全部釋放。

本文鏈接：http://www.tebozhan.com/showinfo-26-15183-0.html被問到ReentrantLock你真的能答好嗎？

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇：是時候放棄Dockerfile了，考慮上手Buildpack吧

下一篇：掌握Go編程中的錯誤處理和日志記錄

標簽：

熱門焦點

天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

這幾年除了手機作為智能生活終端最主要的核心之外，第二個可以成為中心點的產品是什么？——是智能音箱。手機在執行命令的時候有兩種操作方式，手和智能語音助手，而智能音箱只
5月安卓手機好評榜：魅族20 Pro奪冠

性能榜和性價比榜之后，我們來看最后的安卓手機好評榜，數據來源安兔兔評測，收集時間2023年5月1日至5月31日，僅限國內市場。第一名：魅族20 Pro好評率：97.50%不得不感慨魅族老品牌還
印度登月最關鍵一步！月船三號今晚進入環月軌道

8月5日消息，據印度官方消息，月船三號將于北京時間今晚21時30分左右開始近月制動進入環月軌道。這是該探測器能夠成功的最關鍵步驟之一，如果成功將開始圍
JavaScript 混淆及反混淆代碼工具

介紹在我們開始學習反混淆之前，我們首先要了解一下代碼混淆。如果不了解代碼是如何混淆的，我們可能無法成功對代碼進行反混淆，尤其是使用自定義混淆器對其進行混淆時。什么是混
零售大模型“干中學”，攀爬數字化珠峰

文/侯煜編輯/cc來源/華爾街科技眼對于絕大多數登山愛好者而言，攀爬珠穆朗瑪峰可謂終極目標。攀登珠峰的商業路線有兩條，一是尼泊爾境內的南坡路線，一是中國境內的北坡路線。相
ESG的面子與里子

來源 | 光子星球撰文 | 吳坤諺編輯 | 吳先之三伏大幕拉起，各地高溫預警不絕，但處于厄爾尼諾大“烤”之下的除了眾生，還有各大企業發布的ESG報告。ESG是“環境保
半導體需求下滑三星電子DS業務部門今年營業虧損預計超10萬億韓元

7月17日消息，據外媒報道，去年下半年開始的半導體需求下滑，影響到了三星電子、SK海力士、英特爾等諸多廠商，營收明顯下滑，部分廠商甚至出現了虧損。作為
iQOO 11S評測：行業唯一的200W標準版旗艦

【Techweb評測】去年底，iQOO推出了“電競旗艦”iQOO 11系列，作為一款性能強機，該機不僅全球首發2K 144Hz E6全感屏，搭載了第二代驍龍8平臺及144Hz電競
AI藝術欣賞體驗會在上海梅賽德斯奔馳中心音樂俱樂部上演

光影交錯的鏡像世界，虛實幻化的視覺奇觀，虛擬偶像與真人共同主持，這些場景都出現在2019世界人工智能大會的舞臺上。8月29日至31日，“AI藝術欣賞體驗會”在上海

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

被問到ReentrantLock你真的能答好嗎？

一、先了解一下

二、技術架構

三、具體實現

1.先看這個方法：lock.lock()

2.再看這個方法lock.unlock()

3.最后看這個方法lock.tryLock()

4.lock.newCondition();

四、ReentrantLock和synchronized對比

1.實現方面

2.性能方面

3.特性方面

4.使用方面

天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

5月安卓手機好評榜：魅族20 Pro奪冠

印度登月最關鍵一步！月船三號今晚進入環月軌道

JavaScript 混淆及反混淆代碼工具

零售大模型“干中學”，攀爬數字化珠峰

ESG的面子與里子

半導體需求下滑三星電子DS業務部門今年營業虧損預計超10萬億韓元

iQOO 11S評測：行業唯一的200W標準版旗艦

AI藝術欣賞體驗會在上海梅賽德斯奔馳中心音樂俱樂部上演

最新推薦

猜你喜歡

熱門推薦

相關資訊