通過上一篇的分析，我們知道了獨占模式獲取鎖有三種方式，分別是不響應線程中斷獲取，響應線程中斷獲取，設置超時時間獲取。在共享模式下獲取鎖的方式也是這三種，而且基本上都是大同小異，我們搞清楚了一種就能很快的理解其他的方式。雖然說AbstractQueuedSynchronizer源碼有一千多行，但是重複的也比較多，所以讀者不要剛開始的時候被嚇到，只要耐著性子去看慢慢的自然能夠漸漸領悟。就我個人經驗來說，閱讀AbstractQueuedSynchronizer源碼有幾個比較關鍵的地方需要弄明白，分別是獨占模式和共享模式的區別，結點的等待狀態，以及對條件隊列的理解。理解了這些要點那麼後續源碼的閱讀將會輕鬆很多。當然這些在我的《Java並發系列[1]----AbstractQueuedSynchronizer源碼分析之概要分析》這篇文章裡都有詳細的介紹，讀者可以先去查閱。本篇對於共享模式的分析也是分為三種獲取鎖的方式和一種釋放鎖的方式。
1. 不響應線程中斷的獲取
//以不可中斷模式獲取鎖(共享模式)public final void acquireShared(int arg) { //1.嘗試去獲取鎖if (tryAcquireShared(arg) < 0) { //2.如果獲取失敗就進入這個方法doAcquireShared(arg); }}//嘗試去獲取鎖(共享模式)//負數：表示獲取失敗//零值：表示當前結點獲取成功, 但是後繼結點不能再獲取了//正數：表示當前結點獲取成功, 並且後繼結點同樣可以獲取成功protected int tryAcquireShared(int arg) { throw new UnsupportedOperationException();}調用acquireShared方法是不響應線程中斷獲取鎖的方式。在該方法中，首先調用tryAcquireShared去嘗試獲取鎖，tryAcquireShared方法返回一個獲取鎖的狀態，這裡AQS規定了返回狀態若是負數代表當前結點獲取鎖失敗，若是0代表當前結點獲取鎖成功，但後繼結點不能再獲取了，若是正數則代表當前結點獲取鎖成功，並且這個鎖後續結點也同樣可以獲取成功。子類在實現tryAcquireShared方法獲取鎖的邏輯時，返回值需要遵守這個約定。如果調用tryAcquireShared的返回值小於0，就代表這次嘗試獲取鎖失敗了，接下來就調用doAcquireShared方法將當前線程添加進同步隊列。我們看到doAcquireShared方法。
//在同步隊列中獲取(共享模式)private void doAcquireShared(int arg) { //添加到同步隊列中final Node node = addWaiter(Node.SHARED); boolean failed = true; try { boolean interrupted = false; for (;;) { //獲取當前結點的前繼結點final Node p = node.predecessor(); //如果前繼結點為head結點就再次嘗試去獲取鎖if (p == head) { //再次嘗試去獲取鎖並返回獲取狀態//r < 0, 表示獲取失敗//r = 0, 表示當前結點獲取成功, 但是後繼結點不能再獲取了//r > 0, 表示當前結點獲取成功, 並且後繼結點同樣可以獲取成功int r = tryAcquireShared(arg); if (r >= 0) { //到這裡說明當前結點已經獲取鎖成功了, 此時它會將鎖的狀態信息傳播給後繼結點setHeadAndPropagate(node, r); p.next = null; //如果在線程阻塞期間收到中斷請求, 就在這一步響應該請求if (interrupted) { selfInterrupt(); } failed = false; return; } } //每次獲取鎖失敗後都會判斷是否可以將線程掛起, 如果可以的話就會在parkAndCheckInterrupt方法裡將線程掛起if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) { interrupted = true; } } } finally { if (failed) { cancelAcquire(node); } }}進入doAcquireShared方法首先是調用addWaiter方法將當前線程包裝成結點放到同步隊列尾部。這個添加結點的過程我們在講獨占模式時講過，這裡就不再講了。結點進入同步隊列後，如果它發現在它前面的結點就是head結點，因為head結點的線程已經獲取鎖進入房間裡面了，那麼下一個獲取鎖的結點就輪到自己了，所以當前結點先不會將自己掛起，而是再一次去嘗試獲取鎖，如果前面那人剛好釋放鎖離開了，那麼當前結點就能成功獲得鎖，如果前面那人還沒有釋放鎖，那麼就會調用shouldParkAfterFailedAcquire方法，在這個方法裡面會將head結點的狀態改為SIGNAL，只有保證前面結點的狀態為SIGNAL，當前結點才能放心的將自己掛起，所有線程都會在parkAndCheckInterrupt方法裡面被掛起。如果當前結點恰巧成功的獲取了鎖，那麼接下來就會調用setHeadAndPropagate方法將自己設置為head結點，並且喚醒後面同樣是共享模式的結點。下面我們看下setHeadAndPropagate方法具體的操作。
//設置head結點並傳播鎖的狀態(共享模式)private void setHeadAndPropagate(Node node, int propagate) { Node h = head; //將給定結點設置為head結點setHead(node); //如果propagate大於0表明鎖可以獲取了if (propagate > 0 || h == null || h.waitStatus < 0) { //獲取給定結點的後繼結點Node s = node.next; //如果給定結點的後繼結點為空, 或者它的狀態是共享狀態if (s == null || s.isShared()) { //喚醒後繼結點doReleaseShared(); } }}//釋放鎖的操作(共享模式)private void doReleaseShared() { for (;;) { //獲取同步隊列的head結點Node h = head; if (h != null && h != tail) { //獲取head結點的等待狀態int ws = h.waitStatus; //如果head結點的狀態為SIGNAL, 表明後面有人在排隊if (ws == Node.SIGNAL) { //先把head結點的等待狀態更新為0 if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) { continue; } //再去喚醒後繼結點unparkSuccessor(h); //如果head結點的狀態為0, 表明此時後面沒人在排隊, 就只是將head狀態修改為PROPAGATE }else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) { continue; } } //只有保證期間head結點沒被修改過才能跳出循環if (h == head) { break; } }}調用setHeadAndPropagate方法首先將自己設置成head結點，然後再根據傳入的tryAcquireShared方法的返回值來決定是否要去喚醒後繼結點。前面已經講到當返回值大於0就表明當前結點成功獲取了鎖，並且後面的結點也可以成功獲取鎖。這時當前結點就需要去喚醒後面同樣是共享模式的結點，注意，每次喚醒僅僅只是喚醒後一個結點，如果後一個結點不是共享模式的話，當前結點就直接進入房間而不會再去喚醒更後面的結點了。共享模式下喚醒後繼結點的操作是在doReleaseShared方法進行的，共享模式和獨占模式的喚醒操作基本也是相同的，都是去找到自己座位上的牌子(等待狀態)，如果牌子上為SIGNAL表明後面有人需要讓它幫忙喚醒，如果牌子上為0則表明隊列此時並沒有人在排隊。在獨占模式下是如果發現沒人在排隊就直接離開隊列了，而在共享模式下如果發現隊列後面沒人在排隊，當前結點在離開前仍然會留個小紙條(將等待狀態設置為PROPAGATE)告訴後來的人這個鎖的可獲取狀態。那麼後面來的人在嘗試獲取鎖的時候可以根據這個狀態來判斷是否直接獲取鎖。
2. 響應線程中斷的獲取
//以可中斷模式獲取鎖(共享模式)public final void acquireSharedInterruptibly(int arg) throws InterruptedException { //首先判斷線程是否中斷, 如果是則拋出異常if (Thread.interrupted()) { throw new InterruptedException(); } //1.嘗試去獲取鎖if (tryAcquireShared(arg) < 0) { //2. 如果獲取失敗則進人該方法doAcquireSharedInterruptibly(arg); }}//以可中斷模式獲取(共享模式)private void doAcquireSharedInterruptibly(int arg) throws InterruptedException { //將當前結點插入同步隊列尾部final Node node = addWaiter(Node.SHARED); boolean failed = true; try { for (;;) { //獲取當前結點的前繼結點final Node p = node.predecessor(); if (p == head) { int r = tryAcquireShared(arg); if (r >= 0) { setHeadAndPropagate(node, r); p.next = null; failed = false; return; } } if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) { //如果線程在阻塞過程中收到過中斷請求, 那麼就會立馬在這裡拋出異常throw new InterruptedException(); } } } finally { if (failed) { cancelAcquire(node); } }}響應線程中斷獲取鎖的方式和不響應線程中斷獲取鎖的方式在流程上基本是相同的，唯一的區別就是在哪裡響應線程的中斷請求。在不響應線程中斷獲取鎖時，線程從parkAndCheckInterrupt方法中被喚醒，喚醒後就立馬返回是否收到中斷請求，即使是收到了中斷請求也會繼續自旋直到獲取鎖後才響應中斷請求將自己給掛起。而響應線程中斷獲取鎖會才線程被喚醒後立馬響應中斷請求，如果在阻塞過程中收到了線程中斷就會立馬拋出InterruptedException異常。
3. 設置超時時間的獲取
//以限定超時時間獲取鎖(共享模式)public final boolean tryAcquireSharedNanos(int arg, long nanosTimeout) throws InterruptedException { if (Thread.interrupted()) { throw new InterruptedException(); } //1.調用tryAcquireShared嘗試去獲取鎖//2.如果獲取失敗就調用doAcquireSharedNanos return tryAcquireShared(arg) >= 0 || doAcquireSharedNanos(arg, nanosTimeout);}//以限定超時時間獲取鎖(共享模式)private boolean doAcquireSharedNanos(int arg, long nanosTimeout) throws InterruptedException { long lastTime = System.nanoTime(); final Node node = addWaiter(Node.SHARED); boolean failed = true; try { for (;;) { //獲取當前結點的前繼結點final Node p = node.predecessor(); if (p == head) { int r = tryAcquireShared(arg); if (r >= 0) { setHeadAndPropagate(node, r); p.next = null; failed = false; return true; } } //如果超時時間用完了就結束獲取, 並返回失敗信息if (nanosTimeout <= 0) { return false; } //1.檢查是否滿足將線程掛起要求(保證前繼結點狀態為SIGNAL) //2.檢查超時時間是否大於自旋時間if (shouldParkAfterFailedAcquire(p, node) && nanosTimeout > spinForTimeoutThreshold) { //若滿足上面兩個條件就將當前線程掛起一段時間LockSupport.parkNanos(this, nanosTimeout); } long now = System.nanoTime(); //超時時間每次減去獲取鎖的時間nanosTimeout -= now - lastTime; lastTime = now; //如果在阻塞時收到中斷請求就立馬拋出異常if (Thread.interrupted()) { throw new InterruptedException(); } } } finally { if (failed) { cancelAcquire(node); } }}如果看懂了上面兩種獲取方式，再來看設置超時時間的獲取方式就會很輕鬆，基本流程都是一樣的，主要是理解超時的機制是怎樣的。如果第一次獲取鎖失敗會調用doAcquireSharedNanos方法並傳入超時時間，進入方法後會根據情況再次去獲取鎖，如果再次獲取失敗就要考慮將線程掛起了。這時會判斷超時時間是否大於自旋時間，如果是的話就會將線程掛起一段時間，否則就繼續嘗試獲取，每次獲取鎖之後都會將超時時間減去獲取鎖的時間，一直這樣循環直到超時時間用盡，如果還沒有獲取到鎖的話就會結束獲取並返回獲取失敗標識。在整個期間線程是響應線程中斷的。
4. 共享模式下結點的出隊操作
//釋放鎖的操作(共享模式)public final boolean releaseShared(int arg) { //1.嘗試去釋放鎖if (tryReleaseShared(arg)) { //2.如果釋放成功就喚醒其他線程doReleaseShared(); return true; } return false;}//嘗試去釋放鎖(共享模式)protected boolean tryReleaseShared(int arg) { throw new UnsupportedOperationException();}//釋放鎖的操作(共享模式)private void doReleaseShared() { for (;;) { //獲取同步隊列的head結點Node h = head; if (h != null && h != tail) { //獲取head結點的等待狀態int ws = h.waitStatus; //如果head結點的狀態為SIGNAL, 表明後面有人在排隊if (ws == Node.SIGNAL) { //先把head結點的等待狀態更新為0 if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) { continue; } //再去喚醒後繼結點unparkSuccessor(h); //如果head結點的狀態為0, 表明此時後面沒人在排隊, 就只是將head狀態修改為PROPAGATE }else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) { continue; } } //只有保證期間head結點沒被修改過才能跳出循環if (h == head) { break; } }}線程在房間辦完事之後就會調用releaseShared方法釋放鎖，首先調用tryReleaseShared方法嘗試釋放鎖，該方法的判斷邏輯由子類實現。如果釋放成功就調用doReleaseShared方法去喚醒後繼結點。走出房間後它會找到原先的座位(head結點)，看看座位上是否有人留了小紙條(狀態為SIGNAL)，如果有就去喚醒後繼結點。如果沒有(狀態為0)就代表隊列沒人在排隊，那麼在離開之前它還要做最後一件事情，就是在自己座位上留下小紙條(狀態設置為PROPAGATE)，告訴後面的人鎖的獲取狀態，整個釋放鎖的過程和獨占模式唯一的區別就是在這最後一步操作。
注：以上全部分析基於JDK1.7，不同版本間會有差異，讀者需要注意。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。