33張圖剖析ReentrantReadWriteLock源碼
本文大綱如下

縱觀全局
我的英文名叫ReentrantReadWriteLock
(后面簡(jiǎn)稱RRW
),大家喜歡叫我讀寫鎖,因?yàn)槲页D昊燠E在讀多寫少的場(chǎng)景。讀寫鎖規(guī)范
作為合格的讀寫鎖,先要有讀鎖與寫鎖才行。所以聲明了ReadWriteLock
接口,作為讀寫鎖的基本規(guī)范。
讀鎖與寫鎖
WriteLock與ReadLock就是讀鎖和寫鎖,它們是RRW實(shí)現(xiàn)ReadWriteLock
接口的產(chǎn)物。但讀鎖、寫鎖也要遵守鎖操作的基本規(guī)范。所以WriteLock與ReadLock都實(shí)現(xiàn)了Lock
接口。
AQS
了。AQS
眾所周知,要實(shí)現(xiàn)鎖的基本操作,必須要仰仗AQS
老大哥了。AQS(AbstractQueuedSynchronizer)
抽象類定義了一套多線程訪問共享資源的同步模板,解決了實(shí)現(xiàn)同步器時(shí)涉及的大量細(xì)節(jié)問題,能夠極大地減少實(shí)現(xiàn)工作,用大白話來(lái)說(shuō),AQS
為加鎖和解鎖過(guò)程提供了統(tǒng)一的模板函數(shù),只有少量細(xì)節(jié)由子類自己決定。AQS簡(jiǎn)化流程圖如下
如果讀者想深入AQS細(xì)節(jié),可以看阿星的這篇文章:16張圖揭開AQS
Sync
AQS為加鎖和解鎖過(guò)程提供了統(tǒng)一的模板函數(shù),只有少量細(xì)節(jié)由子類自己決定,但是WriteLock與ReadLock沒有直接去繼承AQS。因?yàn)閃riteLock與ReadLock覺得,自己還要去繼承AQS
實(shí)現(xiàn)一些兩者可以公用的抽象函數(shù),不僅麻煩,還有重復(fù)勞動(dòng)。所以干脆單獨(dú)提供一個(gè)對(duì)鎖操作的類,由WriteLock與ReadLock持有使用,這個(gè)類叫Sync
。Sync繼承AQS實(shí)現(xiàn)了如下的核心抽象函數(shù)- tryAcquire
- release
- tryAcquireShared
- tryReleaseShared

WriteLock
寫鎖準(zhǔn)備的。tryAcquireShared、tryReleaseShared是為ReadLock
讀鎖準(zhǔn)備的,這里阿星后面會(huì)說(shuō)。上面說(shuō)了Sync實(shí)現(xiàn)了一些AQS
的核心抽象函數(shù),但是Sync本身也有一些重要的內(nèi)容,看看下面這段代碼
AQS
中維護(hù)了一個(gè)state
狀態(tài)變量,正常來(lái)說(shuō),維護(hù)讀鎖與寫鎖狀態(tài)需要兩個(gè)變量,但是為了節(jié)約資源,使用高低位切割實(shí)現(xiàn)state
狀態(tài)變量維護(hù)兩種狀態(tài),即高16
位表示讀狀態(tài),低16
位表示寫狀態(tài)。關(guān)于讀寫鎖狀態(tài)設(shè)計(jì)具體細(xì)節(jié)可以看阿星的文章:ReentrantReadWriteLock的位運(yùn)算Sync中還定義了HoldCounter與ThreadLocalHoldCounter
- HoldCounter是用來(lái)記錄讀鎖重入數(shù)的對(duì)象
- ThreadLocalHoldCounter是ThreadLocal變量,用來(lái)存放第一個(gè)獲取讀鎖線程外的其他線程的讀鎖重入數(shù)對(duì)象

