從源碼角度帶你理解AQS

作者編寫(xiě)本文的方式旁舰，同時(shí)建議給您一種閱讀方式：

• 本文所有的代碼都是源碼母蛛，可在JDK8中找到械巡，講解的代碼無(wú)刪減都在本文；
• 本文的所有代碼塊及其中的屬性和方法官还，均采用從上到下順序講解芹橡；
• 本文代碼中文注釋才是重點(diǎn)，注釋順序也是按照從上到下閱讀望伦；
• 如有錯(cuò)誤和建議林说、提問(wèn)等，都可以與我聯(lián)系屯伞，互相學(xué)習(xí)哦腿箩！

1. 下面這三個(gè)字段是AQS這個(gè)類(lèi)自己的屬性定義，我們先理解一下劣摇，AQS想要定義一個(gè)什么樣的東西：

    /**
     * Head of the wait queue, lazily initialized.  Except for
     * initialization, it is modified only via method setHead.  Note:
     * If head exists, its waitStatus is guaranteed not to be
     * CANCELLED.
     */
    private transient volatile Node head;

    /**
     * Tail of the wait queue, lazily initialized.  Modified only via
     * method enq to add new wait node.
     */
    private transient volatile Node tail;

    /**
     * The synchronization state.
     */
    private volatile int state;

2. 首先珠移，先大致理解下這些屬性的意義：

• head：一個(gè)頭節(jié)點(diǎn)；
• tail：一個(gè)尾節(jié)點(diǎn)末融。咦钧惧？！這不是LinkedList的雙向鏈表結(jié)構(gòu)嘛勾习，其實(shí)人家真正的名字叫CLH同步隊(duì)列浓瞪；
• state：那這個(gè)就是鏈表全局的同步狀態(tài)的標(biāo)識(shí)嘍，先透露一下巧婶，這個(gè)值可以被用來(lái)做重入鎖的次數(shù)乾颁。

    private static final long stateOffset; // CAS字段偏移量涂乌，對(duì)應(yīng)的是 AQS中 state屬性操作
    // 全局唯一方法，外部類(lèi)只能通過(guò)這個(gè)方法來(lái)操縱 state屬性
    protected final boolean compareAndSetState(int expect, int update) {
        // See below for intrinsics setup to support this
        return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
    }

請(qǐng)看如下代碼步驟和詳細(xì)注釋?zhuān)粋€(gè)完整的加鎖入口 acquire()方法(形如：Lock.lock())：

    // 獲取鎖的開(kāi)始方法英岭，參數(shù)是一個(gè)狀態(tài)次數(shù)（你也可以叫重入次數(shù)）
    public final void acquire(int arg) {
        if (!tryAcquire(arg) && // 先嘗試獲取一次鎖湾盒，獲取不到就是False，獲取到那直接就獲取了鎖诅妹，就不用操作其他的了
            // 當(dāng)嘗試一次后獲取不到历涝，addWaiter方法就開(kāi)始加入CLH隊(duì)列了（Node.EXCLUSIVE為獨(dú)占鎖模式，可先忽略）
            acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) // acquireQueued方法在下個(gè)小節(jié)中講解
            selfInterrupt();
    }

    /**
     * 把一個(gè)新節(jié)點(diǎn)（搶占線(xiàn)程）插入鏈表尾部
     *（整體操作和雙向鏈表一直漾唉，唯一區(qū)別是鏈表節(jié)點(diǎn)中的前驅(qū)和后驅(qū)節(jié)點(diǎn)的修改需要加 CAS鎖）
     *
     * @param mode Node.EXCLUSIVE for exclusive, Node.SHARED for shared
     * @return the new node
     */
    private Node addWaiter(Node mode) {
        Node node = new Node(Thread.currentThread(), mode);
        // 先嘗試一次將新節(jié)點(diǎn)快速插入鏈表尾部，如果CAS失敗堰塌，則進(jìn)入接下來(lái)的enq方法赵刑。
        Node pred = tail;
        if (pred != null) {
            node.prev = pred;
            if (compareAndSetTail(pred, node)) {
                pred.next = node;
                return node;
            }
        }
        // 循環(huán)將新節(jié)點(diǎn)插入鏈表尾部，直到插入成功（其實(shí)與上面先嘗試一次大致相同场刑，唯一區(qū)別是加入了鏈表為空的處理般此，一切為了性能，哈哈哈）
        enq(node);
        return node;
    }

