1. 程式人生 > >Java多執行緒系列---“JUC鎖”06之 公平鎖(下)

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,設定當前執行緒的狀態為空,然後喚醒後繼執行緒。