如果讀者對(duì)ThreadLocal
不太熟悉,可以去看阿星的文章: 保姆級(jí)教學(xué),22張圖揭開ThreadLocal
公平與非公平策略
你看,人家ReentrantLock
都有公平與非公平策略,所以ReentrantReadWriteLock
也要有。什么是公平與非公平策略?因?yàn)樵?code style="font-size: 14px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;color: rgb(19, 148, 216);padding: 2px 6px;word-break: normal;">AQS流程中,獲取鎖失敗的線程,會(huì)被構(gòu)建成節(jié)點(diǎn)入隊(duì)到CLH
隊(duì)列,其他線程釋放鎖會(huì)喚醒CLH
隊(duì)列的線程重新競(jìng)爭(zhēng)鎖,如下圖所示(簡(jiǎn)化流程)。
CLH
隊(duì)列的線程與CLH
隊(duì)列的線程競(jìng)爭(zhēng)鎖,大家各憑本事,不會(huì)因?yàn)槟闶?code style="font-size: 14px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;color: rgb(19, 148, 216);padding: 2px 6px;word-break: normal;">CLH隊(duì)列的線程,排了很久的隊(duì),就把鎖讓給你。公平策略是指,嚴(yán)格按照CLH
隊(duì)列順序獲取鎖,一定會(huì)讓CLH
隊(duì)列線程競(jìng)爭(zhēng)成功,如果非CLH
隊(duì)列線程一直占用時(shí)間片,那就一直失敗,直到時(shí)間片輪到CLH
隊(duì)列線程為止,所以公平策略的性能會(huì)更差。
FairSync、NonfairSync
子類,兩個(gè)子類實(shí)現(xiàn)了readerShouldBlock、writerShouldBlock函數(shù),即讀鎖與寫鎖是否阻塞。
ReentrantReadWriteLock全局圖
最后阿星把前面講過(guò)的內(nèi)容,全部組裝起來(lái),構(gòu)成下面這張圖。
深入細(xì)節(jié)
后面我們只要攻破5
個(gè)細(xì)節(jié)就夠了,分別是讀寫鎖的創(chuàng)建、獲取寫鎖、釋放寫鎖、獲取讀鎖、釋放讀鎖。ReentrantReadWriteLock的創(chuàng)建
讀寫鎖的創(chuàng)建,會(huì)初始化化一系列類,代碼如下
ReentrantReadWriteLock
默認(rèn)是非公平策略,如果想用公平策略,可以直接調(diào)用有參構(gòu)造器,傳入true
即可。但不管是創(chuàng)建FairSync還是NonfairSync,都會(huì)觸發(fā)Sync
的無(wú)參構(gòu)造器,因?yàn)?code style="font-size: 14px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;color: rgb(19, 148, 216);padding: 2px 6px;word-break: normal;">Sync是它們的父類(本質(zhì)上它們倆都是Sync)。
ReentrantReadWriteLock
對(duì)象作為入?yún)ⅰ?/p>
ReentrantReadWriteLock.sync
把Sync
交給了ReadLock與WriteLock。獲取寫鎖
我們遵守ReadWriteLock接口規(guī)范,調(diào)用ReentrantReadWriteLock.writeLock
函數(shù)獲取寫鎖對(duì)象。
lock
函數(shù)獲取寫鎖。WriteLock.lock函數(shù)是由Sync
實(shí)現(xiàn)的(FairSync或NonfairSync)。
sync.acquire(1)
函數(shù)是AQS中的獨(dú)占式獲取鎖流程模板(Sync繼承自AQS)。

tryAcquire
函數(shù),其他函數(shù)是AQS的獲取獨(dú)占式鎖失敗后的流程內(nèi)容,不屬于本文范疇,tryAcquire
函數(shù)代碼如下

- 讀寫互斥
- 寫寫互斥
- 寫鎖支持同一個(gè)線程重入
- writerShouldBlock寫鎖是否阻塞實(shí)現(xiàn)取決公平與非公平的策略(FairSync和NonfairSync)
釋放寫鎖
獲取到寫鎖,臨界區(qū)執(zhí)行完,要記得釋放寫鎖(如果重入多次要釋放對(duì)應(yīng)的次數(shù)),不然會(huì)阻塞其他線程的讀寫操作,調(diào)用unlock
函數(shù)釋放寫鎖(Lock接口規(guī)范)。WriteLock.unlock函數(shù)也是由Sync實(shí)現(xiàn)的(FairSync或NonfairSync)。
sync.release(1)
執(zhí)行的是AQS中的獨(dú)占式釋放鎖流程模板(Sync繼承自AQS)。

tryRelease
函數(shù),其他函數(shù)是AQS的釋放獨(dú)占式成功后的流程內(nèi)容,不屬于本文范疇,tryRelease
函數(shù)代碼如下

