Java多线程拾遗(八) BlockingQueue阻塞队列

╰半橙微兮° 2023-02-14 10:54 26阅读 0赞

#### 使用场景 ####

队列一般适用于生产者与消费者之间交换数据。

而**生产者和消费者可能会发生数据处理速度不匹配**的情况。理想情况下，如果生产者产出数据的速度大于消费者消费的速度，并且当生产出来的数据累积到一定程度的时候，那么生产者必须暂停等待一下（阻塞生产者线程），以便等待消费者线程把累积的数据处理完毕。

总的来说，阻塞队列实现了两种场景下的功能：

*  当队列中**没有数据**的情况下，**消费者端的所有线程都会被自动阻塞**（挂起），直到有数据放入队列。
 *  当队列中**填满数据**的情况下，**生产者端的所有线程都会被自动阻塞**（挂起），直到队列中有空的位置，线程被自动唤醒

#### BlockingQueue 的概念 ####

BlockingQueue继承于Queue接口，字面意思是"阻塞队列".  
![在这里插入图片描述][20200602181119290.png]

#### 入队方法说明 ####

向队列中插入元组，如果队列是满的，抛出异常。

boolean add(E e);

向队列中插入元组，如果队列是满的，不抛出异常。

boolean offer(E e);

向队列中插入元组，如果队列是满的，阻塞，直到有空间。

void put(E e) throws InterruptedException;

向队列中插入元组，如果队列是满的，阻塞指定的时间，直到有空间时，进行插入，如果在指定的时间没有空间，那就是插入失败，即返回`false`

boolean offer(E e, long timeout, TimeUnit unit)
            throws InterruptedException;

#### 出队方法说明 ####

队列出队一个元素并返回，若队列是空的，阻塞自己直到队列有元素可出队

E take() throws InterruptedException;

队列出队一个元素并返回，若队列是空的，阻塞一段指定的时间，直到队列有元素可出队。

如果指定时间没有元素可出队，返回`null`

E poll(long timeout, TimeUnit unit)
            throws InterruptedException;

返回可入队的元素个数，需要注意的是，不要依赖于通过此方法来判断是否能入队，因为可能存在线程并发的情况，这样就会出问题。

int remainingCapacity();

队列出队一个指定的元素并返回boolean类型的结果，内部是通过equal是方法来实现的。

boolean remove(Object o);

返回一个boolean类型，表示是否包含。

public boolean contains(Object o);

“榨干”该阻塞队列，并将所有的元素都放到参数集合中

int drainTo(Collection<? super E> c);

“榨干”该阻塞队列，并将最多`maxElements`个元素都放到参数集合中

int drainTo(Collection<? super E> c, int maxElements);

[20200602181119290.png]: https://img-blog.csdnimg.cn/20200602181119290.png

发表评论取消回复

表情：

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

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

相关阅读

相关多线程之阻塞队列BlockingQueue详解（八）

上篇博文，我们简单的介绍了[多线程之Semaphore][Semaphore]，这篇我们重点介绍阻塞队列BlockingQueue。文章目录什么是

女爷i/ 2023年10月09日 03:08/ 0 赞/ 69 阅读

相关 Java多线程系列--阻塞队列(BlockingQueue)的用法(有实例)

原文网址：[Java多线程系列--阻塞队列(BlockingQueue)的用法(有实例)\_IT利刃出鞘的博客-CSDN博客][Java_--_BlockingQueue_IT

╰+哭是因爲堅強的太久メ/ 2023年10月01日 17:18/ 0 赞/ 33 阅读

相关 JUC - 多线程之阻塞队列BlockingQueue（四）

一、队列队列是一种特殊的线性表，特殊之处在于它只允许在表的前端 (front) 进行删除操作，而在表的后端 (rear) 进行插入操作。和栈一样，队列是一种操作受限制的

骑猪看日落/ 2023年09月24日 12:39/ 0 赞/ 204 阅读

相关 Java多线程拾遗(八) BlockingQueue阻塞队列

使用场景队列一般适用于生产者与消费者之间交换数据。而生产者和消费者可能会发生数据处理速度不匹配的情况。理想情况下，如果生产者产出数据的速度大于消费者消费的速度，并且

╰半橙微兮°/ 2023年02月14日 10:54/ 0 赞/ 27 阅读

相关多线程系列：阻塞队列BlockingQueue分析

BlockingQueue 什么是BlockingQueue 如何保证线程安全获取Unsafe类阻塞队列常用API

た入场券/ 2022年11月15日 11:41/ 0 赞/ 238 阅读

相关线程池ThreadPoolExecutor与阻塞队列BlockingQueue

从Java5开始，Java提供了自己的线程池。每次只执行指定数量的线程，java.util.concurrent.ThreadPoolExecutor 就是这样的线程池

阳光穿透心脏的1/2处/ 2022年08月05日 13:17/ 0 赞/ 213 阅读

相关 java线程（7）——阻塞队列BlockingQueue

回顾：阻塞队列，英文名叫BlockingQueue。首先他是一种队列，联系之前[Java基础——集合][Java]中介绍的Queue与Collection，我们就

你的名字/ 2022年07月26日 05:23/ 0 赞/ 290 阅读

相关 Java 阻塞队列（BlockingQueue）

BlockingQueue是java中的阻塞队列，它是线程安全的。在队列为空时的获取阻塞，在队列满时的放入阻塞。 BlockingQueue方法以四种形式出现

客官°小女子只卖身不卖艺/ 2022年03月17日 18:30/ 0 赞/ 393 阅读

相关 Java线程(十一)：阻塞队列BlockingQueue

[https://blog.csdn.net/persistencegoing/article/details/84376427][https_blog.csdn.net_pe

╰+哭是因爲堅強的太久メ/ 2022年03月10日 14:28/ 0 赞/ 285 阅读

相关 java多线程并发之旅-10-阻塞队列 BlockingQueue

Q 为什么要有阻塞队列？什么是阻塞队列优缺点适用场景实现思想+源码个人启发阻塞队列什么是阻塞队列？阻塞队列（

冷不防/ 2022年02月26日 08:30/ 0 赞/ 402 阅读