把上面代碼的注釋看完后牵现，我們先暫停一下铐懊，此時(shí)我們已經(jīng)或多或少的知道AQS的整體是一個(gè)同步隊(duì)列了，也大致可以想象一個(gè)CLH同步隊(duì)列的樣子了瞎疼，也知道怎樣將一個(gè)線(xiàn)程（節(jié)點(diǎn)）放入CLH隊(duì)列中了科乎，唯一的模糊在于同步狀態(tài) state有什么用，在哪里用贼急？

如果只局限于A(yíng)QS這個(gè)抽象類(lèi)來(lái)說(shuō)茅茂，其并沒(méi)有定義重入的概念，但是支持重入鎖的擴(kuò)展設(shè)計(jì)的太抓。
它只抽象于CLH的同步隊(duì)列的處理空闲，而重入的概念是交由像ReentrantLock、Sync等高層次類(lèi)去實(shí)現(xiàn)的走敌。
從抽象層面來(lái)說(shuō)碴倾，它提供了status字段來(lái)讓你自定義標(biāo)識(shí)，同時(shí)還提供了像tryAcquire掉丽、tryRelease的擴(kuò)展方法來(lái)讓你實(shí)現(xiàn)自己的效果跌榔。

【自行腦補(bǔ)插入一個(gè)CLH同步隊(duì)列圖，其實(shí)就是一個(gè)雙向鏈表】

3. 接下來(lái)我們先全局的看下机打，加入隊(duì)列的節(jié)點(diǎn)（線(xiàn)程）接下來(lái)要做哪些事情：

    /**
     * 這個(gè)方法的目的矫户，就是教你怎樣去排隊(duì)等待。
     * 例：
     * 就像排隊(duì)買(mǎi)早點(diǎn)一樣残邀，只有一個(gè)窗口皆辽。某一天柑蛇，你來(lái)的早不如來(lái)的巧，正好前面一小美女剛買(mǎi)完早點(diǎn)驱闷，你就直接問(wèn)老板要了個(gè)豆腐腦耻台，老板直接給你了（頭節(jié)點(diǎn)一次嘗試）。
     * 第二天空另，我的媽?zhuān)@么老長(zhǎng)的隊(duì)盆耽，你前面有人上班等不及了提前跑了（線(xiàn)程中止前移），那你就能往前走走扼菠。
     * 這個(gè)早點(diǎn)鋪呢摄杂，還有個(gè)奇葩又人人遵守的規(guī)矩，買(mǎi)完飯的人要向后面那個(gè)人打個(gè)招呼?!（線(xiàn)程等待釋放通知）
     *
     * @param node the node
     * @param arg the acquire argument
     * @return {@code true} if interrupted while waiting
     */
    final boolean acquireQueued(final Node node, int arg) {
        boolean failed = true; // 當(dāng)前節(jié)點(diǎn)失敗標(biāo)識(shí)
        try {
            boolean interrupted = false; // 當(dāng)前節(jié)點(diǎn)中斷標(biāo)識(shí)
            for (;;) {
                final Node p = node.predecessor(); // 獲取前驅(qū)節(jié)點(diǎn)
                // 如果前驅(qū)節(jié)點(diǎn)是頭節(jié)點(diǎn)（或者說(shuō)你馬上就輪到你運(yùn)行了循榆，你在鏈表第二位）析恢，
                // 同時(shí)再?lài)L試一次獲取鎖操作（說(shuō)不定頭節(jié)點(diǎn)已經(jīng)釋放鎖了，我直接就獲取到了呢）
                // 其中一個(gè)不滿(mǎn)足則跳過(guò)（不是頭節(jié)點(diǎn)或沒(méi)獲取到鎖）
                if (p == head && tryAcquire(arg)) { 
                    setHead(node);
                    p.next = null; // help GC
                    failed = false;
                    return interrupted;
                }
                // 設(shè)置一個(gè)合適的鏈表節(jié)點(diǎn)位置（也可以稱(chēng)為合適時(shí)機(jī)）讓其線(xiàn)程等待秧饮，（在此期間映挂，可能會(huì)有前驅(qū)節(jié)點(diǎn)中斷或者已運(yùn)行完成等情況，所以要設(shè)置一個(gè)合理位置）
                if (shouldParkAfterFailedAcquire(p, node) &&
                    // 如果找到合適時(shí)機(jī)（true）盗尸，則觸發(fā)邏輯表達(dá)式 parkAndCheckInterrupt方法調(diào)用讓線(xiàn)程等待
                    // 此時(shí)柑船，線(xiàn)程在此進(jìn)入wait的狀態(tài)，等待其他線(xiàn)程喚醒或者被中止泼各，這是重點(diǎn)鞍时，后續(xù)讓你了解如何解鎖的
                    parkAndCheckInterrupt())
                    interrupted = true;
            }
        } finally {
            if (failed)
                cancelAcquire(node); // 執(zhí)行失敗移除，或通知后續(xù)節(jié)點(diǎn)繼續(xù)历恐，第 5 小節(jié)會(huì)細(xì)說(shuō)
        }
    }

    /**
     * 設(shè)置一個(gè)合適的鏈表節(jié)點(diǎn)位置（也可以稱(chēng)為合適時(shí)機(jī)）讓其線(xiàn)程等待寸癌，（在此期間，可能會(huì)有前驅(qū)節(jié)點(diǎn)中斷或者已運(yùn)行完成等情況弱贼，所以要設(shè)置一個(gè)合理位置）
     *
     * @param pred node's predecessor holding status
     * @param node the node
     * @return {@code true} if thread should block
     */
    private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) {
        int ws = pred.waitStatus;
        if (ws == Node.SIGNAL)
            /*
             * 前驅(qū)節(jié)點(diǎn)的 waitStatus = SIGNAL狀態(tài)表示：后繼節(jié)點(diǎn)需要被通知釋放（后驅(qū)節(jié)點(diǎn)這時(shí)候在一直阻塞等待）
             */
            return true;
        if (ws > 0) { // waitStatus 狀態(tài)大于0提佣，代表的是線(xiàn)程已經(jīng)取消或終止了
            /*
             * 我們找到前驅(qū)節(jié)點(diǎn)沒(méi)有被取消或終止的那一個(gè)长豁。就像早點(diǎn)鋪來(lái)不及排隊(duì)的人走掉一樣疚脐，你要接上這個(gè)隊(duì)伍萍鲸，然后重試獲取一個(gè)等待時(shí)機(jī)
             */
            do {
                node.prev = pred = pred.prev;
            } while (pred.waitStatus > 0);
            pred.next = node;
        } else {
            /*
             * 大致意思就是，告知前驅(qū)節(jié)點(diǎn)庇勃，你執(zhí)行完后檬嘀，我需要被通知釋放，然后重新獲取一次等待時(shí)機(jī)
             */
            compareAndSetWaitStatus(pred, ws, Node.SIGNAL);
        }
        return false;
    }

    /**
     * 執(zhí)行線(xiàn)程阻塞等待责嚷，并在喚醒后檢查線(xiàn)程是否中止
     *
     * @return {@code true} if interrupted
     */
    private final boolean parkAndCheckInterrupt() {
        LockSupport.park(this);
        return Thread.interrupted();
    }

