摘要：如果一個(gè)調(diào)用已經(jīng)出現(xiàn)了，這里只計(jì)數(shù)。為表示永不過(guò)期當(dāng)為時(shí)，是相對(duì)于新紀(jì)元之后的毫秒。否則這個(gè)值就是超時(shí)前的納秒數(shù)。要解除阻塞的線(xiàn)程

調(diào)用sync.acquireSharedInterruptibly

public void await() throws InterruptedException {
    sync.acquireSharedInterruptibly(1);
}

sync.acquireSharedInterruptibly
調(diào)用tryAcquireShared方法返回<0執(zhí)行doAcquireSharedInterruptibly

public final void acquireSharedInterruptibly(int arg) throws InterruptedException {
    if (Thread.interrupted())
        throw new InterruptedException();
    if (tryAcquireShared(arg) < 0)
        doAcquireSharedInterruptibly(arg);
}

tryAcquireShared
嘗試獲取共享鎖,獲取成功返回1，否則-1

protected int tryAcquireShared(int acquires) {
    return (getState() == 0) ? 1 : -1;
}

doAcquireSharedInterruptibly

private void doAcquireSharedInterruptibly(int arg)throws InterruptedException {
    final Node node = addWaiter(Node.SHARED);
    boolean failed = true;
    try {
        for (;;) {
            final Node p = node.predecessor();
            //如果前一個(gè)node為隊(duì)頭，則通過(guò)tryAcquireShared嘗試獲取共享鎖
            if (p == head) {
                int r = tryAcquireShared(arg);
                if (r >= 0) {
                //獲取到鎖執(zhí)行
                    setHeadAndPropagate(node, r);
                    p.next = null; // help GC
                    failed = false;
                    return;
                }
            }
            if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt())
                throw new InterruptedException();
        }
    } finally {
        //產(chǎn)生異常執(zhí)行
        if (failed)
            cancelAcquire(node);
    }
}

addWaiter
調(diào)用addWaiter方法把隊(duì)尾設(shè)置為當(dāng)前node；如果隊(duì)尾為空或者設(shè)置失敗則調(diào)用enq方法

private Node addWaiter(Node mode) {
    Node node = new Node(Thread.currentThread(), mode);
    // Try the fast path of enq; backup to full enq on failure
    Node pred = tail;
    if (pred != null) {
        node.prev = pred;
        if (compareAndSetTail(pred, node)) {
            pred.next = node;
            return node;
        }
    }
    enq(node);
    return node;
}

enq
調(diào)用enq方法隊(duì)尾為空則創(chuàng)建空的隊(duì)尾和隊(duì)頭，否則重新設(shè)置隊(duì)尾為當(dāng)前node，設(shè)置成功返回。enq和addWaiter方法不同在于enq循環(huán)執(zhí)行一定會(huì)執(zhí)行成功，不存在失敗情況

private Node enq(final Node node) {
    for (;;) {
        Node t = tail;
        if (t == null) { // Must initialize
            if (compareAndSetHead(new Node()))
                tail = head;
        } else {
            node.prev = t;
            if (compareAndSetTail(t, node)) {
                t.next = node;
                return t;
            }
        }
    }
}

predecessor
調(diào)用predecessor方法獲取前一個(gè)node

final Node predecessor() throws NullPointerException {
    Node p = prev;
    if (p == null)
        throw new NullPointerException();
    else
        return p;
}

static final int CANCELLED = 1; //取消 
static final int SIGNAL = -1; //下個(gè)節(jié)點(diǎn)需要被喚醒 
static final int CONDITION = -2; //線(xiàn)程在等待條件觸發(fā)
static final int PROPAGATE = -3; //（共享鎖）狀態(tài)需要向后傳播

shouldParkAfterFailedAcquire
獲取當(dāng)前node的前一個(gè)note的線(xiàn)程等待狀態(tài)，如果為SIGNAL,那么返回true,大于0通過(guò)循環(huán)將當(dāng)前節(jié)點(diǎn)之前所有取消狀態(tài)的節(jié)點(diǎn)移出隊(duì)列;其他狀時(shí),利用compareAndSetWaitStatus使前節(jié)點(diǎn)的狀態(tài)為-1;如果是第一次await時(shí)ws狀態(tài)是0，多次await時(shí)ws狀態(tài)是0，最后肯定返回true

private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {
    int ws = pred.waitStatus;
    if (ws == Node.SIGNAL)
        return true;
    if (ws > 0) {
        do {
            node.prev = pred = pred.prev;
        } while (pred.waitStatus > 0);
        pred.next = node;
    } else {
        compareAndSetWaitStatus(pred, ws, Node.SIGNAL);
    }
    return false;
}

parkAndCheckInterrupt
調(diào)用park并返回線(xiàn)程是否已經(jīng)中斷

private final boolean parkAndCheckInterrupt() {
    LockSupport.park(this);
    return Thread.interrupted();
}

park
調(diào)用UNSAFE.park阻塞當(dāng)前線(xiàn)程

public static void park(Object blocker) {
    Thread t = Thread.currentThread();
    setBlocker(t, blocker);
    UNSAFE.park(false, 0L);
    setBlocker(t, null);
}

