ReentrantLock加鎖解鎖過程

本文轉載自查看原文 2019-11-23 12:35 360 多線程

公平鎖

調用lock方法加鎖

進入acquire方法獲取加鎖的許可

進入tryacquire

首先獲取當前線程和status狀態，status默認為0

假如現在t1線程進入，然后t2線程進入（t2進入時t1還沒有釋放鎖）

if c==0成立，然后判斷是否需要排隊，調用hasqueuedpredecessors方法

此時的頭和尾都是null，此方法返回false，所以上面if（！hasqueuedpredecessors（））成立，然后進行cas操作，將status改為1

然后設置持有鎖的是當前線程。最后返回true。即t1拿到鎖繼續執行自己的業務邏輯。。。。

1、如果t2執行lock方法的時候t1已經釋放鎖，也就不會存在競爭，一次執行。

2、如果t1還沒有釋放鎖，t2也會走上面的代碼。

走到tryacquire方法嘗試去獲取鎖的時候肯定失敗，因為t1還在占用。方法返回false。

然后會執行addwriter方法進入隊列排隊。

首先創建一個節點node，節點里包含屬性thread，pre，next，是一個雙向鏈表

由於tail=null，所以會走enq方法。

此處無限循環，t==null也成立，首先會先初始化一個新的Node，node里的信息目前為空。然后設置為頭部。（其實隊列里的頭部永遠都是一個空節點，空節點的意思是有node對象，只不過里面的thread屬性為空）

繼續循環，走else，里面的邏輯意思是將自己的節點設置為尾部，空節點設置為頭部，然后將空節點的next指向t2節點，t2的pre指向頭部的空節點。

最終的關系如下圖

繼續走acquirequeued方法

 1 private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {
 2         int ws = pred.waitStatus;//等待狀態，默認為0，Node.SIGNAL=-1
 3         if (ws == Node.SIGNAL)
 4             /*
 5              * This node has already set status asking a release
 6              * to signal it, so it can safely park.
 7              */
 8             return true;
 9         if (ws > 0) {
10             /*
11              * Predecessor was cancelled. Skip over predecessors and
12              * indicate retry.
13              */
14             do {
15                 node.prev = pred = pred.prev;
16             } while (pred.waitStatus > 0);
17             pred.next = node;
18         } else {
19             /*
20              * waitStatus must be 0 or PROPAGATE.  Indicate that we
21              * need a signal, but don't park yet.  Caller will need to
22              * retry to make sure it cannot acquire before parking.
23              */
24             compareAndSetWaitStatus(pred, ws, Node.SIGNAL);
25         }
26         return false;
27     }