在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公式生成方法【指南】  西安市网站制作公司,哪个相亲网站比较好?西安比较好的相亲网站?