看到這里鸳兽，我們已了解到加入CLH隊(duì)列的節(jié)點(diǎn)（線(xiàn)程）會(huì)自己做一些排隊(duì)的處理，我們也該再整理一下Node節(jié)點(diǎn)的屬性和作用了罕拂，這樣我們?cè)俜催^(guò)來(lái)回顧一下揍异，會(huì)更加清晰全陨！

4. Node節(jié)點(diǎn)的屬性和意義：

• waitStatus：我們?cè)谏衔闹锌吹搅舜罅康脑摖顟B(tài)，主要代表節(jié)點(diǎn)的等待狀態(tài)表示方式衷掷，具體看注釋?zhuān)?/li>
• prev：關(guān)聯(lián)前驅(qū)節(jié)點(diǎn)辱姨；
• next：關(guān)聯(lián)后驅(qū)節(jié)點(diǎn)；
• thread：節(jié)點(diǎn)綁定的工作線(xiàn)程戚嗅；
• nextWaiter：鎖的模式雨涛，我們?cè)谄鸪醯墨@取鎖的入口方法里，有一個(gè)Node.EXCLUSIVE懦胞，代表是獨(dú)占模式替久。

        volatile int waitStatus;
        volatile Node prev;
        volatile Node next;
        volatile Thread thread;
        Node nextWaiter;

        // 下面這些字段，代表著 waitStatus的一些狀態(tài)值
        /** waitStatus value to indicate thread has cancelled 躏尉，取消或終止*/
        static final int CANCELLED =  1;
        /** waitStatus value to indicate successor's thread needs unparking 侣肄，需要喚醒下個(gè)節(jié)點(diǎn)*/
        static final int SIGNAL    = -1;
        /** waitStatus value to indicate thread is waiting on condition ，使用Condition方式形成的等待醇份，可先忽略，后續(xù)在講*/
        static final int CONDITION = -2;
        /**
         * waitStatus value to indicate the next acquireShared should unconditionally propagate 吼具，共享鎖下的無(wú)條件傳播模式僚纷，后續(xù)在講
         */
        static final int PROPAGATE = -3;

