本文將主要結(jié)合源碼對 JDK 中的阻塞隊列進(jìn)行分析，并比較其各自的特點；

成都創(chuàng)新互聯(lián)主營白銀網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,app開發(fā)定制,白銀h5微信小程序開發(fā)搭建,白銀網(wǎng)站營銷推廣歡迎白銀等地區(qū)企業(yè)咨詢

一、BlockingQueue 概述

說到阻塞隊列想到的第一個應(yīng)用場景可能就是生產(chǎn)者消費者模式了，如圖所示；

根據(jù)上圖所示，明顯在入隊和出隊的時候，會發(fā)生競爭；所以一種很自然的想法就是使用鎖，而在 JDK 中也的確是通過鎖來實現(xiàn)的；所以?BlockingQueue?的源碼其實可以當(dāng)成鎖的應(yīng)用示例來查看；同時 JDK 也為我們提供了多種不同功能的隊列：

• ArrayBlockingQueue?：基于數(shù)組的有界隊列；

• LinkedBlockingQueue?：基于鏈表的×××隊列（可以設(shè)置容量）；

• PriorityBlockingQueue?：基于二叉堆的×××優(yōu)先級隊列；

• DelayQueue?：基于 PriorityBlockingQueue 的×××延遲隊列；

• SynchronousQueue?：無容量的阻塞隊列（Executors.newCachedThreadPool() 中使用的隊列）；

• LinkedTransferQueue?：基于鏈表的×××隊列；

接下來我們就對最常用的?ArrayBlockingQueue?和?LinkedBlockingQueue?進(jìn)行分析；

二、 ArrayBlockingQueue 源碼分析

1. 結(jié)構(gòu)概述

public?class?ArrayBlockingQueue<E>?extends?AbstractQueue<E>?implements?BlockingQueue<E>,?java.io.Serializable?{????final?Object[]?items;???????????????//?容器數(shù)組
????int?takeIndex;??????????????????????//?出隊索引
????int?putIndex;???????????????????????//?入隊索引
????int?count;??????????????????????????//?排隊個數(shù)
????final?ReentrantLock?lock;???????????//?全局鎖
????private?final?Condition?notEmpty;???//?出隊條件隊列
????private?final?Condition?notFull;????//?入隊條件隊列
????...
}

ArrayBlockingQueue?的結(jié)構(gòu)如圖所示：

如圖所示，

• ArrayBlockingQueue?的數(shù)組其實是一個邏輯上的環(huán)狀結(jié)構(gòu)，在添加、取出數(shù)據(jù)的時候，并沒有像?ArrayList?一樣發(fā)生數(shù)組元素的移動（當(dāng)然除了?removeAt(final int removeIndex)）；

• 并且由?takeIndex?和?putIndex?指示讀寫位置；

• 在讀寫的時候還有兩個讀寫條件隊列；

下面我們就讀寫操作，對源碼簡單分析：

2. 入隊

public?void?put(E?e)?throws?InterruptedException?{
??checkNotNull(e);??final?ReentrantLock?lock?=?this.lock;
??lock.lockInterruptibly();??try?{????while?(count?==?items.length)??//?當(dāng)隊列已滿的時候放入?putCondition?條件隊列
??????notFull.await();???
????enqueue(e);??//?入隊
??}?finally?{
????lock.unlock();
??}
}

