Java阻塞隊列

来源:https://www.cnblogs.com/HuiH/archive/2019/11/08/11823215.html

一、阻塞隊列:用於保存等待執行的任務。在阻塞隊列中,線程阻塞的兩種情況: 1.當隊列中沒有數據的情況下,消費者端的所有線程都會被自動阻塞(掛起),直到有數據放入隊列。 2.當隊列中填滿數據的情況下, 生產者端的所有線程都會被自動阻塞,知道隊列中有空位置,線程被自動喚醒。 二、阻塞隊列的主要方法 拋出 ...


一、阻塞隊列:用於保存等待執行的任務。在阻塞隊列中,線程阻塞的兩種情況:

  1.當隊列中沒有數據的情況下,消費者端的所有線程都會被自動阻塞(掛起),直到有數據放入隊列。

  

  2.當隊列中填滿數據的情況下, 生產者端的所有線程都會被自動阻塞,知道隊列中有空位置,線程被自動喚醒。

  

二、阻塞隊列的主要方法

  拋出異常:拋出一個異常;

  特殊值:返回一個特殊值(null或false,視情況而定)

  阻塞:在成功操作之前,一直阻塞線程

  超時:放棄前只在最大的時間內阻塞

插入操作

  1)public abstract boolean add(E paramE):將指定元素插入此隊列中(如果立即可行且不會違反容量限制),成功是返回true,如果當前沒有可用空間,則拋出異常。如果鈣元素是null,則會拋出NullPointerException異常。

  2)public abstract boolean offer(E paramE):將指定元素插入此隊列中(如果立即可行且不會違反容量限制),成功時返回true,如果當前沒有可用的空間,則返回false。

  3)public abstract void put(E paramE)throws InterruptedExcaption:將指定元素插入隊列中,將等待可用的空間(如果有必要)。

 1 public void put(E paramE) throws InterruptedException {
 2      checkNotNull(paramE);
 3      ReentrantLock  localReentrantLock = this.lock;
 4      localReentrantLock.lockInterruptibly();
 5   try {
 6          while (this.count == this.items.length)
 7          this.notFull.await();//如果隊列滿了,則線程阻塞等待
 8          enqueue(paramE);
 9          localReentrantLock.unlock();
10      } finally {
11          localReentrantLock.unlock();
12      }
13  }

  4)offer(E o,long timeout, TimeUnit unit):可以設定等待的時間,如果指定的時間內,還不能往隊列中加入BlockingQueue,則返回失敗。

獲取數據操作

  1)poll(time):取走BlockingQueue里排在首位的對象,若不能立即取出,則可以等time參數規定的時間,取不到時返回null;

  2)poll(long timeout,TimeUnit unit):從BlockingQueue取出一個隊首的對象,如果在指定的時間內,隊列一旦有數據可取,則立即返回隊列中的數據。否則直到時間超時還沒有數據可取,返回失敗;

  3)take():取走BlockingQueue里排在首位的對象,若BlockingQueue為空,阻斷進入等待狀態直到BlockingQueue有新的數據被加入;

  4)drainTo():一次性從BlockingQueue獲取所有可用的數據對象(還可以指定獲取數據的個數),通過該方法,可以提升獲取數據效率,不需要多次分批加鎖或釋放鎖。