5. 節(jié)點(diǎn)（線(xiàn)程）中斷或者失敗的釋放

在第 3 小節(jié)中，我們已經(jīng)成功的線(xiàn)程持有鎖或者加入CLH的等待隊(duì)列中拗盒，但是還沒(méi)完怖竭。
我們知道，線(xiàn)程會(huì)有被終止的風(fēng)險(xiǎn)陡蝇，或者加鎖失敗痊臭，那后續(xù)這個(gè)節(jié)點(diǎn)還在隊(duì)列中，那怎么辦呢登夫？
請(qǐng)看下面詳細(xì)源碼及注釋?zhuān)?/p>

    /**
     * 取消獲取鎖操作
     *
     * @param node the node
     */
    private void cancelAcquire(Node node) {
        // Ignore if node doesn't exist
        if (node == null)
            return;

        node.thread = null; // 先將持有線(xiàn)程設(shè)置為 null

        // 跳過(guò)所有被終止或失敗的前驅(qū)節(jié)點(diǎn)广匙，去找正常的前驅(qū)節(jié)點(diǎn)
        Node pred = node.prev;
        while (pred.waitStatus > 0)
            node.prev = pred = pred.prev;

        // 獲取前驅(qū)節(jié)點(diǎn)的后驅(qū)節(jié)點(diǎn)，理論上此時(shí)在高并發(fā)情況下恼策，該next可能已經(jīng)不是node
        Node predNext = pred.next;

        // 這個(gè)設(shè)置不需要CAS鸦致，因?yàn)樵趧e的節(jié)點(diǎn)檢查時(shí)，會(huì)跳過(guò)該節(jié)點(diǎn)
        node.waitStatus = Node.CANCELLED;

        // 如果當(dāng)前節(jié)點(diǎn)為CLH尾節(jié)點(diǎn)涣楷，并且可以原子性的修改尾節(jié)點(diǎn)分唾，則直接完成取消操作（此時(shí)，沒(méi)有人排在你后面）
        if (node == tail && compareAndSetTail(node, pred)) {
            compareAndSetNext(pred, predNext, null);
        } else {
            // 如果有人還在你后面排隊(duì)狮斗，那你就要通知他釋放或者前移
            // 當(dāng)你前面排隊(duì)的人很多（當(dāng)前節(jié)點(diǎn)不是頭節(jié)點(diǎn)后面那個(gè)）绽乔，則嘗試告知前面那個(gè)人說(shuō)：你一會(huì)去通知我后面那個(gè)人，我等不及買(mǎi)早點(diǎn)了撤了（前提是碳褒，你后面有人且他打算繼續(xù)排隊(duì)）折砸。
            int ws;
            if (pred != head &&
                ((ws = pred.waitStatus) == Node.SIGNAL ||
                 (ws <= 0 && compareAndSetWaitStatus(pred, ws, Node.SIGNAL))) &&
                pred.thread != null) {
                Node next = node.next;
                if (next != null && next.waitStatus <= 0)
                    compareAndSetNext(pred, predNext, next);
            } else {
                // 如果上面情況都沒(méi)一次性嘗試成功看疗，那么就按個(gè)的進(jìn)行嘗試通知，讓隊(duì)伍接上（喚醒后驅(qū)節(jié)點(diǎn)）
                unparkSuccessor(node);
            }

            node.next = node; // help GC
        }
    }

    /**
     * 喚醒后驅(qū)節(jié)點(diǎn)
     *
     * @param node the node
     */
    private void unparkSuccessor(Node node) {
        /*
         * 這種情況時(shí)正常解鎖判斷的鞍爱，我們后續(xù)在解鎖中會(huì)講鹃觉，目前已取消是必然的 waitStatus = CANCELLED > 0
         */
        int ws = node.waitStatus;
        if (ws < 0)
            compareAndSetWaitStatus(node, ws, 0);

        /*
         * 我們開(kāi)始找后驅(qū)節(jié)點(diǎn)，如果后驅(qū)節(jié)點(diǎn)不存在或者后驅(qū)節(jié)點(diǎn)也處于終止?fàn)顟B(tài)睹逃，
         * 則干脆直接從CLH尾部開(kāi)始向前找合適的后驅(qū)節(jié)點(diǎn)盗扇，找到之后，通知其釋放等待
         */
        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); // 通知后驅(qū)釋放等待沉填，開(kāi)始獲取鎖
    }

至此疗隶，一個(gè)簡(jiǎn)單且完整的獲取鎖操作便完成了他的工作。

注：當(dāng)你深度思考后翼闹，你會(huì)發(fā)現(xiàn)斑鼻，當(dāng)AQS在某種情況下，會(huì)有概率出現(xiàn)靜默問(wèn)題猎荠，但這應(yīng)該是極小的情況坚弱，可以忽略。靜默問(wèn)題指中間鏈表中斷关摇，此時(shí)前驅(qū)無(wú)任務(wù)荒叶，后驅(qū)需要重新從tail找到可用節(jié)點(diǎn)所需時(shí)間內(nèi)靜默的狀態(tài)，我稱(chēng)其為靜默狀態(tài)输虱。

6. 利用AQS如何完成解鎖的操作

解鎖就簡(jiǎn)單很多了些楣，比較在加鎖中也有解鎖的身影了？哪里哦宪睹，你個(gè)賴(lài)皮愁茁？？答案就是節(jié)點(diǎn)終止或失敗亭病。

請(qǐng)看如下代碼步驟和詳細(xì)注釋?zhuān)粋€(gè)完整的解鎖入口 release()方法(形如：Lock.unlock())：

    /**
     * 釋放節(jié)點(diǎn)（線(xiàn)程）鹅很，tryRelease()是抽象方法，交由上層具體類(lèi)實(shí)現(xiàn)罪帖，其意思是嘗試一次解鎖
     *
     * @param arg the release argument.  This value is conveyed to
     *        {@link #tryRelease} but is otherwise uninterpreted and
     *        can represent anything you like.
     * @return the value returned from {@link #tryRelease}
     */
    public final boolean release(int arg) {
        if (tryRelease(arg)) { // 嘗試一次解鎖
            Node h = head;
            if (h != null && h.waitStatus != 0) // 當(dāng)頭節(jié)點(diǎn)不為空且包含有信號(hào)通知時(shí)道宅，則出發(fā)釋放通知（向后驅(qū)節(jié)點(diǎn)發(fā)送）
                unparkSuccessor(h); // 這個(gè)就是第五小節(jié)基本一致了（終止操作）
            return true;
        }
        return false;
    }

到此，整個(gè)一套加鎖胸蛛、解鎖的流程就走通了污茵，但上面簡(jiǎn)述的只是獨(dú)占鎖的方式。

7. 共享鎖的了解