獲取讀鎖
我們遵守ReadWriteLock接口規(guī)范,調(diào)用ReentrantReadWriteLock.readLock
函數(shù)獲取讀鎖對(duì)象。
lock
函數(shù)獲取讀鎖。ReadLock.lock函數(shù)是由Sync
實(shí)現(xiàn)的(FairSync或NonfairSync)。
sync.acquireShared(1)
函數(shù)執(zhí)行的是AQS中的共享式獲取鎖流程模板(Sync繼承自AQS)。

tryAcquireShared
函數(shù),doAcquireShared函數(shù)是AQS的獲取共享式鎖失敗后的流程內(nèi)容,不屬于本文范疇,tryAcquireShared
函數(shù)代碼如下

- 讀鎖共享,讀讀不互斥
- 讀鎖可重入,每個(gè)獲取讀鎖的線程都會(huì)記錄對(duì)應(yīng)的重入數(shù)
- 讀寫互斥,鎖降級(jí)場(chǎng)景除外
- 支持鎖降級(jí),持有寫鎖的線程,可以獲取讀鎖,但是后續(xù)要記得把讀鎖和寫鎖讀釋放
- readerShouldBlock讀鎖是否阻塞實(shí)現(xiàn)取決公平與非公平的策略(FairSync和NonfairSync)
釋放讀鎖
獲取到讀鎖,執(zhí)行完臨界區(qū)后,要記得釋放讀鎖(如果重入多次要釋放對(duì)應(yīng)的次數(shù)),不然會(huì)阻塞其他線程的寫操作,通過(guò)調(diào)用unlock
函數(shù)釋放讀鎖(Lock接口規(guī)范)。ReadLock.unlock函數(shù)也是由Sync實(shí)現(xiàn)的(FairSync或NonfairSync)。
sync.releaseShared(1)
函數(shù)執(zhí)行的是AQS中的共享式釋放鎖流程模板(Sync繼承自AQS)。

tryReleaseShared
函數(shù),doReleaseShared函數(shù)是AQS的釋放共享式鎖成功后的流程內(nèi)容,不屬于本文范疇,tryReleaseShared
函數(shù)代碼如下

- 第一點(diǎn):線程讀鎖的重入數(shù)與讀鎖數(shù)量是兩個(gè)概念,線程讀鎖的重入數(shù)是每個(gè)線程獲取同一個(gè)讀鎖的次數(shù),讀鎖數(shù)量則是所有線程的讀鎖重入數(shù)總和。
- 第二點(diǎn):AQS的共享式釋放鎖流程模板中,只有全部的讀鎖被釋放了,才會(huì)去執(zhí)行doReleaseShared函數(shù)
- 第三點(diǎn):因?yàn)槭褂玫氖茿QS共享式流程模板,如果CLH隊(duì)列后面的線程節(jié)點(diǎn)都是因?qū)戞i阻塞的讀鎖線程節(jié)點(diǎn),會(huì)傳播喚醒
小結(jié)
最后阿星做個(gè)小結(jié),ReentrantReadWriteLock
底層實(shí)現(xiàn)與ReentrantLock
思路一致,它們都離不開AQS
,都是聲明一個(gè)繼承AQS
的Sync
,并在Sync
下擴(kuò)展公平與非公平策略,后續(xù)的鎖相關(guān)操作都委托給公平與非公平策略執(zhí)行。我們還發(fā)現(xiàn),在AQS
中除了獨(dú)占式模板,還有共享式模板,它們?cè)诙嗑€程訪問共享資源的流程會(huì)有所差異,就如ReentrantReadWriteLock
中讀鎖使用共享式,寫鎖使用獨(dú)占式。最后再捋一捋寫鎖與讀鎖的邏輯- 讀讀不阻塞
- 寫鎖阻塞寫之后的讀寫鎖,但是不阻塞寫鎖之前的讀鎖線程
- 寫鎖會(huì)被寫之前的讀寫鎖阻塞
- 讀鎖節(jié)點(diǎn)喚醒會(huì)無(wú)條件傳播喚醒CLH隊(duì)列后面的讀鎖節(jié)點(diǎn)
- 寫鎖可以降級(jí)為讀鎖,防止更新丟失
- 讀鎖、寫鎖都支持重入