java佇列——queue詳細分析
Queue: 基本上,一個佇列就是一個先入先出(FIFO)的資料結構
Queue介面與List、Set同一級別,都是繼承了Collection介面。LinkedList實現了Deque接 口。
Queue的實現
1、沒有實現的阻塞介面的LinkedList: 實現了java.util.Queue介面和java.util.AbstractQueue介面
內建的不阻塞佇列: PriorityQueue 和 ConcurrentLinkedQueue
PriorityQueue 和 ConcurrentLinkedQueue 類在 Collection Framework 中加入兩個具體集合實現。
PriorityQueue 類實質上維護了一個有序列表。加入到 Queue 中的元素根據它們的天然排序(通過其 java.util.Comparable 實現)或者根據傳遞給建構函式的 java.util.Comparator 實現來定位。
ConcurrentLinkedQueue 是基於連結節點的、執行緒安全的佇列。併發訪問不需要同步。因為它在佇列的尾部新增元素並從頭部刪除它們,所以只要不需要知道佇列的大 小, ConcurrentLinkedQueue 對公共集合的共享訪問就可以工作得很好。收集關於佇列大小的資訊會很慢,需要遍歷佇列。
2)實現阻塞介面的:
java.util.concurrent 中加入了 BlockingQueue 介面和五個阻塞佇列類。它實質上就是一種帶有一點扭曲的 FIFO 資料結構。不是立即從佇列中新增或者刪除元素,執行緒執行操作阻塞,直到有空間或者元素可用。
五個佇列所提供的各有不同:
* ArrayBlockingQueue :一個由陣列支援的有界佇列。
* LinkedBlockingQueue :一個由連結節點支援的可選有界佇列。
* PriorityBlockingQueue :一個由優先順序堆支援的無界優先順序佇列。
* DelayQueue :一個由優先順序堆支援的、基於時間的排程佇列。
* SynchronousQueue
下表顯示了jdk1.5中的阻塞佇列的操作:
add 增加一個元索 如果佇列已滿,則丟擲一個IIIegaISlabEepeplian異常
remove 移除並返回佇列頭部的元素 如果佇列為空,則丟擲一個NoSuchElementException異常
element 返回佇列頭部的元素 如果佇列為空,則丟擲一個NoSuchElementException異常
offer 新增一個元素並返回true 如果佇列已滿,則返回false
poll
peek 返回佇列頭部的元素 如果佇列為空,則返回null
put 新增一個元素 如果佇列滿,則阻塞
take 移除並返回佇列頭部的元素 如果佇列為空,則阻塞
remove、element、offer 、poll、peek 其實是屬於Queue介面。
阻塞佇列的操作可以根據它們的響應方式分為以下三類:aad、removee和element操作在你試圖為一個已滿的佇列增加元素或從空佇列取得元素時 丟擲異常。當然,在多執行緒程式中,佇列在任何時間都可能變成滿的或空的,所以你可能想使用offer、poll、peek方法。這些方法在無法完成任務時 只是給出一個出錯示而不會丟擲異常。
注意:poll和peek方法出錯進返回null。因此,向佇列中插入null值是不合法的
最後,我們有阻塞操作put和take。put方法在佇列滿時阻塞,take方法在佇列空時阻塞。
LinkedBlockingQueue的容量是沒有上限的(說的不準確,在不指定時容量為Integer.MAX_VALUE,不要然的話在put時怎麼會受阻呢),但是也可以選擇指定其最大容量,它是基於連結串列的佇列,此佇列按 FIFO(先進先出)排序元素。
ArrayBlockingQueue在構造時需要指定容量, 並可以選擇是否需要公平性,如果公平引數被設定true,等待時間最長的執行緒會優先得到處理(其實就是通過將ReentrantLock設定為true來 達到這種公平性的:即等待時間最長的執行緒會先操作)。通常,公平性會使你在效能上付出代價,只有在的確非常需要的時候再使用它。它是基於陣列的阻塞迴圈隊 列,此佇列按 FIFO(先進先出)原則對元素進行排序。
PriorityBlockingQueue是一個帶優先順序的 佇列,而不是先進先出佇列。元素按優先順序順序被移除,該佇列也沒有上限(看了一下原始碼,PriorityBlockingQueue是對 PriorityQueue的再次包裝,是基於堆資料結構的,而PriorityQueue是沒有容量限制的,與ArrayList一樣,所以在優先阻塞 佇列上put時是不會受阻的。雖然此佇列邏輯上是無界的,但是由於資源被耗盡,所以試圖執行新增操作可能會導致 OutOfMemoryError),但是如果佇列為空,那麼取元素的操作take就會阻塞,所以它的檢索操作take是受阻的。另外,往入該佇列中的元 素要具有比較能力。
DelayQueue(基於PriorityQueue來實現的)是一個存放Delayed 元素的無界阻塞佇列,只有在延遲期滿時才能從中提取元素。該佇列的頭部是延遲期滿後儲存時間最長的 Delayed 元素。如果延遲都還沒有期滿,則佇列沒有頭部,並且poll將返回null。當一個元素的 getDelay(TimeUnit.NANOSECONDS) 方法返回一個小於或等於零的值時,則出現期滿,poll就以移除這個元素了。此佇列不允許使用 null 元素。
一個例子:
package com.yao; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class BlockingQueueTest { /** 定義裝蘋果的籃子 */ public static class Basket{ // 籃子,能夠容納3個蘋果 BlockingQueue<String> basket = new ArrayBlockingQueue<String>(3); // 生產蘋果,放入籃子 public void produce() throws InterruptedException{ // put方法放入一個蘋果,若basket滿了,等到basket有位置 basket.put("An apple"); } // 消費蘋果,從籃子中取走 public String consume() throws InterruptedException{ // get方法取出一個蘋果,若basket為空,等到basket有蘋果為止 String apple = basket.take(); return apple; } public int getAppleNumber(){ return basket.size(); } } // 測試方法 public static void testBasket() { // 建立一個裝蘋果的籃子 final Basket basket = new Basket(); // 定義蘋果生產者 class Producer implements Runnable { public void run() { try { while (true) { // 生產蘋果 System.out.println("生產者準備生產蘋果:" + System.currentTimeMillis()); basket.produce(); System.out.println("生產者生產蘋果完畢:" + System.currentTimeMillis()); System.out.println("生產完後有蘋果:"+basket.getAppleNumber()+"個"); // 休眠300ms Thread.sleep(300); } } catch (InterruptedException ex) { } } } // 定義蘋果消費者 class Consumer implements Runnable { public void run() { try { while (true) { // 消費蘋果 System.out.println("消費者準備消費蘋果:" + System.currentTimeMillis()); basket.consume(); System.out.println("消費者消費蘋果完畢:" + System.currentTimeMillis()); System.out.println("消費完後有蘋果:"+basket.getAppleNumber()+"個"); // 休眠1000ms Thread.sleep(1000); } } catch (InterruptedException ex) { } } } ExecutorService service = Executors.newCachedThreadPool(); Producer producer = new Producer(); Consumer consumer = new Consumer(); service.submit(producer); service.submit(consumer); // 程式執行10s後,所有任務停止 try { Thread.sleep(10000); } catch (InterruptedException e) { } service.shutdownNow(); } public static void main(String[] args) { BlockingQueueTest.testBasket(); } }
出處:https://www.cnblogs.com/lemon-flm/p/7877898.html
相關推薦
java佇列——queue詳細分析
Queue: 基本上,一個佇列就是一個先入先出(FIFO)的資料結構Queue介面與List、Set同一級別,都是繼承了Collection介面。LinkedList實現了Deque接 口。Queue的實現1、沒有實現的阻塞介面的LinkedList: 實現了java.uti
(二)Java集合專題-詳細分析HashtableJDK1.8集合底層實現的思想
(一)詳細分析Hashtable1.8集合底層實現的思路和原始碼 (1)先來看一下Hashtable的結構圖:首先他和HashMap結構都是一樣的,都是由陣列和連結串列進行實現的(在JDK1.8是用陣列和連結串列和紅黑樹的),每一個數組裡面存的是一個Entry節點,節點裡面有Key、
(一)Java集合專題-詳細分析HashMap集合底層實現的思想
詳細分析HashMap JDK1.8集合底層實現的思想和原理 (1)先來看一下整個Map家族的整體都是怎麼樣的關係 (2)先了解一下HashMap的基本特性: 1.實現了Map介面,裡面的方法全部被H
java佇列Queue方法
Queue是一種很常見的資料結構型別,在java裡面Queue是一個介面,它只是定義了一個基本的Queue應該有哪些功能規約。實際上有多個Queue的實現,有的是採用線性表實現,有的基於連結串列實現。還有的適用於多執行緒的環境。java中具有Queue功能的
java佇列(Queue)用法總結
1.佇列的特點 佇列是一種比較特殊的線性結構。它只允許在表的前端(front)進行刪除操作,而在表的後端(rear)進行插入操作。進行插入操作的端稱為隊尾,進行刪除操作的端稱為隊頭。 佇列中最先插入的元素也將最先被刪除,對應的最後插入的元素將最後被刪除。因此佇列又稱為“先進先出”(F
淺談Java佇列Queue
佇列Queue就是一個先進先出的資料結構,與List、Set同一級別,繼承了Collection介面。 一、Queue的實現
詳細分析棧和佇列的資料結構的實現過程(Java 實現)
[TOC] # 棧和佇列的資料結構的實現過程(Java 實現) ## 棧的資料結構的實現 ### 棧的基礎知識回顧 1. 棧是一種**線性結構**。 2. **相比陣列,棧對應的操作是陣列的子集。** - 也就是棧可基於陣列實現,可以將棧看成一種特殊的陣列。 3. **棧只能從一端新增元素,
Java內部類持有外部類的引用詳細分析與解決方案
調用 lai urn star keyword inner android get sta 在Java中內部類的定義與使用一般為成員內部類與匿名內部類,他們的對象都會隱式持有外部類對象的引用,影響外部類對象的回收。 GC只會回收沒有被引用或者根集不可到達的對象(取決於GC算
Java類的加載和對象創建流程的詳細分析
spa java類 parent str pac run 實例 public font 相信我們在面試Java的時候總會有一些公司要做筆試題目的,而Java類的加載和對象創建流程的知識點也是常見的題目之一。接下來通過實例詳細的分析一下: package com.test;p
關於使用Java中的for循環和if語句打印空心菱形的詳細分析(也算是通過重新梳理一遍來加深自己的理解吧!)
初始化 span 賦值 公式 數列 image 一中 more for循環 啥也別說了,小二,先上代碼: (圖一) 如以上代碼所示,由於程序的執行順序是從左至右,由上而下的,所以當我們想要在DOS窗口打印 一個空心菱形如圖二所示 (圖二) 時:我們可以將其分成上下兩部分,
Java佇列(Queue)用法
佇列是一種特殊的線性表,它只允許在表的前端進行刪除操作,而在表的後端進行插入操作。 LinkedList類實現了Queue介面,因此我們可以把LinkedList當成Queue來用。 以下例項演示了佇列(Queue)的用法: import java.util.LinkedList; im
Java中使用佇列Queue
示例程式碼: Queue<Integer> queue = new LinkedList<Integer>(); for (int i = 1; i <= 100; i ++) queue.add(i); while (queue
java 佇列同步器AbstractQueuedSynchronizer(AQS)實現分析
AQS 內部使用一個int變數state表示同步狀態。 內部使用一個隱式的FIFO佇列(並沒有宣告這樣一個佇列,只是通過每個節點記錄它的上下節點來從邏輯上產生一個佇列)來完成阻塞執行緒的排隊。 這個FIFO佇列在 AQS 中被定義為一個內部類Node:
Java併發佇列Queue
ConcurrentLinkedQueue BlockingQueue介面 Deque雙端佇列 併發Queue 在併發佇列上JDK提供了兩套實現,一個是以ConcurrentLinkedQueue為代表的高效能佇列,一個是
java的根類Object詳細分析
Object類是Java中其他所有類的祖先,沒有Object類Java面向物件無從談起。作為其他所有類的基類,Object具有哪些屬性和行為,是Java語言設計背後的思維體現。 Object類位於java.lang包中,ja
基於Java 生產者消費者模式(詳細分析)
多多支持 final 睡眠狀態 生產線 兩種模式 while語句 interrupt count 自己的 本文目錄:1.等待、喚醒機制的原理2.Lock和Condition3.單生產者單消費者模式4.使用Lock和Condition實現單生產單消費模式5.多生產多消費模式(
java動態代理實現與原理詳細分析(【轉載】By--- Gonjan )
【轉載】By--- Gonjan 關於Java中的動態代理,我們首先需要了解的是一種常用的設計模式--代理模式,而對於代理,根據建立代理類的時間點,又可以分為靜態代理和動態代理。 一、代理模式
java動態代理實現與原理詳細分析(【轉載】By--- Gonjan )
sleep class 實施 div prot stack 註意 san 由於 【轉載】By--- Gonjan 關於Java中的動態代理,我們首先需要了解的是一種常用的設計模式--代理模式,而對於代理,根據創建代理類的時間點,又可以分為靜態代理和動態代理。
資料結構之 佇列(Queue)的實現 Java
佇列 - 實現 為了實現佇列,我們可以使用動態陣列和指向佇列頭部的索引。 如上所述,佇列應支援兩種操作:入隊和出隊。入隊會向佇列追加一個新元素,而出隊會刪除第一個元素。 所以我們需要一個索引來指出起點。 這是一個供你參考的實現: // "static void mai
Java中陣列氣泡排序、選擇排序、二分查詢的詳細分析
前言:儘管在實際開發中,我們通過Arrays工具類就可以便利地對陣列進行排序和查詢的操作,但是掌握氣泡排序、選擇排序、二分法查詢的思想對於程式設計來說還是極其重要的,在很多場景都會用到。希望通過這篇部落格的分析能給大家帶來收穫。 主題:陣列的排序和查詢 1、冒泡法排序: