阻塞队列

Love The Way You Lie 2022-08-19 08:54 160阅读 0赞

阻塞队列是当队列为空并且你想出队时的一种队列，或者你想进入队列，但是队列已经满了。一个线程试图在一个空队列里边出队的话就会阻塞，直到其他的线程进入队列。一个线程试图进入一个满队列的时候它也会阻塞直到队列中的其他线程出队列或者清空队列之后。

下边这个图展现了两个图通过一个队列如何进行合作的。

![Center][]

java5在 java.util.concurrent package包中有阻塞队列的实现，你可以在我的 java.util.concurrent.BlockingQueue指导中学习那个类。即使java5 已经有了阻塞队列的实现，了解实现背后的原理也是很有帮助的。

### 阻塞队列的实现 ###

阻塞队列的实现看起来很像 Bounded 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方法在队列大小等于限制大小的时候（0或者limit）调用notifyAll()。在调用的时候如果没有超过大小的限制，就不会有线程等待入队或者出队。

[Center]: /images/20220731/2793eeb23ddf49db8dbb1d7ad9fd89cc.png

发表评论取消回复

表情：

评论列表（有 0 条评论，160人围观）

还没有评论，来说两句吧...

相关阅读

相关阻塞队列

① 阻塞队列的介绍阻塞队列是一个队列（`FIFO`）。当阻塞队列是空时，从队列中获取元素的操作将被阻塞；当阻塞队列是满时，往队列里添加元素的操作将被阻塞。 ② 阻塞队列的

灰太狼/ 2022年11月05日 03:09/ 0 赞/ 168 阅读

相关 BlockingQueue阻塞队列

BlockingQueue简介 Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类

朱雀/ 2022年09月08日 00:16/ 0 赞/ 236 阅读

相关 BlockingQueue阻塞队列

BlockingQueue简介阻塞队列，顾名思义，首先它是一个队列, 通过一个共享的队列，可以使得数据由队列的一端输入，从另外一端输出；当队列是空的，从队列中获取元

落日映苍穹つ/ 2022年08月28日 13:49/ 0 赞/ 248 阅读

相关阻塞队列

阻塞队列是当队列为空并且你想出队时的一种队列，或者你想进入队列，但是队列已经满了。一个线程试图在一个空队列里边出队的话就会阻塞，直到其他的线程进入队列。一个线程试图进入一个满队

Love The Way You Lie/ 2022年08月19日 08:54/ 0 赞/ 161 阅读

相关等待队列阻塞非阻塞

阻塞设备驱动不阻塞，用户想获取设备资源只能不停的查询，这无谓的消耗CPU资源。而阻塞访问，不能获取资源的进程将进入休眠，它将CPU资源“礼让”给其他进程唤醒进程的地

怼烎@/ 2022年06月15日 10:55/ 0 赞/ 210 阅读

相关 AQS阻塞队列

AQS阻塞队列管理资料 [http://blog.csdn.net/wangyangzhizhou/article/details/42048453]

绝地灬酷狼/ 2022年05月29日 00:29/ 0 赞/ 192 阅读

相关阻塞队列

阻塞队列阻塞队列：最常见的业务场景就是生产者不断生产任务放进阻塞队列中，消费者不断从阻塞队列中获取任务；当阻塞队列中填满数据时，所有生产者端的线程自动阻塞，当阻塞

傷城~/ 2022年05月27日 05:48/ 0 赞/ 193 阅读

相关队列阻塞

阻塞队列 import java.util.LinkedList; import java.util.List; public c

青旅半醒/ 2022年04月15日 05:51/ 0 赞/ 230 阅读

相关阻塞队列

BlockingQueue是一个继承自Queue的接口，在Queue的队列基础上增加了阻塞操作，在BlockingQueue为空时从队头取数据将会被阻塞，因为此时还没有数据可取

女爷i/ 2022年02月04日 22:37/ 0 赞/ 244 阅读

相关阻塞队列BlockingQueue

> 固定长度的队列往里放数据，如果放满了还要放，阻塞式队列就会等待，直到有数据取出，空出位置后才继续放；非阻塞式队列不能等待就只能报错了。多线程环境中，通过队列可以很容易实

小咪咪/ 2021年09月29日 15:16/ 0 赞/ 399 阅读