三、Java中的阻塞隊列

  1. ArrayBlockingQueue:由數組結構實現的有界阻塞隊列。此隊列按照先進先出(FIFO)的原則對元素進行排序。預設情況下不保證訪問者公平的訪問隊列,所謂的公平訪問隊列是指阻塞的所有生產者線程或消費者線程,當隊列可用時,可以按照阻塞的先後順序訪問隊列,即先阻塞的生產者線程,可以先往隊列里插入元素,先阻塞的消費者線程,可以先從隊列里獲取元素。通常情況下為了保證公平性會降低吞吐量。我們可以使用以下代碼創建一個公平的阻塞隊列:

    ArrayBlockingQueue fairQueue = new ArrayBlockingQueue(1000,ture);

  2. LinkedBlockingQueue:由鏈表結構組成的有界阻塞隊列。同ArrayBlockingQueue類似,此隊列按照先進先出(FIFO)的原則對元素進行排序。而LinkedBlockingQueue之所以能夠高效地處理併發數據,還因為其對於生產者端和消費者端分別採用了獨立的鎖來控制數據同步,在高併發的情況下生產者和消費者可以並行地操作隊列中的數據,以此來提高整個隊列的併發性能。吞吐量通常要高於ArrayBlockingQueue。

    LinkedBlockingQueue會預設一個類似無限大小的容量(Integer.MAX_VALUE)。

  3. PriorityBlockingQueue:支持優先順序排序的無界阻塞隊列。預設情況下元素採取升序排列。可以自定義實現compareTo() 方法來指定元素進行排序規則,或初始化PriorityBlockingQueue時,制定構造函數Comparator來對元素進行排序。需要註意的是不能保證同優先順序元素的順序。

  4. DelayQueue:使用優先順序隊列實現的支持延時獲取元素的無界阻塞隊列。隊列使用PriorityQueue來實現。隊列中的元素必須實現Delayed介面,在創建元素是可以指定多久才能從隊列中獲取當前元素。只有在延遲期滿時才能從隊列中提取元素。我們可以將DelayQueue運用在以下場景中:

    1)緩存系統的設計:可以用DelayQueue保存緩存元素的有效期,使用一個線程迴圈查詢DelayQueue,一旦能從DelayQueue中獲取元素時,表示緩存有效期到了。

    2)定時任務調度:使用DelayQueue保存當天將會執行的任務和執行時間,一旦從DelayQueue中獲取到任務就開始執行,從比如TimerQueue就是使用DelayQueue實現的。

  5. SynchronousQueue:是一個不存儲元素的阻塞隊列。每個插入操作必須等到另一個線程調用移除操作,否則插入操作一直處於阻塞狀態。SynchronousQueue負責把生產者線程處理的數據直接傳遞給消費者線程。隊列本身並不存儲任何元素,非常適合於傳遞性場景,比如在一個線程中使用的數據,傳遞給另外一個線程使用,SynchronousQueue的吞吐量高於LinkedBlockingQueue和ArrayBlockingQueue。

  6. LinkedTransferQueue:由鏈表結構組成的無界阻塞隊列。相對於其他阻塞隊列,LinkedTransferQueue多了tryTransfer和transfer方法。

    1)transfer方法:如果當前有消費者正在等待接收元素(消費者使用take方法或帶時間限制的poll方法時),transfer方法可以把生產者傳入的元素立刻transfer(傳輸)給消費者。如果沒有消費者在等待接收元素,transfer方法會將元素存放在隊列的tail節點,並等待該元素被消費者消費了才返回。

    2)tryTransfer方法:是用來試探下生產者傳入的元素是否能直接傳給消費者。如果沒有消費者等待接收元素,則返回false。tryTransfer方法與transfer方法的區別是tryTransfer方法無論消費者是否接收,方法立即返回,而transfer方法是必須等到消費者消費了才返回。對於帶有時間限制的tryTransfer(E o,long timeout,TimeUnit unit)方法,則是試圖把生產者傳入的元素直接傳給消費者,但是如果沒有消費者消費該元素則等待指定的時間再返回,如果超時還沒消費元素,則返回false,如果在超市時間內消費了元素,則返回true。

  7.LinkedBlockingDeque:由鏈表結構組成的雙向阻塞隊列。所謂雙向隊列指可以從隊列的兩端插入和移除元素。雙端隊列因為多了一個操作隊列的入口,在多線程同時入隊時,也就減少了一半的競爭。相比其他的阻塞隊列,LinkedBlockingDeque多了addFirst,addLast,offerFirst,offerLast,peekFirst,peekLast等方法,以First單詞結尾的方法,表示插入、獲取(peek)或移除雙端隊列第一個元素。以Last單詞結尾的方法,表示插入、獲取或移除雙端隊列的最後一個元素。另外插入方法add等同於addLast,移除方法remove等同於removeFirst。但是take方法卻等同於takeFirst,使用時還是用帶有First和Last尾碼的方法更清楚。在初始化LinkedBlockingQueue時可以設置容量防止其過度膨脹。另外雙向阻塞隊列可以運用在“工作竊取”模式中。


您的分享是我們最大的動力!

