0

0

在Java里如何使用LinkedBlockingQueue实现线程安全队列_Java并发队列解析

P粉602998670

P粉602998670

发布时间:2026-01-18 15:26:50

|

788人浏览过

|

来源于php中文网

原创

new LinkedBlockingQueue() 线程安全因其内部使用 ReentrantLock 和两个 Condition(notEmpty、notFull)对所有关键操作加锁,无需额外同步;但迭代器弱一致,遍历时修改会抛 ConcurrentModificationException。

在java里如何使用linkedblockingqueue实现线程安全队列_java并发队列解析

为什么直接 new LinkedBlockingQueue() 就线程安全?

LinkedBlockingQueue 内部使用了 ReentrantLock 和配套的 Condition 实现生产/消费端的互斥与等待唤醒,所有关键操作(put()take()offer()poll())都加锁保护。它不是靠 synchronized 方法块,而是显式锁 + 双条件变量(notEmptynotFull),因此比 ArrayBlockingQueue 在高并发吞吐场景下通常更轻量。

不需要额外包装或同步——只要不暴露内部迭代器或调用 toArray() 后手动修改数组,就天然线程安全。

阻塞 vs 非阻塞方法怎么选?

根据下游处理逻辑是否允许“等”或“丢弃”来决定:

  • put(E e):阻塞直到队列有空位,适合强一致性场景(如任务必须入队);但若生产者远快于消费者且容量有限,可能长期挂起
  • take():阻塞直到有元素,适合消费者不能空转的场景(如后台工作线程持续拉取任务)
  • offer(E e)poll():立即返回 true/false 或元素/null,适合需快速失败、降级或带超时控制的逻辑
  • offer(E e, long timeout, TimeUnit unit)poll(long timeout, TimeUnit unit):折中方案,避免无限等待又不轻易丢弃

注意:offer(null) 会抛 NullPointerException,这是明确设计行为,不是 bug。

立即学习Java免费学习笔记(深入)”;

容量设为 Integer.MAX_VALUE 有什么隐患?

默认构造函数 new LinkedBlockingQueue() 实际等价于 new LinkedBlockingQueue(Integer.MAX_VALUE),看似“无界”,但仍是**有界链表**——节点对象本身占用堆内存,且 GC 压力随队列长度线性上升。

Magic Write
Magic Write

Canva旗下AI文案生成器

下载

常见问题

  • OOM 风险:生产者持续涌入、消费者卡顿 → 链表无限增长 → java.lang.OutOfMemoryError: Java heap space
  • 虚假“无界”错觉:和真正的无界队列(如 ConcurrentLinkedQueue)不同,它仍受锁竞争影响,高并发下性能不如后者
  • 监控困难:JVM 无法区分“正常积压”和“异常堆积”,需额外埋点统计 size() 并告警

建议:显式指定合理容量(如 new LinkedBlockingQueue(1024)),配合拒绝策略(如自定义 RejectedExecutionHandler)控制背压。

和 ConcurrentLinkedQueue 的核心区别在哪?

两者都线程安全,但设计目标完全不同:

  • LinkedBlockingQueue:面向**阻塞协作**,提供 put/take 等阻塞语义,适合生产者-消费者模型中需要等待的场景(如线程池任务队列)
  • ConcurrentLinkedQueue:纯非阻塞、无锁(CAS 实现),只提供 offer/poll,不支持等待;适合高性能、低延迟、能容忍“立刻失败”的场景(如事件总线缓冲)
  • 性能差异:在无竞争或轻竞争下,ConcurrentLinkedQueue 吞吐更高;但一旦出现大量失败重试(如反复 poll() 返回 null),实际吞吐可能反低于阻塞队列

别因为“Concurrent”前缀就默认它更适合所有并发场景——如果业务逻辑依赖阻塞等待,硬换 ConcurrentLinkedQueue 会导致忙等或逻辑重构成本陡增。

public class QueueUsageExample {
    private final LinkedBlockingQueue queue = new LinkedBlockingQueue<>(128);

    public void produce(String item) throws InterruptedException {
        // 拒绝策略:满时丢弃并记录
        if (!queue.offer(item)) {
            System.err.println("Dropped item: " + item);
        }
    }

    public String consume() throws InterruptedException {
        return queue.take(); // 保证一定能拿到,除非被中断
    }
}

真正容易被忽略的是:即使用了 LinkedBlockingQueue,如果多个线程共用同一个 Iterator(比如调用 iterator() 后遍历),依然会抛 ConcurrentModificationException —— 它的迭代器是弱一致性的,不支持边遍历边修改,这点和文档里写的 “weakly consistent” 直接相关。

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

835

2023.06.15

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

741

2023.07.05

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

736

2023.07.31

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

397

2023.08.01

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

399

2023.08.02

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

446

2023.08.02

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

430

2023.08.02

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

16926

2023.08.03

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

65

2026.01.16

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 2.6万人学习

C# 教程
C# 教程

共94课时 | 7万人学习

Java 教程
Java 教程

共578课时 | 47.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号