本章節(jié)節(jié)中葬项，如果與獨(dú)占鎖相同的邏輯地方不再講述泞当，只會(huì)一筆帶過(guò)。對(duì)于共享鎖民珍，原理大致和獨(dú)占相似襟士，
最大的不同就是共享鎖中 setHeadAndPropagate方法盗飒，設(shè)置頭節(jié)點(diǎn)，然后通知后驅(qū)共享節(jié)點(diǎn)釋放陋桂。

    // 共享方式獲取逆趣，入口
    public final void acquireShared(int arg) {
        if (tryAcquireShared(arg) < 0) // 嘗試一次獲取鎖，繼承AQS實(shí)現(xiàn)
            doAcquireShared(arg); // 循環(huán)嘗試獲取共享鎖
    }

    /**
     * 共享模式下嗜历，和獨(dú)占鎖模式先邏輯大致相同：把一個(gè)新節(jié)點(diǎn)（搶占線(xiàn)程）插入鏈表尾部
     * @param arg the acquire argument
     */
    private void doAcquireShared(int arg) {
        final Node node = addWaiter(Node.SHARED); // 在獨(dú)占鎖中 addWaiter的入?yún)⑹荖ode.EXCLUSIVE
        boolean failed = true;
        try {
            boolean interrupted = false;
            for (;;) {
                final Node p = node.predecessor();
                if (p == head) {
                    int r = tryAcquireShared(arg); // 獨(dú)占鎖模式返回的是boolean值宣渗，共享模式返回int值，負(fù)值為獲取失敗
                    if (r >= 0) {
                        setHeadAndPropagate(node, r); // 最大的區(qū)別在這里梨州，我們?cè)谙旅婵聪逻@個(gè)方法
                        p.next = null; // help GC
                        if (interrupted)
                            selfInterrupt();
                        failed = false;
                        return;
                    }
                }
                if (shouldParkAfterFailedAcquire(p, node) &&
                    parkAndCheckInterrupt())
                    interrupted = true;
            }
        } finally {
            if (failed)
                cancelAcquire(node);
        }
    }

    /**
     * Sets head of queue, and checks if successor may be waiting
     * in shared mode, if so propagating if either propagate > 0 or
     * PROPAGATE status was set.
     * 
     * 由于是共享模式痕囱，極端情況下可能會(huì)同時(shí)存在于兩個(gè)節(jié)點(diǎn)競(jìng)爭(zhēng)head，前提是在一次嘗試后為獲取到鎖暴匠，
     * 理論上鞍恢，共享模式下在最早的第一次 tryAcquireShared調(diào)用下就可以成功，除非資源不夠才會(huì)調(diào)用 addWait放入隊(duì)列每窖。
     *
     * @param node the node
     * @param propagate the return value from a tryAcquireShared
     */
    private void setHeadAndPropagate(Node node, int propagate) {
        Node h = head; // Record old head for check below 第一次設(shè)置前沒(méi)有head節(jié)點(diǎn)
        setHead(node); // 在獨(dú)占模式中帮掉，僅僅只用調(diào)用這一個(gè)方法
        
        // 如果嘗試獲取成功，則設(shè)置該節(jié)點(diǎn)為頭節(jié)點(diǎn)窒典，
        // 保證 propagate資源足夠旭寿、頭節(jié)點(diǎn)為null（沒(méi)有正在運(yùn)行的節(jié)點(diǎn)）、需要通知后驅(qū)節(jié)點(diǎn)狀態(tài)的其中一個(gè)條件的情況下崇败，
        // 且后驅(qū)節(jié)點(diǎn)是null或是共享模式，則依次傳播釋放其他正在等待的共享節(jié)點(diǎn)
        if (propagate > 0 || h == null || h.waitStatus < 0 ||
            (h = head) == null || h.waitStatus < 0) {
            Node s = node.next;
            if (s == null || s.isShared())
                doReleaseShared(); // 共享傳播肩祥，釋放其他共享節(jié)點(diǎn)
        }
    }

    // 共享模式下的釋放通知后室，包括解鎖，也采用該方法
    private void doReleaseShared() {
        // 依次喚醒下一個(gè)節(jié)點(diǎn)混狠，當(dāng)排隊(duì)節(jié)點(diǎn)阻塞等待時(shí)岸霹，一定會(huì)設(shè)置好前驅(qū)節(jié)點(diǎn)的通知狀態(tài)
        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;
        }
    }

注：doReleaseShared()方法需要結(jié)合上下文看，這玩意挺繞人将饺，哈哈哈贡避！

求助：

我猜測(cè)一個(gè)問(wèn)題，假設(shè)沒(méi)有acquireShared方法中那第一次嘗試獲取予弧，當(dāng) 頭節(jié)點(diǎn)和當(dāng)前節(jié)點(diǎn)同時(shí)進(jìn)入setHeadAndPropagate方法時(shí)刮吧，當(dāng)前節(jié)點(diǎn)會(huì)替換掉頭節(jié)點(diǎn)，原來(lái)的頭節(jié)點(diǎn)已經(jīng)消失掖蛤。此時(shí)杀捻，無(wú)法修改原來(lái)頭節(jié)點(diǎn)的 waitStatus通知狀態(tài)，且當(dāng)前節(jié)點(diǎn)既是head又是tail蚓庭，導(dǎo)致在通知時(shí)直接跳過(guò)致讥，也不做任何釋放仅仆，難道CLH隊(duì)列一直保留著最后一個(gè)廢棄的節(jié)點(diǎn)？垢袱？墓拜？
下面這個(gè)操作一方面是設(shè)置頭節(jié)點(diǎn)，另一方面是不是移除必要信息请契，形成一個(gè)空頭節(jié)點(diǎn)（只有next屬性）呢咳榜？
如有大神請(qǐng)幫忙展開(kāi)講講，謝謝姚糊！

    /**
     * Sets head of queue to be node, thus dequeuing. Called only by
     * acquire methods.  Also nulls out unused fields for sake of GC
     * and to suppress unnecessary signals and traversals.
     *
     * @param node the node
     */
    private void setHead(Node node) {
        head = node;
        node.thread = null;
        node.prev = null;
    }