Java多執行緒系列---“JUC鎖”06之 公平鎖(下)
轉自:http://www.cnblogs.com/skywang12345/p/3496609.html
釋放公平鎖(基於JDK1.7.0_40)
1. unlock()
unlock()在ReentrantLock.java中實現的,原始碼如下:
public void unlock() {
sync.release(1);
}
說明:
unlock()是解鎖函式,它是通過AQS的release()函式來實現的。
在這裡,“1”的含義和“獲取鎖的函式acquire(1)的含義”一樣,它是設定“釋放鎖的狀態”的引數。由於“公平鎖”是可重入的,所以對於同一個執行緒,每釋放鎖一次,鎖的狀態-1。
關於AQS, ReentrantLock 和 sync的關係如下:
public class ReentrantLock implements Lock, java.io.Serializable { private final Sync sync; abstract static class Sync extends AbstractQueuedSynchronizer { ... } ... }
從中,我們發現:sync是ReentrantLock.java中的成員物件,而Sync是AQS的子類。
2. release()
release()在AQS中實現的,原始碼如下:
public final boolean release(int arg) { if (tryRelease(arg)) { Node h = head; if (h != null && h.waitStatus != 0) unparkSuccessor(h); return true; } return false; }
說明:
release()會先呼叫tryRelease()來嘗試釋放當前執行緒鎖持有的鎖。成功的話,則喚醒後繼等待執行緒,並返回true。否則,直接返回false。
3. tryRelease()
tryRelease()在ReentrantLock.java的Sync類中實現,原始碼如下:
protected final boolean tryRelease(int releases) { // c是本次釋放鎖之後的狀態 int c = getState() - releases; // 如果“當前執行緒”不是“鎖的持有者”,則丟擲異常! if (Thread.currentThread() != getExclusiveOwnerThread()) throw new IllegalMonitorStateException(); boolean free = false; // 如果“鎖”已經被當前執行緒徹底釋放,則設定“鎖”的持有者為null,即鎖是可獲取狀態。 if (c == 0) { free = true; setExclusiveOwnerThread(null); } // 設定當前執行緒的鎖的狀態。 setState(c); return free; }
說明:
tryRelease()的作用是嘗試釋放鎖。
(01) 如果“當前執行緒”不是“鎖的持有者”,則丟擲異常。
(02) 如果“當前執行緒”在本次釋放鎖操作之後,對鎖的擁有狀態是0(即,當前執行緒徹底釋放該“鎖”),則設定“鎖”的持有者為null,即鎖是可獲取狀態。同時,更新當前執行緒的鎖的狀態為0。
getState(), setState()在前一章已經介紹過,這裡不再說明。
getExclusiveOwnerThread(), setExclusiveOwnerThread()在AQS的父類AbstractOwnableSynchronizer.java中定義,原始碼如下:
public abstract class AbstractOwnableSynchronizer implements java.io.Serializable { // “鎖”的持有執行緒 private transient Thread exclusiveOwnerThread; // 設定“鎖的持有執行緒”為t protected final void setExclusiveOwnerThread(Thread t) { exclusiveOwnerThread = t; } // 獲取“鎖的持有執行緒” protected final Thread getExclusiveOwnerThread() { return exclusiveOwnerThread; } ... }
4. unparkSuccessor()
在release()中“當前執行緒”釋放鎖成功的話,會喚醒當前執行緒的後繼執行緒。
根據CLH佇列的FIFO規則,“當前執行緒”(即已經獲取鎖的執行緒)肯定是head;如果CLH佇列非空的話,則喚醒鎖的下一個等待執行緒。
下面看看unparkSuccessor()的原始碼,它在AQS中實現。
private void unparkSuccessor(Node node) { // 獲取當前執行緒的狀態 int ws = node.waitStatus; // 如果狀態<0,則設定狀態=0 if (ws < 0) compareAndSetWaitStatus(node, ws, 0); //獲取當前節點的“有效的後繼節點”,無效的話,則通過for迴圈進行獲取。 // 這裡的有效,是指“後繼節點對應的執行緒狀態<=0” Node s = node.next; if (s == null || s.waitStatus > 0) { s = null; for (Node t = tail; t != null && t != node; t = t.prev) if (t.waitStatus <= 0) s = t; } // 喚醒“後繼節點對應的執行緒” if (s != null) LockSupport.unpark(s.thread); }
說明:
unparkSuccessor()的作用是“喚醒當前執行緒的後繼執行緒”。後繼執行緒被喚醒之後,就可以獲取該鎖並恢復運行了。
關於node.waitStatus的說明,請參考“上一章關於Node類的介紹”。
總結
“釋放鎖”的過程相對“獲取鎖”的過程比較簡單。釋放鎖時,主要進行的操作,是更新當前執行緒對應的鎖的狀態。如果當前執行緒對鎖已經徹底釋放,則設定“鎖”的持有執行緒為null,設定當前執行緒的狀態為空,然後喚醒後繼執行緒。