摘要：其二如果返回值等于表示當(dāng)前線程獲取共享鎖成功，但它后續(xù)的線程是無(wú)法繼續(xù)獲取的，也就是不需要把它后面等待的節(jié)點(diǎn)喚醒。

在了解了AQS獨(dú)占鎖模式以后，接下來(lái)再來(lái)看看共享鎖的實(shí)現(xiàn)原理。

原文地址：http://www.jianshu.com/p/1161...

搞清楚AQS獨(dú)占鎖的實(shí)現(xiàn)原理之后，再看共享鎖的實(shí)現(xiàn)原理就會(huì)輕松很多。兩種鎖模式之間很多通用的地方本文只會(huì)簡(jiǎn)單說(shuō)明一下，就不在贅述了，具體細(xì)節(jié)可以參考我的上篇文章深入淺出AQS之獨(dú)占鎖模式

獲取鎖的過(guò)程：

當(dāng)線程調(diào)用acquireShared()申請(qǐng)獲取鎖資源時(shí)，如果成功，則進(jìn)入臨界區(qū)。

當(dāng)獲取鎖失敗時(shí)，則創(chuàng)建一個(gè)共享類(lèi)型的節(jié)點(diǎn)并進(jìn)入一個(gè)FIFO等待隊(duì)列，然后被掛起等待喚醒。

當(dāng)隊(duì)列中的等待線程被喚醒以后就重新嘗試獲取鎖資源，如果成功則喚醒后面還在等待的共享節(jié)點(diǎn)并把該喚醒事件傳遞下去，即會(huì)依次喚醒在該節(jié)點(diǎn)后面的所有共享節(jié)點(diǎn)，然后進(jìn)入臨界區(qū)，否則繼續(xù)掛起等待。

釋放鎖過(guò)程：

當(dāng)線程調(diào)用releaseShared()進(jìn)行鎖資源釋放時(shí)，如果釋放成功，則喚醒隊(duì)列中等待的節(jié)點(diǎn)，如果有的話。

基于上面所說(shuō)的共享鎖執(zhí)行流程，我們接下來(lái)看下源碼實(shí)現(xiàn)邏輯：
首先來(lái)看下獲取鎖的方法acquireShared()，如下

   public final void acquireShared(int arg) {
        //嘗試獲取共享鎖，返回值小于0表示獲取失敗
        if (tryAcquireShared(arg) < 0)
            //執(zhí)行獲取鎖失敗以后的方法
            doAcquireShared(arg);
    }

這里tryAcquireShared()方法是留給用戶去實(shí)現(xiàn)具體的獲取鎖邏輯的。關(guān)于該方法的實(shí)現(xiàn)有兩點(diǎn)需要特別說(shuō)明：

一、該方法必須自己檢查當(dāng)前上下文是否支持獲取共享鎖，如果支持再進(jìn)行獲取。

二、該方法返回值是個(gè)重點(diǎn)。其一、由上面的源碼片段可以看出返回值小于0表示獲取鎖失敗，需要進(jìn)入等待隊(duì)列。其二、如果返回值等于0表示當(dāng)前線程獲取共享鎖成功，但它后續(xù)的線程是無(wú)法繼續(xù)獲取的，也就是不需要把它后面等待的節(jié)點(diǎn)喚醒。最后、如果返回值大于0，表示當(dāng)前線程獲取共享鎖成功且它后續(xù)等待的節(jié)點(diǎn)也有可能繼續(xù)獲取共享鎖成功，也就是說(shuō)此時(shí)需要把后續(xù)節(jié)點(diǎn)喚醒讓它們?nèi)L試獲取共享鎖。

有了上面的約定，我們?cè)賮?lái)看下doAcquireShared方法的實(shí)現(xiàn)：

    //參數(shù)不多說(shuō)，就是傳給acquireShared()的參數(shù)
    private void doAcquireShared(int arg) {
        //添加等待節(jié)點(diǎn)的方法跟獨(dú)占鎖一樣，唯一區(qū)別就是節(jié)點(diǎn)類(lèi)型變?yōu)榱斯蚕硇?，不再贅?        final Node node = addWaiter(Node.SHARED);
        boolean failed = true;
        try {
            boolean interrupted = false;
            for (;;) {
                final Node p = node.predecessor();
                //表示前面的節(jié)點(diǎn)已經(jīng)獲取到鎖，自己會(huì)嘗試獲取鎖
                if (p == head) {
                    int r = tryAcquireShared(arg);
                    //注意上面說(shuō)的， 等于0表示不用喚醒后繼節(jié)點(diǎn)，大于0需要
                    if (r >= 0) {
                        //這里是重點(diǎn)，獲取到鎖以后的喚醒操作，后面詳細(xì)說(shuō)
                        setHeadAndPropagate(node, r);
                        p.next = null;
                        //如果是因?yàn)橹袛嘈褋?lái)則設(shè)置中斷標(biāo)記位
                        if (interrupted)
                            selfInterrupt();
                        failed = false;
                        return;
                    }
                }
                //掛起邏輯跟獨(dú)占鎖一樣，不再贅述
                if (shouldParkAfterFailedAcquire(p, node) &&
                    parkAndCheckInterrupt())
                    interrupted = true;
            }
        } finally {
            //獲取失敗的取消邏輯跟獨(dú)占鎖一樣，不再贅述
            if (failed)
                cancelAcquire(node);
        }
    }

