怎么從源碼看AQS

本篇內(nèi)容介紹了“怎么從源碼看AQS”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

成都創(chuàng)新互聯(lián)是一家專業(yè)提供南昌企業(yè)網(wǎng)站建設(shè),專注與網(wǎng)站設(shè)計制作、網(wǎng)站設(shè)計、H5網(wǎng)站設(shè)計、小程序制作等業(yè)務(wù)。10年已為南昌眾多企業(yè)、政府機構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站建設(shè)公司優(yōu)惠進行中。

AQS實際上是操作以Node為元素的隊列，Node包含了所屬線程，先以不公平鎖分析：lock時先嘗試獲取鎖，獲取失敗則進入隊列且被阻塞（期間可以被打斷）等待，當(dāng)鎖被釋放的時候，如果隊列不為空，則喚醒頭節(jié)點的下一個節(jié)點NEXT，如果此時被新線程NT拿到鎖，則NEXT繼續(xù)進入阻塞等待，當(dāng)NT釋放鎖時，頭節(jié)點的下一個節(jié)點還是NEXT再次被喚醒，如果此時NEXT獲得鎖，則將NEXT設(shè)置為頭節(jié)點，這就是一個大概的流程，順著這個思路，再來一步步看實現(xiàn)代碼。

AQS->AbstractQueuedSynchronizer，看名字抽象隊列同步器，首先得有隊列。

先來看隊列節(jié)點類，Node：

static final class Node {
        
        static final Node SHARED = new Node(); //共享模式標(biāo)記
        static final Node EXCLUSIVE = null;//獨占模式標(biāo)記
        
        static final int CANCELLED =  1;
        static final int SIGNAL    = -1;
        static final int CONDITION = -2;
        static final int PROPAGATE = -3;
        volatile int waitStatus;//取值為 上面的4個int，初始化為0

        volatile Node prev;//前一個節(jié)點

        volatile Node next;//下一個節(jié)點

        volatile Thread thread;

        Node nextWaiter;//下一個等待節(jié)點  SHARED，EXCLUSIVE 
        
        //如果節(jié)點在共享模式下等待，則返回true
        final boolean isShared() {
            return nextWaiter == SHARED;
        }

        //返回前一個節(jié)點
        final Node predecessor() throws NullPointerException {
            Node p = prev;
            if (p == null)
                throw new NullPointerException();
            else
                return p;
        }

        Node() {
        }
        //以下是Node的兩種不同的使用方式
        Node(Thread thread, Node mode) {  
            this.nextWaiter = mode;
            this.thread = thread;
        }

        Node(Thread thread, int waitStatus) { 
            this.waitStatus = waitStatus;
            this.thread = thread;
        }
    }

注意上面兩種不同的節(jié)點使用方式，要構(gòu)建隊列那么還得有隊列的首尾表示節(jié)點，

    //隊列頭節(jié)點，除開初始化，只能通過setHead方法設(shè)置    
    private transient volatile Node head;
    //隊列尾節(jié)點，只能通過enq方法設(shè)置
    private transient volatile Node tail;
   //同步狀態(tài)
    private volatile int state; //初始狀態(tài)為0

那么具體的實現(xiàn)或者用法，我們還是通過舉例來說明：

ReentrantLock-可重入鎖，下面以RL代表，以AQS代表AbstractQueuedSynchronizer。

在RL中有個靜態(tài)內(nèi)部類，Sync 是AbstractQueuedSynchronizer的抽象子類。在Sync的基礎(chǔ)上繼續(xù)擴展出兩個實現(xiàn)子類 NonfairSync（非公平）和FairSync（公平）。而RL實現(xiàn)鎖機制就是建立在 Sync的基礎(chǔ)之上的。

先說說NonfairSync（以nfs簡稱），非公平鎖：

當(dāng)我們使用RL.lock()獲取鎖，實際調(diào)用是nfs的lock方法

final void lock() {
    if (compareAndSetState(0, 1))
        setExclusiveOwnerThread(Thread.currentThread());
    else
        acquire(1);
}

compareAndSetState就是使用CAS樂觀鎖來修改AQS的state值，由0 改為1，有疑問可以參考UnSafe類實現(xiàn)CAS樂觀鎖，然后將當(dāng)前線程設(shè)置為鎖的占有線程。acquire方法是由AQS實現(xiàn)的，

//嘗試獲取鎖失敗，則進入隊列
public final void acquire(int arg) {
        if (!tryAcquire(arg) &&
            acquireQueued(addWaiter(Node.EXCLUSIVE), arg))//如果在acquireQueued期間線程標(biāo)記中斷，那么將進入線程中斷selfInterrupt。
            selfInterrupt();
    }

tryAcquire是由子類來實現(xiàn)的，這里也就是由nfs實現(xiàn)，主要是再次嘗試獲取鎖（可重入鎖），來看具體實現(xiàn)：

