ReentrantLock是如何基于AQS實(shí)現(xiàn)的

1、reentrantlock是如何基于aqs實(shí)現(xiàn)的reentrantlock是一個可重入的互斥鎖，基于aqs實(shí)現(xiàn)，它具有與用法 synchronized 辦法和語句相同的一些基本行為和語義，但功能更強(qiáng)大。lock和unlockreentrantlock 中舉行同步操作都是從lock辦法開頭。lock獵取鎖，舉行一系列的業(yè)務(wù)操作，結(jié)束后用法unlock釋放鎖。private final reentrantlock lock = new reentrantlock（）;public void sync（）lock.lock（）;try / method body finally lock.unloc

2、k（）lockreentrantlock 中l(wèi)ock的實(shí)現(xiàn)是通過調(diào)用aqs的 abstractqueuedsynchronizeracquire 辦法實(shí)現(xiàn)。public final void acquire（int arg） /嘗試獵取鎖if （！tryacquire（arg） &&acquirequeued（addwaiter（node.exclusive）， arg）selfinterrupt（）;按照之前介紹的模板辦法模式，對于鎖的獵取tryacquire是在reentrantlock中實(shí)現(xiàn)的。而非公正鎖中的實(shí)際實(shí)現(xiàn)辦法為nonfairtryacquire。reentra

3、ntlocknonfairtryacquireprotected final boolean tryacquire（int acquires） return nonfairtryacquire（acquires）;final boolean nonfairtryacquire（int acquires） final thread current = thread.currentthread（）;int c = getstate（）;if （c = 0） if （compareandsetstate（0, acquires） setexclusiveownerthread（current）;re

4、turn true;else if （current = getexclusiveownerthread（） int nextc = c + acquires;if （nextc 0） do node.prev = pred = pred.prev; while （pred.waitstatus 0）;pred.next = node; else compareandsetwaitstatus（pred, ws, node.signal）;return false;推斷一個節(jié)點(diǎn)是否需要被堵塞是通過該節(jié)點(diǎn)的前繼節(jié)點(diǎn)的狀態(tài)推斷的。假如前繼節(jié)點(diǎn)狀態(tài)為 singal ，則表示前繼節(jié)點(diǎn)還在等待，當(dāng)前節(jié)點(diǎn)

5、需要繼續(xù)被堵塞。返回true。假如前繼節(jié)點(diǎn)大于0，則表示前繼節(jié)點(diǎn)為取消狀態(tài)。取消狀態(tài)的節(jié)點(diǎn)不參加鎖的競爭，挺直跳過。返回false。假如前繼節(jié)點(diǎn)時其他狀態(tài)（0,propagate），不舉行堵塞，表示當(dāng)前節(jié)點(diǎn)需要重試嘗試獵取鎖。返回false。shouldparkafterfailedacquire辦法假如返回true，表示需要將當(dāng)前節(jié)點(diǎn)堵塞，堵塞辦法為parkandcheckinterrupt。abstractqueuedsynchronizerparkandcheckinterruptprivate final boolean parkandcheckinterrupt（） locksupp

6、ort.park（this）;return terrupted（）;堵塞是通過locksupport舉行堵塞，被堵塞的節(jié)點(diǎn)不參加鎖的競爭（不在舉行循環(huán)獵取鎖），只能被unpark后才繼續(xù)競爭鎖。而被堵塞的節(jié)點(diǎn)要被釋放則依靠于unlock辦法。unlockreentrantlock 中unlock的實(shí)現(xiàn)是通過調(diào)用aqs的 abstractqueuedsynchronizerrelease 辦法實(shí)現(xiàn)。public final boolean release（int arg） if （tryrelease（arg） node h = head;if （h != null &

7、& h.waitstatus != 0）unparksuccessor（h）;return true;return false;release調(diào)用tryrelease辦法，tryrelease是在 reentrantlock 中實(shí)現(xiàn)。reentrantlocktryreleaseprotected final boolean tryrelease（int releases） int c = getstate（） - releases;if （thread.currentthread（） != getexclusiveownerthread（）throw new illegalmonit

8、orstateexception（）;boolean free = false;if （c = 0） free = true;setexclusiveownerthread（null）;setstate（c）;return free;tryrelease辦法規(guī)律很容易，首先減去releases（普通為1）表示釋放一個鎖，假如釋放后state=0表示釋放鎖勝利，后續(xù)等待的節(jié)點(diǎn)可以獵取該鎖了。假如state!=0則表示該鎖為重入鎖，需要多次釋放。當(dāng)釋放鎖勝利后（state=0），會對頭結(jié)點(diǎn)的后繼節(jié)點(diǎn)舉行unpark。abstractqueuedsynchronizerunparksuccessor

9、private void unparksuccessor（node node） int ws = node.waitstatus;if （ws 0） s = null;for （node t = tail; t != null && t != node; t = t.prev）if （t.waitstatus 0的節(jié)點(diǎn)）。公正鎖和非公正鎖reentrantlock 的構(gòu)造辦法接受一個可選的公正參數(shù)。當(dāng)設(shè)置為 true 時，在多個線程的競爭時，傾向于將鎖分配給等待時光最長的線程。public reentrantlock（boolean fair） sync = fair ? ne

10、w fairsync（） : new nonfairsync（）;在多個鎖競爭統(tǒng)一資源的環(huán)境下，aqs維護(hù)了一個等待隊(duì)列，未能獵取到鎖的線程都會被掛到該隊(duì)列中。假如用法公正鎖則會從隊(duì)列的頭結(jié)點(diǎn)開頭獵取該資源。而按照代碼在公正鎖和非公正鎖的實(shí)現(xiàn)的差別僅僅在于公正鎖多了一個檢測的辦法。公正鎖protected final boolean tryacquire（int acquires） /if （c = 0） if （！hasqueuedpredecessors（） /!hasqueuedpredecessors（）便是比非公正鎖多出來的操作&& compareandsetstate（0, acquires） setexclusiveownerthread（current）;return true;/return false;hasqueuedpredecessors（）public final boolean hasqueuedpredecessors（） node t = tail; / read fields in reverse initialization ordernode h