Java阻塞隊列的實現

付倫發(fā)布于2019-08-14 11:39 / 1892人閱讀

摘要：盡管中已經包含了阻塞隊列的官方實現，但是熟悉其背后的原理還是很有幫助的。阻塞隊列的實現阻塞隊列的實現類似于帶上限的的實現。下面是阻塞隊列的一個簡單實現必須注意到，在和方法內部，只有隊列的大小等于上限或者下限時，才調用方法。

阻塞隊列與普通隊列的區(qū)別在于，當隊列是空的時，從隊列中獲取元素的操作將會被阻塞，或者當隊列是滿時，往隊列里添加元素的操作會被阻塞。試圖從空的阻塞隊列中獲取元素的線程將會被阻塞，直到其他的線程往空的隊列插入新的元素。同樣，試圖往已滿的阻塞隊列中添加新元素的線程同樣也會被阻塞，直到其他的線程使隊列重新變得空閑起來，如從隊列中移除一個或者多個元素，或者完全清空隊列，下圖展示了如何通過阻塞隊列來合作：

線程1往阻塞隊列中添加元素，而線程2從阻塞隊列中移除元素

從5.0開始，JDK在java.util.concurrent包里提供了阻塞隊列的官方實現。盡管JDK中已經包含了阻塞隊列的官方實現，但是熟悉其背后的原理還是很有幫助的。

阻塞隊列的實現

阻塞隊列的實現類似于帶上限的Semaphore的實現。下面是阻塞隊列的一個簡單實現

public class BlockingQueue {

  private List queue = new LinkedList();
  private int  limit = 10;

  public BlockingQueue(int limit){
    this.limit = limit;
  }


  public synchronized void enqueue(Object item)
  throws InterruptedException  {
    while(this.queue.size() == this.limit) {
      wait();
    }
    if(this.queue.size() == 0) {
      notifyAll();
    }
    this.queue.add(item);
  }


  public synchronized Object dequeue()
  throws InterruptedException{
    while(this.queue.size() == 0){
      wait();
    }
    if(this.queue.size() == this.limit){
      notifyAll();
    }

    return this.queue.remove(0);
  }

}

必須注意到，在enqueue和dequeue方法內部，只有隊列的大小等于上限（limit）或者下限（0）時，才調用notifyAll方法。如果隊列的大小既不等于上限，也不等于下限，任何線程調用enqueue或者dequeue方法時，都不會阻塞，都能夠正常的往隊列中添加或者移除元素。

原文 Blocking Queues
翻譯：寒桐校對：方騰飛
via ifeve

GPU云服務器云服務器 java實現鏈式隊列開源消息隊列Java實現并發(fā)阻塞隊列阻塞隊列線程集

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉載請注明本文地址：http://m.hztianpu.com/yun/64045.html

什么是阻塞隊列？如何使用阻塞隊列來實現生產者-消費者模型？

摘要：什么是阻塞隊列阻塞隊列是一個在隊列基礎上又支持了兩個附加操作的隊列。阻塞隊列的應用場景阻塞隊列常用于生產者和消費者的場景，生產者是向隊列里添加元素的線程，消費者是從隊列里取元素的線程。由鏈表結構組成的無界阻塞隊列。什么是阻塞隊列？阻塞隊列是一個在隊列基礎上又支持了兩個附加操作的隊列。 2個附加操作：支持阻塞的插入方法：隊列滿時，隊列會阻塞插入元素的線程，直到隊列不滿。支持阻塞的...

jemygraw 2019-08-15 14:44 評論0 收藏0
java 隊列

摘要：是基于鏈接節(jié)點的線程安全的隊列。通過這些高效并且線程安全的隊列類，為我們快速搭建高質量的多線程程序帶來極大的便利。隊列內部僅允許容納一個元素。該隊列的頭部是延遲期滿后保存時間最長的元素。隊列簡述 Queue：基本上，一個隊列就是一個先入先出（FIFO）的數據結構Queue接口與List、Set同一級別，都是繼承了Collection接口。LinkedList實現了Deque接口。...

goji 2019-08-16 17:47 評論0 收藏0
Java知識點總結（Java容器-Queue）

摘要：知識點總結容器知識點總結容器接口與是在同一級別，都是繼承了接口。另一種隊列則是雙端隊列，支持在頭尾兩端插入和移除元素，主要包括。一個由鏈表結構組成的無界阻塞隊列。是一個阻塞的線程安全的隊列，底層實現也是使用鏈式結構。 Java知識點總結（Java容器-Queue） @(Java知識點總結)[Java, Java容器] Queue Queue接口與List、Set是在同一級別，都是繼承了...

hedzr 2019-08-16 12:37 評論0 收藏0
Java 隊列

摘要：隊列中有元素時，就說明有過期了，線程繼續(xù)執(zhí)行，然后元素出隊，根據相應的移除緩存。所以嚴格來說，雖然實現了隊列接口，但是它的目的卻并不是隊列，而是將生產者消費者線程配對。轉移隊列鏈式轉移隊列。引言本周在編寫短信驗證碼頻率限制切面的時候，經潘老師給的實現思路，使用隊列進行實現。看了看java.util包下的Queue接口，發(fā)現還從來沒用過呢！ Collection集合類接口，由它派生...

Pocher 2019-08-16 17:00 評論0 收藏0
Java并發(fā)編程筆記（一）

摘要：并發(fā)編程實戰(zhàn)水平很高，然而并不是本好書。一是多線程的控制，二是并發(fā)同步的管理。最后，使用和來關閉線程池，停止其中的線程。當線程調用或等阻塞時，對這個線程調用會使線程醒來，并受到，且線程的中斷標記被設置。《Java并發(fā)編程實戰(zhàn)》水平很高，然而并不是本好書。組織混亂、長篇大論、難以消化，中文翻譯也較死板。這里是一篇批評此書的帖子，很是貼切。俗話說：看到有這么多人罵你，我就放心了。然而知...

cnsworder 2019-08-15 14:19 評論0 收藏0