Java自定义线程池需校验参数强耦合关系：corePoolSize≥0且≤maximumPoolSize；keepAliveTime仅在maximumPoolSize>corePoolSize时生效；无界队列使maximumPoolSize失效；拒绝策略须业务适配；threadFactory不可返回null；需监控、动态调参与优雅关闭。

Java 中自定义线程池时，仅按文档填入 corePoolSize、maxPoolSize 等参数远远不够。参数之间存在隐含约束和运行时依赖，若未验证或校验不严，轻则任务被拒绝、资源浪费，重则线程泄漏、OOM 或服务雪崩。

核心参数间的逻辑一致性检查

ThreadPoolExecutor 构造参数不是独立配置项，彼此强耦合：

• corePoolSize 必须 ≥ 0，且不能大于 maxPoolSize；若违反，构造时抛 IllegalArgumentException
• keepAliveTime 必须 ≥ 0，但仅当 maxPoolSize > corePoolSize 时才生效（否则空闲线程不会被回收）
• workQueue 容量需匹配拒绝策略：无界队列（如 LinkedBlockingQueue）会使 maxPoolSize 失效，此时实际并发线程数恒为 corePoolSize；有界队列（如 ArrayBlockingQueue）必须配合合理的容量与拒绝策略，否则易触发 RejectedExecutionException
• threadFactory 不能返回 null 线程，否则 execute() 时抛 NullPointerException；建议使用 Executors.defaultThreadFactory() 基础上定制命名与守护属性

拒绝策略的显式声明与行为预判

不传 rejection handler 会使用默认的 AbortPolicy，直接抛异常。生产环境应避免“裸用”默认策略：

deep-java-review

Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...

下载

• 选用 CallerRunsPolicy 可缓解压力（由调用线程执行任务），但需确保调用线程能承受额外负载
• 选用 DiscardPolicy 或 DiscardOldestPolicy 时，务必确认丢弃任务是业务可接受的（例如日志采集、监控上报等非关键路径）
• 自定义拒绝策略应记录日志 + 上报指标（如 Prometheus counter），便于容量告警与复盘

运行时状态与资源泄漏防护

线程池生命周期管理不当极易引发资源泄漏或状态混乱：

立即学习“Java免费学习笔记（深入）”；

• 调用 shutdown() 后不可再 submit 新任务，否则抛 RejectedExecutionException；应配合 awaitTermination() 等待优雅关闭
• shutdownNow() 不保证所有任务终止：仅中断正在执行的线程，对未启动任务返回列表，对已提交未执行任务直接丢弃 —— 需业务层自行保障任务幂等或可中断
• 避免在 beforeExecute / afterExecute 回调中抛异常，否则可能导致线程池异常退出或统计失真
• 使用 ThreadLocal 变量时务必 cleanup，否则线程复用会导致脏数据传递（尤其在 Tomcat 等容器复用线程场景下）

监控与动态调参的可行性验证

静态配置难以应对流量波动，健壮的线程池应支持可观测性与安全调整：

• 暴露关键指标：getActiveCount()、getCompletedTaskCount()、getQueue().size()，接入 Micrometer 或自建健康端点
• 动态修改 corePoolSize / maxPoolSize 是允许的（setCorePoolSize/setMaximumPoolSize），但要注意：maxPoolSize 缩小可能触发线程中断，需确保任务可安全中断
• 扩容前建议先观察队列积压趋势与拒绝率；缩容前确认活跃线程数长期低于目标值，避免抖动
• 避免在高并发路径中频繁调用 getPoolSize() 等同步方法，影响性能