在前面一節(jié)中，我們分析了ReentrantLock.lock()方法，接下來我們接著分析ReentrantLock.unlock()方法。

1.ReentrantLock.unlock()分析

(1)首先嘗試釋放鎖，如果要求釋放數(shù)等于鎖狀態(tài)數(shù)，那么將鎖狀態(tài)位清0，清除鎖所有者，返回true；否則返回false;
(2)如果(1)返回的是true，說明鎖完全釋放。接下來將檢查等待隊列，并選擇一個waitStatus處于等待狀態(tài)的節(jié)點下的線程unpark(恢復)，選擇的依據(jù)是從尾節(jié)點開始，選取最靠近頭節(jié)點的等待節(jié)點,同時清理隊列中線程被取消的節(jié)點；
(3)如果(1)返回false，說明鎖只是部分釋放，當前線程仍舊持有該鎖；

java.util.concurrent.locks.ReentrantLock
2

public void unlock() {
3

sync.release(1);
4

}
5

java.util.concurrent.locks.AbstractQueuedSynchronizer
7

public final boolean release(int arg) {
8

if (tryRelease(arg)) {
9

Node h = head;
10

if (h != null && h.waitStatus != 0)
11

unparkSuccessor(h);
12

return true;
13

}
14

return false;
15

}
16

protected final boolean tryRelease(int releases) {
19

int c = getState() - releases; //重入鎖加鎖的次數(shù)-釋放數(shù)量
20

if (Thread.currentThread() != getExclusiveOwnerThread()) //判斷獨占鎖是否為當前線程所有
21

throw new IllegalMonitorStateException();
22

boolean free = false;
23

if (c == 0) { //加鎖次數(shù)=釋放數(shù)量
24

free = true;
25

setExclusiveOwnerThread(null); //清除鎖擁有者標識
26

}
27

setState(c); //設置加鎖狀態(tài)
28

return free;
29

}
30

/**
33

* Wakes up node's successor, if one exists.
34

*
35

* @param node the node
36

*/
37

private void unparkSuccessor(Node node) {
38

/*
39

* Try to clear status in anticipation of signalling. It is
40

* OK if this fails or if status is changed by waiting thread.
41

*/
42

compareAndSetWaitStatus(node, Node.SIGNAL, 0); //清除頭節(jié)點signal狀態(tài)
43

/*
45

* Thread to unpark is held in successor, which is normally
46

* just the next node. But if cancelled or apparently null,
47

* traverse backwards from tail to find the actual
48

* non-cancelled successor.
49

*/
50

Node s = node.next;
51

if (s == null || s.waitStatus > 0) { //等待隊列喚醒的競爭滿足FIFO，本段代碼主要是尋找最靠近頭節(jié)點的，且waitStatus為signal、condition的鏈表節(jié)點
52

s = null;
53

for (Node t = tail; t != null && t != node; t = t.prev)
54

if (t.waitStatus <= 0)
55

s = t;
56

}
57

if (s != null)
58

LockSupport.unpark(s.thread);
59

}

posted on 2011-08-19 15:24 zhangxl 閱讀(1861) 評論(0) 編輯收藏所屬分類: java 并發(fā)

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: ReentrantLock源碼之二unlock方法解析(鎖的釋放) ReentrantLock源碼之一lock方法解析(鎖的獲取) java 等待通知/條件變量的區(qū)別淺析

2025年7月

日

一

二

三

四

五

六

常用鏈接

留言簿(1)

隨筆分類(17)

隨筆檔案(28)

文章分類(30)

文章檔案(30)

相冊

my picture

收藏夾(2)

我的關注(2)

hibernate

java基礎

serialization

mysql

mysql debin

xml

IBM XSL
w3c標準的xpath說明
web service ibm
XPath 示例
XPath 簡單語法
XQuery 1.0 and XPath 2.0 Full-Text Use Cases

常用鏈接

留言簿(1)

隨筆分類(17)

隨筆檔案(28)

文章分類(30)

文章檔案(30)

相冊

收藏夾(2)

hibernate

java基礎

mysql

xml

關注

壓力測試

算法

最新隨筆

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