0

0

Java并发编程中的任务队列与线程池使用

P粉602998670

P粉602998670

发布时间:2026-01-07 17:21:09

|

257人浏览过

|

来源于php中文网

原创

优先选 ArrayBlockingQueue,因其有界性可暴露容量瓶颈并配合拒绝策略保障稳定;若用 LinkedBlockingQueue 必须显式指定容量,禁用无界构造。

java并发编程中的任务队列与线程池使用

线程池创建时用 LinkedBlockingQueue 还是 ArrayBlockingQueue

取决于任务提交频率和可控性。LinkedBlockingQueue 默认无界,看似安全,但容易掩盖背压问题——当生产者(提交任务)远快于消费者(线程执行),队列无限增长,最终触发 OutOfMemoryErrorArrayBlockingQueue 是有界队列,能强制暴露容量瓶颈,配合合理的拒绝策略更利于系统稳定。

  • 高吞吐、任务执行时间短且可预测 → 选 ArrayBlockingQueue,设合理容量(如核心线程数 × 2~4)
  • 任务来源不可控、需容忍短时突发 → 可用 LinkedBlockingQueue,但必须显式指定容量(如 new LinkedBlockingQueue(1000)),绝不用无参构造
  • 若用 SynchronousQueue,它不存储任务,仅作“手递手”中转,适合 CPU 密集型、希望立即触发线程创建的场景,但会频繁启停线程,慎用于 I/O 密集型

ThreadPoolExecutorcorePoolSizemaximumPoolSize 怎么设?

这不是调优起点,而是业务负载建模的结果。盲目设大值会导致线程争抢 CPU 或阻塞在 I/O 上,反而降低吞吐;设太小则任务积压、响应延迟升高。

  • CPU 密集型任务:理论上限 ≈ Runtime.getRuntime().availableProcessors()corePoolSizemaximumPoolSize 可设为相同值,避免线程上下文切换开销
  • I/O 密集型任务(如 HTTP 调用、DB 查询):需估算平均 I/O 等待时间占比,公式参考:corePoolSize ≈ CPU 核数 / (1 - 阻塞系数),其中阻塞系数常取 0.8~0.9,即单线程约 80% 时间在等 I/O
  • 永远不要把 maximumPoolSize 设为 Integer.MAX_VALUE —— 这会让线程池在队列满后无限制新建线程,极大概率 OOM

为什么 submit(Runnable) 返回的 Future 调用 get() 会阻塞?

因为 Future.get() 是同步等待语义,它会挂起当前线程直到任务完成或超时。这不是 bug,而是设计使然。但在线程池内部调用它,极易造成死锁——比如所有工作线程都在等另一个任务的 get(),而那个任务又排在队列里,无人执行。

  • 避免在 RunnableCallable 内部调用同一线程池中其他任务的 future.get()
  • 如需组合多个异步结果,优先用 CompletableFuture.supplyAsync(..., executor) 配合 thenCombine/allOf,它们不阻塞线程,而是注册回调
  • 若必须阻塞等待,确保调用方不在该线程池的工作线程中(例如放在 Servlet 线程或独立的调度线程里)

关闭线程池时,shutdown()shutdownNow() 的实际行为差异

shutdown() 是温和终止:不再接受新任务,但会等所有已提交任务(包括队列中未执行的)完成;shutdownNow() 是强制中断:尝试停止正在执行的任务(通过 Thread.interrupt()),并清空队列、返回未执行任务列表。

阿里云AI平台
阿里云AI平台

阿里云AI平台

下载

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

  • 绝大多数场景应优先用 shutdown() + awaitTermination(long, TimeUnit),给任务留出合理收尾时间(如释放连接、刷盘日志)
  • shutdownNow() 仅适用于可中断任务(即代码中检查了 Thread.currentThread().isInterrupted() 并主动退出),否则中断信号被忽略,任务仍会跑完
  • Spring 中用 @PreDestroy 关闭线程池时,务必加超时等待逻辑,否则应用可能假死在关闭阶段
executor.shutdown();
try {
    if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
        executor.shutdownNow();
        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
            System.err.println("线程池未正常关闭");
        }
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

真正难的不是选哪个队列或设几个线程,而是理解每个参数背后对资源竞争、任务生命周期和错误传播路径的影响。多数线上问题,都出在“以为设了线程池就等于并发安全”,却没管住任务本身的阻塞点和依赖关系。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

161

2025.08.06

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

89

2026.01.26

servlet生命周期
servlet生命周期

Servlet生命周期是指Servlet从创建到销毁的整个过程。本专题为大家提供servlet生命周期的各类文章,大家可以免费体验。

393

2023.08.08

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

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

766

2023.08.10

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

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

99

2025.12.01

http500解决方法
http500解决方法

http500解决方法有检查服务器日志、检查代码错误、检查服务器配置、检查文件和目录权限、检查资源不足、更新软件版本、重启服务器或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

497

2023.11.09

http请求415错误怎么解决
http请求415错误怎么解决

解决方法:1、检查请求头中的Content-Type;2、检查请求体中的数据格式;3、使用适当的编码格式;4、使用适当的请求方法;5、检查服务器端的支持情况。更多http请求415错误怎么解决的相关内容,可以阅读下面的文章。

452

2023.11.14

HTTP 503错误解决方法
HTTP 503错误解决方法

HTTP 503错误表示服务器暂时无法处理请求。想了解更多http错误代码的相关内容,可以阅读本专题下面的文章。

3598

2024.03.12

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

26

2026.03.13

热门下载

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

精品课程

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

共23课时 | 4.4万人学习

C# 教程
C# 教程

共94课时 | 11.3万人学习

Java 教程
Java 教程

共578课时 | 81.9万人学习

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

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