0

0

在Java里BlockingQueue在并发中的作用_Java阻塞队列说明

P粉602998670

P粉602998670

发布时间:2026-01-28 14:16:02

|

584人浏览过

|

来源于php中文网

原创

BlockingQueue通过阻塞式put/take操作自动协调生产者-消费者线程,避免手动wait/notify;其核心是阻塞语义与原子性,而非队列本身。

在java里blockingqueue在并发中的作用_java阻塞队列说明

BlockingQueue 是怎么解决生产者-消费者线程协调问题的

它本质是一个带阻塞语义的线程安全队列,核心价值不在“队列”,而在“阻塞”和“原子性”——当队列空时 take() 会挂起消费者线程;当队列满时 put() 会挂起生产者线程,直到条件满足。这比手动用 wait()/notify()synchronized + while 循环更简洁、不易出错。

常见误用是把它当普通容器用:比如在非并发场景下仍选 LinkedBlockingQueue 而不是 ArrayList,徒增锁开销;或在已知容量固定、无竞争的场景下还用 ArrayBlockingQueue,其实 ConcurrentLinkedQueue(非阻塞)可能更轻量。

不同实现类的阻塞行为和适用场景差异

ArrayBlockingQueue 是有界、基于数组、公平锁可选;LinkedBlockingQueue 默认无界(实际是 Integer.MAX_VALUE),基于链表,吞吐通常更高但 GC 压力略大;SynchronousQueue 不存储元素,每个 put() 必须等待配对的 take(),适合手递手传递任务,比如 Executors.newCachedThreadPool() 的默认队列。

  • 要严格控内存、防 OOM?选 ArrayBlockingQueue 并显式指定容量
  • 任务入队快、消费也快,且不希望因队列积压拖垮系统?考虑 SynchronousQueue
  • 不确定负载峰值,又想避免无界队列失控?用 LinkedBlockingQueue 但务必设容量,如 new LinkedBlockingQueue(1024)

为什么 offer() / poll() 和 put() / take() 容易混用出 bug

put()take() 是阻塞式,调用即可能挂起当前线程;offer(e)poll() 是非阻塞式,失败直接返回 falsenull;还有带超时的 offer(e, timeout, unit)poll(timeout, unit) —— 这三组行为完全不同,不能凭名字猜测。

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

典型错误:在高并发写日志场景中,用 queue.offer(log) 失败后静默丢弃,却没意识到队列已满,导致日志丢失;而本该用 queue.offer(log, 1, TimeUnit.SECONDS) 做有限等待,或兜底走异步落盘。

Designs.ai
Designs.ai

AI设计工具

下载

另一个坑:poll() 返回 null 时,需确认是队列真为空,还是存入的元素本身允许为 nullArrayBlockingQueue 不允许,LinkedBlockingQueue 允许)。

中断敏感性与 try-catch 的真实必要性

put()take() 在等待过程中若被线程中断,会抛出 InterruptedException,且会清除中断状态。忽略这个异常或只打印日志而不恢复中断,会导致上层无法感知线程被中断,后续逻辑可能卡死。

正确做法是捕获后立即重设中断标志:Thread.currentThread().interrupt(),或按业务需要退出循环。例如在 worker 线程中:

while (!Thread.currentThread().isInterrupted()) {
    try {
        Task task = queue.take();
        process(task);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt(); // 必须重置
        break;
    }
}

注意:offer()poll() 不响应中断,所以它们不会抛 InterruptedException —— 这点常被忽略,误以为所有方法都一样。

真正难的不是记住 API,而是判断什么时候该阻塞、什么时候该超时、什么时候该放弃。队列容量、线程模型、下游处理能力,三者必须对齐,否则阻塞只是把问题从一处转移到另一处。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

236

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

458

2024.03.01

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

94

2023.09.25

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

503

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

87

2025.12.01

俄罗斯Yandex引擎入口
俄罗斯Yandex引擎入口

2026年俄罗斯Yandex搜索引擎最新入口汇总,涵盖免登录、多语言支持、无广告视频播放及本地化服务等核心功能。阅读专题下面的文章了解更多详细内容。

167

2026.01.28

包子漫画在线官方入口大全
包子漫画在线官方入口大全

本合集汇总了包子漫画2026最新官方在线观看入口,涵盖备用域名、正版无广告链接及多端适配地址,助你畅享12700+高清漫画资源。阅读专题下面的文章了解更多详细内容。

35

2026.01.28

ao3中文版官网地址大全
ao3中文版官网地址大全

AO3最新中文版官网入口合集,汇总2026年主站及国内优化镜像链接,支持简体中文界面、无广告阅读与多设备同步。阅读专题下面的文章了解更多详细内容。

74

2026.01.28

php怎么写接口教程
php怎么写接口教程

本合集涵盖PHP接口开发基础、RESTful API设计、数据交互与安全处理等实用教程,助你快速掌握PHP接口编写技巧。阅读专题下面的文章了解更多详细内容。

2

2026.01.28

热门下载

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

精品课程

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

共23课时 | 2.9万人学习

C# 教程
C# 教程

共94课时 | 7.8万人学习

Java 教程
Java 教程

共578课时 | 52.2万人学习

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

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