private?void?enqueue(E?x)?{??//?assert?lock.getHoldCount()?==?1;
??//?assert?items[putIndex]?==?null;
??final?Object[]?items?=?this.items;
??items[putIndex]?=?x;??//?插入隊列
??if?(++putIndex?==?items.length)?putIndex?=?0;??//?指針走一圈的時候復(fù)位
??count++;
??notEmpty.signal();??//?喚醒?takeCondition?條件隊列中等待的線程}

3. 出隊

public?E?take()?throws?InterruptedException?{??final?ReentrantLock?lock?=?this.lock;
??lock.lockInterruptibly();??try?{????while?(count?==?0)??//?當(dāng)隊列為空的時候，放入?takeCondition?條件
??????notEmpty.await();??
????return?dequeue();???//?出隊
??}?finally?{
????lock.unlock();
??}
}

private?E?dequeue()?{??//?assert?lock.getHoldCount()?==?1;
??//?assert?items[takeIndex]?!=?null;
??final?Object[]?items?=?this.items;??@SuppressWarnings("unchecked")
??E?x?=?(E)?items[takeIndex];??//?取出元素
??items[takeIndex]?=?null;??if?(++takeIndex?==?items.length)
????takeIndex?=?0;
??count--;??if?(itrs?!=?null)
????itrs.elementDequeued();
??notFull.signal();??//?取出元素后，隊列空出一位，所以喚醒?putCondition?中的線程
??return?x;
}

三、LinkedBlockingQueue 源碼分析

1. 結(jié)構(gòu)概述

public?class?LinkedBlockingQueue<E>?extends?AbstractQueue<E>?implements?BlockingQueue<E>,?java.io.Serializable?{??
??private?final?int?capacity;?//?默認(rèn)?Integer.MAX_VALUE
??private?final?AtomicInteger?count?=?new?AtomicInteger();?//?容量
??transient?Node<E>?head;??????????//?頭結(jié)點?head.item?==?null
??private?transient?Node<E>?last;??//?尾節(jié)點?last.next?==?null
??private?final?ReentrantLock?takeLock?=?new?ReentrantLock();??//?出隊鎖
??private?final?Condition?notEmpty?=?takeLock.newCondition();??//?出隊條件
??private?final?ReentrantLock?putLock?=?new?ReentrantLock();???//?入隊鎖
??private?final?Condition?notFull?=?putLock.newCondition();????//?入隊條件
??
??static?class?Node<E>?{
????E?item;
????Node<E>?next;
????Node(E?x)?{?item?=?x;?}
??}
}

LinkedBlockingQueue?的結(jié)構(gòu)如圖所示：

如圖所示，

• LinkedBlockingQueue?其實就是一個簡單的單向鏈表，其中頭部元素的數(shù)據(jù)為空，尾部元素的 next 為空；

• 因為讀寫都有競爭，所以在頭部和尾部分別有一把鎖；同時還有對應(yīng)的兩個條件隊列；

下面我們就讀寫操作，對源碼簡單分析：

2. 入隊

public?boolean?offer(E?e)?{??if?(e?==?null)?throw?new?NullPointerException();??final?AtomicInteger?count?=?this.count;??if?(count.get()?==?capacity)?return?false;??//?如果隊列已滿，直接返回失敗
??int?c?=?-1;
??Node<E>?node?=?new?Node<E>(e);??????????????//?將數(shù)據(jù)封裝為節(jié)點
??final?ReentrantLock?putLock?=?this.putLock;
??putLock.lock();??try?{????if?(count.get()?<?capacity)?{
??????enqueue(node);??????????????????????????//?入隊
??????c?=?count.getAndIncrement();??????if?(c?+?1?<?capacity)???????????????????//?如果隊列未滿，則繼續(xù)喚醒?putCondition?條件隊列
????????notFull.signal();
????}
??}?finally?{
????putLock.unlock();
??}??if?(c?==?0)???????????//?如果添加之前的容量為0，說明在出隊的時候有競爭，則喚醒?takeCondition
????signalNotEmpty();???//?因為是兩把鎖，所以在喚醒?takeCondition的時候，還需要獲取?takeLock
??return?c?>=?0;
}

private?void?enqueue(Node<E>?node)?{??//?assert?putLock.isHeldByCurrentThread();
??//?assert?last.next?==?null;
??last?=?last.next?=?node;??//?連接節(jié)點，并設(shè)置尾節(jié)點}

3. 出隊

public?E?take()?throws?InterruptedException?{
??E?x;??int?c?=?-1;??final?AtomicInteger?count?=?this.count;??final?ReentrantLock?takeLock?=?this.takeLock;
??takeLock.lockInterruptibly();??try?{????while?(count.get()?==?0)?{???//?如果隊列為空，則加入?takeCondition?條件隊列
??????notEmpty.await();
????}
????x?=?dequeue();???????????????//?出隊
????c?=?count.getAndDecrement();????if?(c?>?1)
??????notEmpty.signal();?????????//?如果隊列還有剩余，則繼續(xù)喚醒?takeCondition?條件隊列
??}?finally?{
????takeLock.unlock();
??}??if?(c?==?capacity)?????????????//?如果取之前隊列是滿的，說明入隊的時候有競爭，則喚醒?putCondition
????signalNotFull();?????????????//?同樣注意是兩把鎖
??return?x;
}

private?E?dequeue()?{??//?assert?takeLock.isHeldByCurrentThread();
??//?assert?head.item?==?null;
??Node<E>?h?=?head;
??Node<E>?first?=?h.next;
??h.next?=?h;?//?help?GC???//?將next引用指向自己，則該節(jié)點不可達(dá)，在下一次GC的時候回收
??head?=?first;
??E?x?=?first.item;
??first.item?=?null;??return?x;
}

四、ABQ、LBQ 對比

根據(jù)以上的講解，我們可以逐步分析出一些不同，以及在不同場景隊列的選擇：

1. 結(jié)構(gòu)不同

• ABQ：基于數(shù)組，有界，一把鎖；

• LBQ：基于鏈表，×××，兩把鎖；

內(nèi)存分配

• ABQ：隊列空間預(yù)先初始化，受堆空間影響小，穩(wěn)定性高；

• LBQ：隊列空間動態(tài)變化，受對空間影響大，穩(wěn)定性差；

入隊、出隊效率

• ABQ：數(shù)據(jù)直接賦值，移除；隊列空間重復(fù)使用，效率高；

• LBQ：數(shù)據(jù)需要包裝為節(jié)點；需開辟新空間，效率低；

競爭方面

• ABQ：出入隊共用一把鎖，相互影響；競爭嚴(yán)重時效率低；

• LBQ：出入隊分用兩把鎖，互不影響；競爭嚴(yán)重時效率影響小；

所以在這里并不能簡單的給出詳細(xì)的數(shù)據(jù)，證明哪個隊列更適合什么場景，最好是結(jié)合實際使用場景分析。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

當(dāng)前標(biāo)題：JDK源碼分析（11）之BlockingQueue相關(guān)-創(chuàng)新互聯(lián)
標(biāo)題鏈接：http://vcdvsql.cn/article40/hdcho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、域名注冊、動態(tài)網(wǎng)站、網(wǎng)站收錄、品牌網(wǎng)站制作、定制網(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)