讲师中心 微信公众号
AI工具推荐 视频效率加速

Java并发编程中的Executor框架与线程池

星宇姑娘_5275

星宇姑娘_5275

发布时间:2026-01-09 14:12:36

|

741人浏览过

|

来源于php中文网

原创

直接new Thread()不适合高并发场景,因频繁创建销毁线程导致栈内存分配、GC压力、调度竞争及OS线程耗尽;Executor框架通过复用线程、统一管理生命周期、解耦任务提交与执行来优化。

java并发编程中的executor框架与线程池

为什么直接 new Thread() 不适合高并发场景

频繁创建和销毁线程会带来显著的系统开销:JVM 需要分配栈内存、触发 GC、参与线程调度竞争。在 QPS 较高的服务中,new Thread(runnable).start() 很快会耗尽 OS 线程资源(Linux 默认每进程约 1024 个线程),抛出 java.lang.OutOfMemoryError: unable to create new native thread。

Executor 框架通过复用线程、统一管理生命周期、解耦任务提交与执行,把“怎么跑”交给线程池,“跑什么”由业务代码决定。

  • 线程池不是万能的——它只缓解线程创建成本,不解决任务内部阻塞、死锁或共享状态竞争
  • Executors 工具类创建的线程池有陷阱:比如 Executors.newFixedThreadPool(n) 底层用的是无界 LinkedBlockingQueue,任务堆积会导致 OOM
  • 生产环境推荐显式构造 ThreadPoolExecutor,明确控制核心线程数、队列容量、拒绝策略

ThreadPoolExecutor 的几个关键参数怎么设才合理

核心不是背参数名,而是理解它们如何协同影响吞吐与稳定性。以 Web 请求处理为例:

  • corePoolSize:常驻线程数,建议设为 CPU 核心数 × (1 + 平均等待时间 / 平均执行时间),IO 密集型可适当放大
  • maximumPoolSize:最大线程数,避免设得过大(如 1000+),否则上下文切换开销反超收益;一般不超过 corePoolSize × 2
  • workQueue:优先选有界队列,如 ArrayBlockingQueue(100);避免 SynchronousQueue 在突发流量下直接触发拒绝策略
  • handler:别用默认的 AbortPolicy(直接抛 RejectedExecutionException);更稳妥的是 CallerRunsPolicy(让调用线程自己执行任务,自然降速)或自定义记录+告警
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    4,           // corePoolSize
    8,           // maximumPoolSize
    60L,         // keepAliveTime
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<Runnable>(100),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

submit() 和 execute() 的区别不只是返回值

execute(Runnable) 是 Executor 接口方法,只负责提交,不关心结果;submit() 是 ExecutorService 扩展方法,支持获取执行结果和异常。

java-api-doc-generator
java-api-doc-generator

分析 Java Spring Boot 后端 Controller 代码,自动生成 Markdown 格式的接口文档。当用户说“生成 Java 接口文档”、“生成 API 文档”、“从 Spring 代码生成文档”时触发。

下载

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

  • 用 submit(Runnable) 时,返回的 Future 调用 get() 只会返回 null,但能捕获运行时异常(比如空指针)
  • 用 submit(Callable<t>)</t> 才真正发挥异步计算价值:Future<string> f = executor.submit(() -> "done"); String result = f.get();</string>
  • 注意 Future.get() 是阻塞的;若需非阻塞,可用 isDone() 轮询,或结合 CompletableFuture 做链式回调
  • 忘记调用 get() 或未处理 ExecutionException,会导致异常“静默丢失”

线程池 shutdown() 和 shutdownNow() 到底停不停得干净

两者都不保证立即终止所有线程,只是改变线程池状态并尝试中断正在运行的任务。

  • shutdown():设置 RUNNING → SHUTDOWN,不再接受新任务,但会等已提交任务(包括队列中等待的)全部执行完
  • shutdownNow():设置 RUNNING → STOP,尝试中断所有正在执行的线程,并清空队列,返回未执行的任务列表
  • 真正“停干净”的关键是任务自身响应中断:必须在循环中检查 Thread.interrupted() 或捕获 InterruptedException,否则 shutdownNow() 对该线程无效
  • 典型错误写法:while (true) { doWork(); } —— 它永远不响应中断;应改为 while (!Thread.currentThread().isInterrupted()) { doWork(); }

实际关闭流程建议加超时等待:

executor.shutdown();
try {
    if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
        executor.shutdownNow();
        if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
            System.err.println("Pool did not terminate");
        }
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

线程池的边界往往藏在 shutdown 逻辑里——没等完就退出、没处理中断、没清理资源,都会让应用在重启或降级时留下残留线程。

相关文章

编程速学教程(入门课程)
编程速学教程(入门课程)

编程怎么学习?编程怎么入门?编程在哪学?编程怎么学才快?不用担心,这里为大家提供了编程速学教程(入门课程),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

6899

2023.08.02

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

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

549

2023.09.22

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

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

1698

2024.03.01

while的用法
while的用法

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

354

2023.09.25

C++ 智能指针与现代内存管理
C++ 智能指针与现代内存管理

深入讲解 C++ 现代内存管理的核心工具——智能指针,涵盖 unique_ptr 独占所有权语义、shared_ptr 引用计数机制与循环引用问题、weak_ptr 弱引用的应用场景、make_unique/make_shared 工厂函数的性能优势、自定义删除器的编写、RAII 资源管理思想的实践,以及从裸指针迁移到智能指针的重构策略,帮助开发者编写安全无泄漏的现代 C++ 代码。

379

2026.04.23

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

3188

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

5169

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

3849

2025.12.29

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

60

2026.10.28

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习

Buffalo框架快速入门指南
Buffalo框架快速入门指南

共0课时 | 0人学习

Valgrind支持平台说明
Valgrind支持平台说明

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn