阻塞队列BlockingQueue(JDK8)

2024-05-24 12:38

本文主要是介绍阻塞队列BlockingQueue(JDK8),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  1. BlockingQueue(阻塞队列)是JDK5新增的线程安全的高效队列类,基于生产者-消费者模式。队列为空时,获取元素的操作等待队列变为非空;队列已满时插入操作等待队列空间可用。
  2. BlockingQueue不接受null元素,会throw NullPointerException,null用于标记poll操作的失败。
  3. BlockingQueue默认容量大小为Integer.MAX_VALUE,支持自定义容量大小。类似于Collection接口,支持remove(x),然而由于性能问题并不推荐大量使用。drainTo(c)比重复poll更高效。
  4. BlockingQueue本质上不提供close、shutdown操作用来标记“不再有元素继续被添加”,开发者可自行定义特殊元素来表示“不再有元素继续被添加”。
  5. 本文地址:http://blog.csdn.net/u010887744/article/details/70195270

方法 操作成功一直阻塞直到处理成功失败返回特殊值失败抛异常
插入add(e)true  队列已满则IllegalStateException: Queue full
offer(e)true 队列已满:false 
put(e)void一直阻塞直到插入成功  
offer e,timeout, unit)true 插入超时:false 
addAll(c)true 部分插入异常返回false队列已满则IllegalStateException: Queue full
移除/获取remove()返回被移除的元素  队列为空:抛出NoSuchElementException
remove(e)true 不存在该元素:false 
removeAll(c)迭代remove(e),队列因此请求而改变则返回true false 
poll()队列头 队列为空返回null而不是抛异常 

这篇关于阻塞队列BlockingQueue(JDK8)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/998433

相关文章

【数据结构与算法 经典例题】使用队列实现栈(图文详解)

💓 博客主页:倔强的石头的CSDN主页               📝Gitee主页:倔强的石头的gitee主页    ⏩ 文章专栏:《数据结构与算法 经典例题》C语言                                   期待您的关注 ​​ 目录  一、问题描述 二、前置知识 三、解题思路 四、C语言实现代码 🍃队列实现代码:

RabbitMQ实践——临时队列

临时队列是一种自动删除队列。当这个队列被创建后,如果没有消费者监听,则会一直存在,还可以不断向其发布消息。但是一旦的消费者开始监听,然后断开监听后,它就会被自动删除。 新建自动删除队列 我们创建一个名字叫queue.auto.delete的临时队列 绑定 我们直接使用默认交换器,所以不用创建新的交换器,也不用建立绑定关系。 实验 发布消息 我们在后台管理页面的默认交换器下向这个队列

Java并发编程—阻塞队列源码分析

在前面几篇文章中,我们讨论了同步容器(Hashtable、Vector),也讨论了并发容器(ConcurrentHashMap、CopyOnWriteArrayList),这些工具都为我们编写多线程程序提供了很大的方便。今天我们来讨论另外一类容器:阻塞队列。   在前面我们接触的队列都是非阻塞队列,比如PriorityQueue、LinkedList(LinkedList是双向链表,它实现了D

剑指offer—编程题7(用两个栈实现一个队列)

题目:用两个栈实现一个队列。队列的声明如下,请实现它的两个函数appendTail 和deleteHead,分别完成在队列尾部插入结点和在队列头部删除结点的功能。 代码如下: [java]  view plain copy print ? public class Test07 {       /**       * 用两个栈模拟的队列       *

SpringBoot中如何监听两个不同源的RabbitMQ消息队列

spring-boot如何配置监听两个不同的RabbitMQ 由于前段时间在公司开发过程中碰到了一个问题,需要同时监听两个不同的rabbitMq,但是之前没有同时监听两个RabbitMq的情况,因此在同事的帮助下,成功实现了监听多个MQ。下面我给大家一步一步讲解下,也为自己做个笔记; 详细步骤: 1. application.properties 文件配置: u.rabbitmq.ad

leetcode刷题(41)——232. 用栈实现队列

使用栈实现队列的下列操作: push(x) – 将一个元素放入队列的尾部。 pop() – 从队列首部移除元素。 peek() – 返回队列首部的元素。 empty() – 返回队列是否为空。 示例: MyQueue queue = new MyQueue();queue.push(1);queue.push(2); queue.peek(); // 返回 1queue.pop();

【算法】优先级队列-基础与应用

优先级队列(Priority Queue)是一种特殊的队列类型,它允许在其元素中分配优先级。与传统的先进先出(FIFO)队列不同,优先级队列中元素的出队顺序取决于它们的优先级。优先级较高的元素会被优先处理,即使它们是在优先级较低的元素之后被加入队列的。 优先级队列的特点: 插入操作:新元素被添加到队列中时,它们根据自身的优先级被放置在适当的位置。移除操作:优先级队列通常移除并返回具有最高优先

Python 算法交易实验72 QTV200第一步: 获取原始数据并存入队列

说明 最近的数据流往前进了一步,我觉得基本可以开始同步的推进QTV200了。上次规划了整体的数据流,现在开始第一步。 内容 1 结构位置 这是上次的总体图: 以下是这次要实现的一小部分: 从结构上,这个是整体数据流的起点,系统因为这些不断 运行的数据才开始“动”了起来,可以称为源点。 2 规范与约束 源点是基于每分钟的节拍从外界读取数据,这部分目前我没用用付费接口(数据的需求量很

【LinuxC语言】阻塞、回调与轮询快速理解

文章目录 前言阻塞阻塞的基本概念阻塞函数非阻塞函数区别 回调轮询 总结 前言 在Linux C语言编程中,阻塞、回调和轮询是三种常见的处理输入/输出(I/O)的方式。这些方法在处理网络通信、多线程编程和套接字编程等场景中都有广泛的应用。理解这三种方法的工作原理和使用场景,对于提高编程效率和程序性能至关重要。 阻塞 阻塞的基本概念 阻塞是一种同步操作,它会暂停程序的

【Orange Pi 5与Linux编程编程】-POSIX消息队列

Linux系统中的POSIX消息队列编程 文章目录 Linux系统中的POSIX消息队列编程1、POSIX 消息队列2、Linux 中的 POSIX 消息队列命名3、POSIX 消息队列调用3.1 mq_open, mq_close3.2 mq_timed_send、mq_send、mq_timed_receive、mq_receive3.3 mq_notify3.4 mq_unlink3