setBlocker
在當(dāng)前線(xiàn)程t的parkBlockerOffset位置設(shè)置blocker的引用

private static void setBlocker(Thread t, Object arg) {
    // Even though volatile, hotspot doesn"t need a write barrier here.
    UNSAFE.putObject(t, parkBlockerOffset, arg);
}

UNSAFE.park

/**
 * 阻塞一個(gè)線(xiàn)程直到unpark出現(xiàn)、線(xiàn)程
 * 被中斷或者timeout時(shí)間到期。如果一個(gè)unpark調(diào)用已經(jīng)出現(xiàn)了，
 * 這里只計(jì)數(shù)。timeout為0表示永不過(guò)期.當(dāng)isAbsolute為true時(shí)，
 * timeout是相對(duì)于新紀(jì)元之后的毫秒。否則這個(gè)值就是超時(shí)前的納秒數(shù)。這個(gè)方法執(zhí)行時(shí)
 * 也可能不合理地返回(沒(méi)有具體原因)
 * 
 * @param isAbsolute true if the timeout is specified in milliseconds from
 *                   the epoch.
 *                   如果為true timeout的值是一個(gè)相對(duì)于新紀(jì)元之后的毫秒數(shù)
 * @param time either the number of nanoseconds to wait, or a time in
 *             milliseconds from the epoch to wait for.
 *             可以是一個(gè)要等待的納秒數(shù)，或者是一個(gè)相對(duì)于新紀(jì)元之后的毫秒數(shù)直到
 *             到達(dá)這個(gè)時(shí)間點(diǎn)
 */
UNSAFE.park(false, 0L);

調(diào)用sync.releaseShared

public void countDown() {
    sync.releaseShared(1);
}

releaseShared
執(zhí)行tryReleaseShared成功后執(zhí)行doReleaseShared

public final boolean releaseShared(int arg) {
    if (tryReleaseShared(arg)) {
        doReleaseShared();
        return true;
    }
    return false;
}

tryReleaseShared
更新state值為state-1，如果state新值為0返回true，否則false

protected boolean tryReleaseShared(int releases) {
    // Decrement count; signal when transition to zero
    for (;;) {
        int c = getState();
        if (c == 0)
            return false;
        int nextc = c-1;
        if (compareAndSetState(c, nextc))
            return nextc == 0;
    }
}

doReleaseShared
只要等待隊(duì)列有數(shù)據(jù)，獲取隊(duì)頭等待狀態(tài)，隊(duì)頭狀態(tài)=-1其他node為等待時(shí)，則把隊(duì)頭等待狀態(tài)置為初始，且調(diào)用unparkSuccessor方法；隊(duì)頭狀態(tài)=0時(shí)，把隊(duì)頭狀態(tài)置為-3傳播到下一node

private void doReleaseShared() {
    /*
     * Ensure that a release propagates, even if there are other
     * in-progress acquires/releases.  This proceeds in the usual
     * way of trying to unparkSuccessor of head if it needs
     * signal. But if it does not, status is set to PROPAGATE to
     * ensure that upon release, propagation continues.
     * Additionally, we must loop in case a new node is added
     * while we are doing this. Also, unlike other uses of
     * unparkSuccessor, we need to know if CAS to reset status
     * fails, if so rechecking.
     */
    for (;;) {
        Node h = head;
        if (h != null && h != tail) {
            int ws = h.waitStatus;
            if (ws == Node.SIGNAL) {
                if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
                    continue;            // loop to recheck cases
                unparkSuccessor(h);
            }
            else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
                continue;                // loop on failed CAS
        }
        if (h == head)                   // loop if head changed
            break;
    }
}

unparkSuccessor
上面調(diào)用unparkSuccessor時(shí)，node的狀態(tài)已經(jīng)更改為0，且node.next存在，執(zhí)行unpark方法

private void unparkSuccessor(Node node) {
    /*
     * If status is negative (i.e., possibly needing signal) try
     * to clear in anticipation of signalling.  It is OK if this
     * fails or if status is changed by waiting thread.
     */
    int ws = node.waitStatus;
    if (ws < 0)
        compareAndSetWaitStatus(node, ws, 0);

    /*
     * Thread to unpark is held in successor, which is normally
     * just the next node.  But if cancelled or apparently null,
     * traverse backwards from tail to find the actual
     * non-cancelled successor.
     */
    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);
}

unpark
unpark執(zhí)行完之后是如何更改head的?

public static void unpark(Thread thread) {
    if (thread != null)
        UNSAFE.unpark(thread);
}

UNSAFE.unpark

/**
 * Releases the block on a thread created by 
 * park.  This method can also be used
 * to terminate a blockage caused by a prior call to park.
 * This operation is unsafe, as the thread must be guaranteed to be
 * live.  This is true of Java, but not native code.
 * 釋放被park創(chuàng)建的在一個(gè)線(xiàn)程上的阻塞.這個(gè)
 * 方法也可以被使用來(lái)終止一個(gè)先前調(diào)用park導(dǎo)致的阻塞.
 * 這個(gè)操作操作時(shí)不安全的,因此線(xiàn)程必須保證是活的.這是java代碼不是native代碼。
 * @param thread the thread to unblock.
 *           要解除阻塞的線(xiàn)程
 */
UNSAFE.unpark(thread);