獨(dú)占鎖模式獲取成功以后設(shè)置頭結(jié)點(diǎn)然后返回中斷狀態(tài)，結(jié)束流程。而共享鎖模式獲取成功以后，調(diào)用了setHeadAndPropagate方法，從方法名就可以看出除了設(shè)置新的頭結(jié)點(diǎn)以外還有一個(gè)傳遞動(dòng)作，一起看下代碼：

    //兩個(gè)入?yún)?，一個(gè)是當(dāng)前成功獲取共享鎖的節(jié)點(diǎn)，一個(gè)就是tryAcquireShared方法的返回值，注意上面說(shuō)的，它可能大于0也可能等于0
    private void setHeadAndPropagate(Node node, int propagate) {
        Node h = head; //記錄當(dāng)前頭節(jié)點(diǎn)
        //設(shè)置新的頭節(jié)點(diǎn)，即把當(dāng)前獲取到鎖的節(jié)點(diǎn)設(shè)置為頭節(jié)點(diǎn)
        //注：這里是獲取到鎖之后的操作，不需要并發(fā)控制
        setHead(node);
        //這里意思有兩種情況是需要執(zhí)行喚醒操作
        //1.propagate > 0 表示調(diào)用方指明了后繼節(jié)點(diǎn)需要被喚醒
        //2.頭節(jié)點(diǎn)后面的節(jié)點(diǎn)需要被喚醒（waitStatus<0），不論是老的頭結(jié)點(diǎn)還是新的頭結(jié)點(diǎn)
        if (propagate > 0 || h == null || h.waitStatus < 0 ||
            (h = head) == null || h.waitStatus < 0) {
            Node s = node.next;
            //如果當(dāng)前節(jié)點(diǎn)的后繼節(jié)點(diǎn)是共享類(lèi)型獲取沒(méi)有后繼節(jié)點(diǎn)，則進(jìn)行喚醒
            //這里可以理解為除非明確指明不需要喚醒（后繼等待節(jié)點(diǎn)是獨(dú)占類(lèi)型），否則都要喚醒
            if (s == null || s.isShared())
                //后面詳細(xì)說(shuō)
                doReleaseShared();
        }
    }

    private void setHead(Node node) {
        head = node;
        node.thread = null;
        node.prev = null;
    }

最終的喚醒操作也很復(fù)雜，專門(mén)拿出來(lái)分析一下：
注：這個(gè)喚醒操作在releaseShare()方法里也會(huì)調(diào)用。

private void doReleaseShared() {
        for (;;) {
            //喚醒操作由頭結(jié)點(diǎn)開(kāi)始，注意這里的頭節(jié)點(diǎn)已經(jīng)是上面新設(shè)置的頭結(jié)點(diǎn)了
            //其實(shí)就是喚醒上面新獲取到共享鎖的節(jié)點(diǎn)的后繼節(jié)點(diǎn)
            Node h = head;
            if (h != null && h != tail) {
                int ws = h.waitStatus;
                //表示后繼節(jié)點(diǎn)需要被喚醒
                if (ws == Node.SIGNAL) {
                    //這里需要控制并發(fā)，因?yàn)槿肟谟衧etHeadAndPropagate跟release兩個(gè)，避免兩次unpark
                    if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
                        continue;      
                    //執(zhí)行喚醒操作      
                    unparkSuccessor(h);
                }
                //如果后繼節(jié)點(diǎn)暫時(shí)不需要喚醒，則把當(dāng)前節(jié)點(diǎn)狀態(tài)設(shè)置為PROPAGATE確保以后可以傳遞下去
                else if (ws == 0 &&
                         !compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
                    continue;                
            }
            //如果頭結(jié)點(diǎn)沒(méi)有發(fā)生變化，表示設(shè)置完成，退出循環(huán)
            //如果頭結(jié)點(diǎn)發(fā)生變化，比如說(shuō)其他線程獲取到了鎖，為了使自己的喚醒動(dòng)作可以傳遞，必須進(jìn)行重試
            if (h == head)                   
                break;
        }
    }

接下來(lái)看下釋放共享鎖的過(guò)程：

public final boolean releaseShared(int arg) {
        //嘗試釋放共享鎖
        if (tryReleaseShared(arg)) {
            //喚醒過(guò)程，詳情見(jiàn)上面分析
            doReleaseShared();
            return true;
        }
        return false;
    }

注：上面的setHeadAndPropagate()方法表示等待隊(duì)列中的線程成功獲取到共享鎖，這時(shí)候它需要喚醒它后面的共享節(jié)點(diǎn)（如果有），但是當(dāng)通過(guò)releaseShared（）方法去釋放一個(gè)共享鎖的時(shí)候，接下來(lái)等待獨(dú)占鎖跟共享鎖的線程都可以被喚醒進(jìn)行嘗試獲取。

跟獨(dú)占鎖相比，共享鎖的主要特征在于當(dāng)一個(gè)在等待隊(duì)列中的共享節(jié)點(diǎn)成功獲取到鎖以后（它獲取到的是共享鎖），既然是共享，那它必須要依次喚醒后面所有可以跟它一起共享當(dāng)前鎖資源的節(jié)點(diǎn)，毫無(wú)疑問(wèn)，這些節(jié)點(diǎn)必須也是在等待共享鎖（這是大前提，如果等待的是獨(dú)占鎖，那前面已經(jīng)有一個(gè)共享節(jié)點(diǎn)獲取鎖了，它肯定是獲取不到的）。當(dāng)共享鎖被釋放的時(shí)候，可以用讀寫(xiě)鎖為例進(jìn)行思考，當(dāng)一個(gè)讀鎖被釋放，此時(shí)不論是讀鎖還是寫(xiě)鎖都是可以競(jìng)爭(zhēng)資源的。