在Java中如何使用Executor框架_Java线程池基本用法解析
发布时间 - 2026-01-30 00:00:00 点击率:次生产环境应手动创建ThreadPoolExecutor,显式配置核心线程数、最大线程数、队列容量和拒绝策略;submit()适用于需结果和异常处理的场景,execute()仅执行无返回任务;shutdown后须调用awaitTermination等待任务完成。
怎么创建一个能用的线程池
别一上来就写 new ThreadPoolExecutor(...),大多数场景直接用 Executors 工厂方法更安全。但要注意:它提供的几个静态方法有隐藏陷阱。
-
Executors.newFixedThreadPool(int)底层用的是无界
LinkedBlockingQueue,任务堆积时可能 OOM -
Executors.newCachedThreadPool()允许无限创建线程,突发流量下容易耗尽系统资源 - 生产环境推荐手动构造
ThreadPoolExecutor,显式控制核心线程数、最大线程数、队列容量和拒绝策略
例如启动一个最多 8 个线程、队列最多存 100 个任务、超时 60 秒自动回收空闲线程的池:
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, // corePoolSize
8, // maxPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
new ArrayBlockingQueue(100),
new ThreadPoolExecutor.CallerRunsPolicy()
);
submit() 和 execute() 到底该用哪个
区别不在“能不能跑”,而在“要不要结果”和“异常处理方式”。
-
execute(Runnable):只负责执行,不返回任何东西,如果任务抛出未捕获异常,会直接打印到 stderr,且无法被调用方感知 -
submit(Runnable)或submit(Callable:返回) Future,可主动检查状态、获取结果、等待完成;异常会被包装进Future.get()抛出,便于集中处理 - 如果你需要异步计算结果(比如查数据库后聚合),必须用
submit()+Callable
常见错误:用 execute() 提交可能抛异常的任务,又没配 ThreadFactory 设置 UncaughtExceptionHandler,导致异常静默丢失。
线程池 shutdown 的正确姿势
不关干净会导致 JVM 不退出,或任务被丢弃却不通知。关键不是“调 shutdown”,而是“等完再停”。
- 先调
shutdown():停止接收新任务,但会继续执行已提交和队列中的任务 - 再调
awaitTermination(long, TimeUnit)等待执行完成,建议设合理超时(如 30 秒) - 如果超时仍未结束,可考虑
shutdownNow()尝试中断正在运行的任务(注意:不是所有任务都能被中断)
典型误操作:shutdown() 后立刻 return,没等任务结束,主线程就退出了。
拒绝策略选哪个才不丢任务也不卡死
当线程池满 + 队列满时触发,选错会导致数据丢失或线程阻塞。四种内置策略行为差异很大:
-
AbortPolicy(默认):直接抛RejectedExecutionException,调用方必须处理,否则崩溃 -
CallerRunsPolicy:由提交任务的线程自己执行该任务,能自然降速,适合非关键任务 -
DiscardPolicy:静默丢弃,不报错,适合允许丢失的监控类任务 -
DiscardOldestPolicy:丢掉队列头任务,再尝试提交当前任务,有一定风险(可能反复丢老任务)
自定义策略可以记录日志、发告警、写入重试队列——但别在拒绝策略里做耗时操作(比如远程调用),会卡住 submit() 线程。
# java
# ai
# 区别
# java线程池
# 数据丢失
# jvm
# int
# 堆
# 线程
# 主线程
# 异步
# 数据库
# 最多
# 抛出
# 装进
# 的是
# 几个
# 如果你
# 也不
# 出了
# 都能
# 而在
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
如何在 Pandas 中基于一列条件计算另一列的分组均值
EditPlus中的正则表达式 实战(2)
高端网站建设与定制开发一站式解决方案 中企动力
电视网站制作tvbox接口,云海电视怎样自定义添加电视源?
如何用低价快速搭建高质量网站?
如何快速建站并高效导出源代码?
Laravel怎么使用Session存储数据_Laravel会话管理与自定义驱动配置【详解】
Laravel路由Route怎么设置_Laravel基础路由定义与参数传递规则【详解】
如何在腾讯云服务器快速搭建个人网站?
如何在阿里云高效完成企业建站全流程?
JavaScript模板引擎Template.js使用详解
猎豹浏览器开发者工具怎么打开 猎豹浏览器F12调试工具使用【前端必备】
高防服务器租用首荐平台,企业级优惠套餐快速部署
Swift开发中switch语句值绑定模式
Laravel怎么实现搜索高亮功能_Laravel结合Scout与Algolia全文检索【实战】
消息称 OpenAI 正研发的神秘硬件设备或为智能笔,富士康代工
如何在IIS中新建站点并配置端口与IP地址?
如何在IIS中新建站点并解决端口绑定冲突?
标准网站视频模板制作软件,现在有哪个网站的视频编辑素材最齐全的,背景音乐、音效等?
详解MySQL数据库的安装与密码配置
WEB开发之注册页面验证码倒计时代码的实现
LinuxCD持续部署教程_自动发布与回滚机制
Laravel如何使用Passport实现OAuth2?(完整配置步骤)
Laravel如何实现多语言支持_Laravel本地化与国际化(i18n)配置教程
Laravel怎么实现验证码功能_Laravel集成验证码库防止机器人注册
Laravel如何实现全文搜索_Laravel Scout集成Algolia或Meilisearch教程
打开php文件提示内存不足_怎么调整php内存限制【解决方案】
js实现点击每个li节点,都弹出其文本值及修改
Laravel怎么设置路由分组Prefix_Laravel多级路由嵌套与命名空间隔离【步骤】
Laravel Octane如何提升性能_使用Laravel Octane加速你的应用
家族网站制作贴纸教程视频,用豆子做粘帖画怎么制作?
如何用PHP快速搭建CMS系统?
国美网站制作流程,国美电器蒸汽鍋怎么用官方网站?
如何在建站主机中优化服务器配置?
Laravel如何实现用户密码重置功能?(完整流程代码)
Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性
如何在景安云服务器上绑定域名并配置虚拟主机?
详解ASP.NET 生成二维码实例(采用ThoughtWorks.QRCode和QrCode.Net两种方式)
网站制作怎么样才能赚钱,用自己的电脑做服务器架设网站有什么利弊,能赚钱吗?
Laravel如何使用Seeder填充数据_Laravel模型工厂Factory批量生成测试数据【方法】
网站制作价目表怎么做,珍爱网婚介费用多少?
Laravel怎么实现软删除SoftDeletes_Laravel模型回收站功能与数据恢复【步骤】
Laravel如何实现图片防盗链功能_Laravel中间件验证Referer来源请求【方案】
HTML5建模怎么导出为FBX格式_FBX格式兼容性及导出步骤【指南】
如何正确选择百度移动适配建站域名?
如何在云虚拟主机上快速搭建个人网站?
如何在阿里云部署织梦网站?
再谈Python中的字符串与字符编码(推荐)
ChatGPT怎么生成Excel公式_ChatGPT公式生成方法【指南】
西安市网站制作公司,哪个相亲网站比较好?西安比较好的相亲网站?


