Lock框架

Lock框架為java并發(fā)編程提供了除synchronized之外的另外一種選擇。synchronized是隱式實(shí)現(xiàn)，底層封裝了對(duì)鎖資源的獲取和釋放的所有實(shí)現(xiàn)細(xì)節(jié)，程序員不需要關(guān)心也沒(méi)有辦法關(guān)心這些細(xì)節(jié)，使用起來(lái)非常方便也非常安全。

而Lock由java語(yǔ)言實(shí)現(xiàn)，公開(kāi)了鎖資源獲取和釋放的所有細(xì)節(jié)，在資源鎖定過(guò)程中提供了更多選項(xiàng)，在獲取鎖資源后，可以通過(guò)Condition對(duì)象對(duì)鎖資源做細(xì)粒度的管理。

最關(guān)鍵的是Lock大量使用了CAS，充分利用“持有鎖的線(xiàn)程不會(huì)長(zhǎng)時(shí)間占用鎖”這一假設(shè)，有可能的情況下就盡量先自旋、后鎖定資源。所以多線(xiàn)程環(huán)境下Lock應(yīng)該比synchronized有更好的性能。

java線(xiàn)程池框架Executor中大量使用了基于Lock接口的ReentrantLock，掌握ReentrantLock是深入理解各種Executor（ThreadPoolExecutor、ScheduledThreadPoolExecutor等）以及各種阻塞隊(duì)列的必要前提。

Lock有獨(dú)占鎖、共享鎖的區(qū)別，獨(dú)占鎖是指某一線(xiàn)程獲取鎖資源后即獨(dú)占該鎖資源、其他線(xiàn)程只能等待，共享鎖是指多個(gè)線(xiàn)程能同時(shí)獲得鎖資源。

今天我們的研究對(duì)象是ReentrantLock，ReentrantLock是獨(dú)占鎖，主要研究?jī)?nèi)容：

• ReentrantLock的基本概念
• 基礎(chǔ)數(shù)據(jù)機(jī)構(gòu)：AQS，CLH隊(duì)列
• 公平鎖、非公平鎖
• Condition
• 沒(méi)有Condition參與的lock、unlock
• 有Condition參與的lock、unlock

ReentrantLock的基本概念

顧名思義，ReentrantLock是“可重入鎖”，意思是同一線(xiàn)程可以多次獲得鎖，n次獲得需要n次釋放才能最終釋放掉ReentrantLock。

ReentrantLock的基本原理：

• 與synchronized不同，ReentrantLock不存在“鎖對(duì)象”的概念，或者可以理解為鎖對(duì)象就是ReentrantLock對(duì)象本身
• ReentrantLock設(shè)置一個(gè)狀態(tài)值，通過(guò)對(duì)狀態(tài)值的原子操作實(shí)現(xiàn)對(duì)鎖資源的獲取和釋放，任何一個(gè)線(xiàn)程能獲取鎖資源的充分必要條件是ReentrantLock處于空閑狀態(tài)，同理，任何一個(gè)線(xiàn)程獲得鎖資源后ReentrantLock即處于占用狀態(tài)
• ReentrantLock的兩個(gè)最基本的操作：lock和unlock，lock獲取鎖資源，unlock釋放鎖資源
• ReentrantLock維護(hù)一個(gè)CLH隊(duì)列，CLH隊(duì)列是一個(gè)先進(jìn)先出的雙向隊(duì)列
• ReentrantLock處于空閑狀態(tài)則lock調(diào)用立即返回，調(diào)用線(xiàn)程獲得鎖資源。否則，請(qǐng)求線(xiàn)程進(jìn)入CLH隊(duì)列排隊(duì)，等待被其他線(xiàn)程喚醒
• 獲得鎖資源的線(xiàn)程在業(yè)務(wù)執(zhí)行完成后調(diào)用unlock釋放鎖資源，之后以FIFO的原則喚醒最先進(jìn)入隊(duì)列排隊(duì)的線(xiàn)程
• 被喚醒的線(xiàn)程繼續(xù)執(zhí)行l(wèi)ock操作，節(jié)點(diǎn)從CLH隊(duì)列出隊(duì)，返回---意味著請(qǐng)求鎖資源的線(xiàn)程在等待后獲取鎖資源成功，繼續(xù)第6步的邏輯

以上是沒(méi)有Condition對(duì)象參與的ReentrantLock的獲取、釋放鎖資源的邏輯，相對(duì)比較簡(jiǎn)單。

有Condition參與的時(shí)候，情況會(huì)稍微復(fù)雜一點(diǎn)：

• ReentrantLock對(duì)象可以通過(guò)new Condition()操作持有Condition對(duì)象，一個(gè)ReentrantLock可以持有多個(gè)Condition對(duì)象
• Condition維護(hù)一個(gè)Condition隊(duì)列
• Condition的常用的操作包括await、signal等，執(zhí)行操作的時(shí)候假設(shè)當(dāng)前線(xiàn)程已經(jīng)獲取到了ReentrantLock鎖資源
• await操作會(huì)釋放掉當(dāng)前線(xiàn)程已經(jīng)獲取到的ReentrantLock鎖資源、掛起當(dāng)前線(xiàn)程，并且將當(dāng)前線(xiàn)程加入Condition的隊(duì)列排隊(duì)等待被其他線(xiàn)程喚醒。比如DelayedWorkQueue的take方法中，如果當(dāng)前DelayedWorkQueue隊(duì)列空的話(huà)，則take線(xiàn)程加入到命名為available的Condition中排隊(duì)等候
• 當(dāng)相關(guān)操作可能導(dǎo)致Condition的條件滿(mǎn)足的時(shí)候，調(diào)用Condition的signal方法喚醒在Condition隊(duì)列中等待的線(xiàn)程。比如上例中DelayedWorkQueue的add方法完成之后，調(diào)用available的signal方法，喚醒在available隊(duì)列中排隊(duì)等候的線(xiàn)程。
• 線(xiàn)程被喚醒之后從Condition隊(duì)列出隊(duì)，進(jìn)ReentrantLock的CLH隊(duì)列排隊(duì)等待重新獲取鎖資源

Condition舉例：take方法中隊(duì)列空的話(huà)，掛起等待

Condition舉例：offer方法中寫(xiě)入隊(duì)列后，喚醒等待的線(xiàn)程

對(duì)ReentrantLock應(yīng)該有一個(gè)基本的認(rèn)識(shí)了，如果只是想要對(duì)ReentrantLock做一個(gè)基本了解、能夠看懂ReentrantLock的應(yīng)用、而不是要從源碼角度做深入研究的話(huà)，個(gè)人認(rèn)為掌握上面這些基本原理應(yīng)該就夠了，保證能看懂阻塞隊(duì)列、線(xiàn)程池中的有關(guān)ReentrantLock的源碼邏輯了。

但是如果想要徹底搞清楚ReentrantLock到底是怎么實(shí)現(xiàn)以上邏輯的，就需要從源碼角度繼續(xù)做深入研究了。

ReentrantLock數(shù)據(jù)結(jié)構(gòu)：AQS及CLH隊(duì)列

多個(gè)線(xiàn)程同時(shí)競(jìng)爭(zhēng)ReentrantLock鎖資源的時(shí)候，只能有一個(gè)競(jìng)爭(zhēng)獲勝的線(xiàn)程獲得鎖資源、其他線(xiàn)程就只能排隊(duì)等待。這個(gè)用來(lái)排隊(duì)的隊(duì)列就是CLH隊(duì)列，AQS（AbstractQueuedSynchronizer）是實(shí)現(xiàn)CLH隊(duì)列的虛擬類(lèi)。

ReentrantLock有一個(gè)非常重要的屬性Sync，Sync是AQS的虛擬擴(kuò)展類(lèi)，Sync有兩個(gè)實(shí)現(xiàn)類(lèi)：NonfairSync和FairSync，類(lèi)結(jié)構(gòu)如下：

NonfairSync和FairSync都是AQS的最終實(shí)現(xiàn)，AQS虛擬類(lèi)是一個(gè)標(biāo)準(zhǔn)模板，定義了Lock鎖的基本數(shù)據(jù)結(jié)構(gòu)（阻塞隊(duì)列）、并實(shí)現(xiàn)了Lock的絕大部分功能。

進(jìn)入隊(duì)列排隊(duì)的線(xiàn)程被封裝為Node，Node是AQS定義的內(nèi)部類(lèi)，是我們學(xué)習(xí)AQS首先要掌握的內(nèi)容。

Node的重要屬性：

waitStatus：等待狀態(tài)，Node就是用來(lái)排隊(duì)的，waitStatus就代表當(dāng)前節(jié)點(diǎn)的等待狀態(tài)，有以下幾種等待狀態(tài)：

• CANCELLED = 1：表示當(dāng)前等待線(xiàn)程已經(jīng)被calcel掉了
• SIGNAL = -1：表示該節(jié)點(diǎn)是在CLH隊(duì)列中排隊(duì)等待出隊(duì)
• CONDITION = -2：表示當(dāng)前節(jié)點(diǎn)是在Condition隊(duì)列中等待出隊(duì)
• PROPAGATE = -3：共享鎖會(huì)用到，暫不分析

prev：上一節(jié)點(diǎn)
next：雙向隊(duì)列嘛，當(dāng)然也要有下一節(jié)點(diǎn)
Thread thread：節(jié)點(diǎn)的主角，排隊(duì)線(xiàn)程
nextWaiter：Condition隊(duì)列專(zhuān)用，用來(lái)指向Condition隊(duì)列的下一節(jié)點(diǎn)

AQS的同步隊(duì)列（CLH）以及Condition隊(duì)列的節(jié)點(diǎn)都是用這個(gè)Node，所以Node類(lèi)做了一部分針對(duì)兩者的兼容設(shè)計(jì)，比如nextWaiter是針對(duì)Condtion隊(duì)列的下一節(jié)點(diǎn)，next是針對(duì)CLH的下一節(jié)點(diǎn)。

AQS重要屬性

state：鎖狀態(tài)，通過(guò)對(duì)state的原子操作實(shí)現(xiàn)對(duì)鎖資源的控制：某一線(xiàn)程通過(guò)原子操作成功將state從空閑修改為占用則意味著當(dāng)前線(xiàn)程成功獲得了鎖資源。無(wú)法獲得鎖資源的線(xiàn)程則封裝為Node節(jié)點(diǎn)進(jìn)入隊(duì)列排隊(duì)等待。

head：首節(jié)點(diǎn)，頭節(jié)點(diǎn)
tail：尾結(jié)點(diǎn)

通過(guò)head節(jié)點(diǎn)、tail節(jié)點(diǎn)，以及每個(gè)節(jié)點(diǎn)的prev、next，AQS實(shí)現(xiàn)了一個(gè)雙向隊(duì)列。

公平鎖和非公平鎖

所謂的公平鎖和非公平鎖就是由Sync屬性決定的：當(dāng)Sync創(chuàng)建為NonfairSync的時(shí)候，就是非公平的ReentrantLock，否則就是公平的ReentrantLock。

使用無(wú)參構(gòu)造器創(chuàng)建的是非公平ReentrantLock，有參構(gòu)造器ReentrantLock(boolean fair)可以通過(guò)參數(shù)指定創(chuàng)建公平還是非公平鎖。

公平鎖在線(xiàn)程請(qǐng)求鎖資源的時(shí)候會(huì)檢查CLH隊(duì)列，隊(duì)列不空的話(huà)首先進(jìn)入隊(duì)列排隊(duì)，先提出申請(qǐng)的線(xiàn)程會(huì)優(yōu)先獲得鎖資源，因此是“公平”的鎖。

非公平鎖在線(xiàn)程請(qǐng)求鎖資源的時(shí)候不會(huì)檢查CLH隊(duì)列，直接嘗試獲得鎖資源，獲取失敗后才進(jìn)入隊(duì)列排隊(duì)。所以請(qǐng)求線(xiàn)程會(huì)得到比隊(duì)列中的線(xiàn)程更高的優(yōu)先級(jí)，對(duì)于隊(duì)列中排隊(duì)的線(xiàn)程來(lái)說(shuō)是不公平的，所以叫非公平鎖。

Condition

Condition提供await和signal（以及他們的變種）方法為ReentrantLock鎖資源提供更多選擇：當(dāng)前線(xiàn)程獲取到ReentrantLock鎖資源后，可以通過(guò)Condition對(duì)象的await方法掛起當(dāng)前線(xiàn)程直到其他線(xiàn)程通過(guò)該對(duì)象的signal方法喚醒。

一個(gè)ReentrantLock可以創(chuàng)建多個(gè)Condition對(duì)象，每一個(gè)Condition對(duì)象都是獨(dú)立的、互不影響。ReentrantLock好比是一條街上的黑社會(huì)老大，黑社會(huì)老大首先要把這條街拿下，也就是獲得ReentrantLock鎖資源。之后的每一個(gè)Condition好比是這條街道上的飯店A、小賣(mài)店B、公共衛(wèi)生間C，分別對(duì)應(yīng)ConditionObjectA、ConditionObjectB、ConditionObjectC，得到黑社會(huì)老大允許后你就可以隨意進(jìn)出飯店吃飯了，但是如果飯店客滿(mǎn)了，就必須通過(guò)調(diào)用ConditionObjectA的await方法進(jìn)入到ConditionObjectA的隊(duì)列中排隊(duì)等待（當(dāng)前線(xiàn)程封裝為AQS中的Node進(jìn)入隊(duì)列（假設(shè)叫NodeA），當(dāng)前線(xiàn)程A掛起），此時(shí)黑社會(huì)老大需要交出對(duì)整條街的鎖權(quán)限（貌似不太合理...），此后飯店A有人吃完了要離店，就會(huì)通過(guò)ConditionObjectA的signal方法通知正在隊(duì)列中排隊(duì)等候的NodeA，于是NodeA從ConditionObjectA隊(duì)列中出來(lái)，到ReentrantLock的CLH隊(duì)列中排隊(duì)、等待重新獲取ReentrantLock鎖資源之后再喚醒線(xiàn)程A。這個(gè)過(guò)程中如果有其他人（其他線(xiàn)程）要進(jìn)入小賣(mài)店B，需要進(jìn)行操作的就是小賣(mài)店對(duì)應(yīng)的ConditionObjectB，和飯店對(duì)應(yīng)的ConditionObjectA沒(méi)有任何關(guān)系。

小結(jié)

發(fā)現(xiàn)開(kāi)篇定下的內(nèi)容太多了，篇幅所限，后面的“沒(méi)有Condition參與的lock、unlock”以及“有Condition參與的lock、unlock”，基本就是上述邏輯的源碼分析，放在下一篇。

以上就是Java并發(fā)編程Lock Condition和ReentrantLock基本原理的詳細(xì)內(nèi)容，更多關(guān)于Java并發(fā)編程的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論