更多相關文章
  • 通過前面2篇文章我們搭建了SW的基礎環境,監控了微服務,能瞭解所有服務的運行情況。但是當出現服務響應慢,介面耗時嚴重時我們需要立即定位到問題,這就需要我們今天的主角 監控告警,同時此篇也是SW系列的最後一篇。 UI參數 首先我們認識一下SW DashBoard上的幾個關鍵參數,如下圖所示 告警配置 ...
  • 一.docker簡介 1、docker定義:docker是一個用來裝應用的容器,就像杯子可以裝水,筆筒可以裝筆,書包可以放書一樣。你可以把“Hello World!”放到docker中,也可以把網站放到docker中,你可以把任何你想到的程式放到docker中。 2、docker思想: (1)集裝箱 ...
  • 智力題目有三個容積分別為3升、5升、8升的水桶,其中容積為8升的水桶中裝滿了水,容積為3升和容積為5升的水桶都是空的。三個水桶都沒有刻度,現在需要將大水桶中的8升水等分成兩份,每份都是4升水,附加條件是只能這三個水桶,不能藉助其他輔助容器。“恩,是的,這是一個很經典的問題。”“然而,我們並不能想全, ...
  • 今天,在Anaconda prompt啟動python遇到瞭如下錯誤: UnicodeDecodeError: ‘gbk’ codec can’t decode byte 0xaf in position 553: illegal multibyte sequence 看了看出錯跟蹤,查看瞭如下位置 ...
  • 許多小伙伴對於java中的三種初始化塊的執行順序一直感到頭疼,接下來我們就來分析一下這三種初始化塊到底是怎麼運行的。有些公司也會將這個問題作為筆試題目。 下麵通過一段代碼來看看創建對象時這麼初始化塊是如何運行的 package com.hxy; public class CodeBlock{ pub ...
  • 字元串或串(String)是由數字、字母、下劃線組成的一串字元。一般記為 s=“a1a2···an”(n>=0)。它是編程語言中表示文本的數據類型。在程式設計中,字元串(string)為符號或數值的一個連續序列,如符號串(一串字元)或二進位數字串(一串二進位數字)。 String類型你一定不陌生,畢 ...
  • 我們知道,swoole中有兩大進程,分別是 master 主進程和 manager 管理進程。 其中 master 主進程中會有一個主 reactor 線程和多個 reactor 線程,主要的作用就是用來維護TCP連接,處理網路IO,收發數據。 而 manager 管理進程,作用則是 fork 和管 ...
  • 1. random模塊 導入的是random模塊,格式是: import random 1.1 隨機小數 取隨機小數 : 數學計算。 print(random.random()) # 取0-1之間的小數print(random.uniform(1,2)) # 取1-2之間的小數 1.2 隨機整數 取 ...
一周排行
  • C 語法糖——持續更新 1. return的switch寫法 ...
  • 0. 前言 繼上一篇,以及上上篇,我們對SqlSugar有了一個大概的認識,但是這並不完美,因為那些都是理論知識,無法描述我們工程開發中實際情況。而這一篇,將帶領小伙伴們一起試著寫一個能在工程中使用的模板類。 1. 創建一個Client SqlSugar在操作的時候需要一個Client,用來管理數據 ...
  • 1 class Program 2 { 3 static void Main(string[] args) 4 { 5 //數組:長度不可變,類型單一 6 //ArrayList集合:長度可以任意改變,類型可以不單一 7 8 //創建一個ArrayList對象 9 ArrayList mylist ...
  • .NET 程式下銳浪報表 (Grid++ Report) 的綠色發佈指南 在銳浪報表官方為 CSharp 編寫的開發文檔:“在C#與VB.NET中開始使用說明.txt” 中,關於發佈項目是這麼描述的: ★發佈你的項目,用VS.NET製作安裝程式:1、先創建安裝項目:在解決方案資源管理器的根節點上點右 ...
  • 執行代碼清理時,可以點擊那個掃把小圖片,會按照預設的第一種配置文件來自動修複。也可以點擊下拉三角符合,選擇不同的配置文件,然後進行修複。或者快捷鍵Ctrl+K,Ctrl+E。 針對每一項配置的說明: 刪除不必要的using 儘可能將私有欄位設置為只讀 刪除不必要的類型轉換(針對強類型轉換),像Con ...
  • 1.概念簡述 (1)AR模型 AR 模型(auto regressive model)自回歸模型,模型參量法高解析度譜分析方法之一,也是現代譜估計中常用的模型。 用AR模型法求信具體作法是: ①選擇AR模型,在輸入是衝激函數或白雜訊的情況下,使其輸出等於所研究的信號,至少,應是對該信號的一個好的近似 ...
  • 4.元組 元組的主要特性為: 1.元組在創建之後,具有不可以更改的特性,因此不能直接給元組的元素賦值 2.元組的元素類型可以為任意類型,如字典、字元串、列表等 3.元組常用於在程式的整個生命周期中都不變的場景中 4.1 常用方法 元組大小和內容在定義賦值之後,就不可更改,常用的方法如下所示: cou ...
  • 老孟導讀:今天分享一個類似“孔雀開屏”的動畫效果,打開新的頁面時,新的頁面從屏幕右上角以圓形逐漸打開到全屏。 先來看下具體的效果 不知道這種效果大家叫什麼名字?如果有更合適的名字可以在評論處告訴我,下麵來說下如何實現此效果。 在使用Navigator進入一個新的頁面時,通常用法如下: 就包含了切換頁 ...
  • hashCode() 和equals() 方法的重要性體現在什麼地方? Java中的HashMap使用hashCode()和equals()方法設置值,根據鍵獲取值的時候也會用到這兩個方法。 怎樣 設置 的值? hashCode()獲得 hash值。而hash值用來確定hashmap中內部 Node ...
  • IDEA一些不錯的插件分享 目錄 IDEA一些不錯的插件分享 插件集合 CamelCase Translation LiveEdit MarkDown Navigator Jrebel CheckStyle IDEA Alibaba Java Coding Guidelines Ideavim Ma ...