final boolean nonfairTryAcquire(int acquires) {
            final Thread current = Thread.currentThread();
            int c = getState();
            if (c == 0) { //如果state為0 ， 則嘗試獲取鎖
                if (compareAndSetState(0, acquires)) {
                    setExclusiveOwnerThread(current);
                    return true;
                }
            }
            //如果鎖已經(jīng)被占用，但是占有者是當(dāng)前線程，那么將state + 1，即重入鎖，最大值為Integer.MAX_VALUE
            else if (current == getExclusiveOwnerThread()) {
                int nextc = c + acquires;
                if (nextc < 0) 
                    throw new Error("Maximum lock count exceeded");
                setState(nextc);
                return true;
            }
            return false;//否則返回false
        }

第二個條件 acquireQueued(addWaiter(Node.EXCLUSIVE), arg)，EXCLUSIVE獨占鎖標(biāo)志，兩個方法都是AQS實現(xiàn)的：

private Node addWaiter(Node mode) {
        Node node = new Node(Thread.currentThread(), mode);
        //先判斷隊列的尾節(jié)點是否為空，此處是一個快速嘗試，失敗了就繼續(xù)走enq方法
        Node pred = tail;
        if (pred != null) {//嘗試將尾節(jié)點設(shè)置為node，設(shè)置成功則返回
            node.prev = pred;
            if (compareAndSetTail(pred, node)) {
                pred.next = node;
                return node;
            }
        }
        enq(node);//將node插入隊列尾部，然后返回，也是由CAS實現(xiàn)，注意 enq會初始化一個空的Node（無參構(gòu)造函數(shù)）作為head節(jié)點
        return node;
    }
final boolean acquireQueued(final Node node, int arg) {
        boolean failed = true;
        try {
            boolean interrupted = false;
            //進入循環(huán)
            for (;;) {
                final Node p = node.predecessor();//獲取node的上一個節(jié)點p
                if (p == head && tryAcquire(arg)) {//如果p是頭節(jié)點，而且當(dāng)前線程拿到了鎖，那么就將node設(shè)為頭節(jié)點，注意這里可能會有最新來的線程和p節(jié)點所屬的線程進行競爭，競爭失敗則繼續(xù)進入阻塞等待，當(dāng)鎖被釋放時，又會喚醒頭節(jié)點的下一個節(jié)點
                    setHead(node);
                    p.next = null; // 方便回收
                    failed = false;
                    return interrupted;
                }
                if (shouldParkAfterFailedAcquire(p, node) &&
                    parkAndCheckInterrupt())  //線程會阻塞，等待釋放，直到prev節(jié)點完全釋放鎖的時候會被喚醒，然后開始再次循環(huán)。shouldParkAfterFailedAcquire 主要是修改node的waitStatus。parkAndCheckInterrupt 主要阻塞當(dāng)前線程，期間線程可能會被中斷，當(dāng)線程被喚醒之后，再判斷是否被中斷。
                    interrupted = true;
            }
        } finally {
            if (failed)
                cancelAcquire(node); //取消獲得的鎖
        }
    }
//因為是普通節(jié)點，所以waitStatus的初始值為0，忘了的話可以回到上面看下Node的兩種構(gòu)造函數(shù)
//所以這里主要由兩步，第一步嘗試將pred的 waitStatus 改為SIGNAL，第二次再進來就直接返回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;
    }

成功獲取鎖之后才能釋放鎖：

//AQS實現(xiàn)
public final boolean release(int arg) {
        if (tryRelease(arg)) { //由子類實現(xiàn)，包括重入鎖持有，直到所有鎖全部釋放
            Node h = head;
            if (h != null && h.waitStatus != 0) //如果head節(jié)點的等待狀態(tài)不為0，在獲取鎖失敗的時候，node節(jié)點會將prev的waitstatus改為SIGNAL，也就是p后面還有節(jié)點， 具體是在 shouldParkAfterFailedAcquire方法
                unparkSuccessor(h);//喚醒h的下一個節(jié)點
            return true;//完全釋放鎖
        }
        return false;
    }
//nfs實現(xiàn)：
protected final boolean tryRelease(int releases) {
            int c = getState() - releases;
            if (Thread.currentThread() != getExclusiveOwnerThread()) // 判斷當(dāng)前線程是否是鎖的持有線程
                throw new IllegalMonitorStateException();
            boolean free = false;
            if (c == 0) { //如果c == 0表示當(dāng)前線程獲得的重入鎖已經(jīng)全部釋放，則修改鎖的持有線程為null
                free = true;
                setExclusiveOwnerThread(null);
            }
            setState(c);//否則只是將state - 1 
            return free;
        }

從上面加鎖、釋放鎖的步驟可以看出，不公平鎖不公平的地方在于，當(dāng)head節(jié)點完全釋放鎖的時候，這個時候最新來的線程和head節(jié)點喚醒的下一個節(jié)點會同時競爭鎖。

“怎么從源碼看AQS”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！

網(wǎng)頁名稱：怎么從源碼看AQS
網(wǎng)站路徑：http://bm7419.com/article38/pcoisp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站收錄、手機網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、網(wǎng)站導(dǎo)航、定制網(wǎng)站、用戶體驗

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容