java中自定义threadpoolexecutor需合理设置7个参数：corepoolsize（核心线程数）、maximumpoolsize（最大线程数）、keepalivetime（空闲线程存活时间）、unit（时间单位）、workqueue（阻塞队列）、threadfactory（线程工厂）、handler（拒绝策略），生产环境应避免executors工具类创建的线程池。
Java 中使用 ThreadPoolExecutor 自定义线程池，核心在于合理设置七个关键参数，并理解它们之间的协作关系。直接用 Executors 工具类创建的线程池（如 newFixedThreadPool）隐藏了底层细节，容易引发资源耗尽或拒绝问题，所以生产环境推荐手动构造 ThreadPoolExecutor。
核心七个参数含义与设置逻辑
ThreadPoolExecutor 构造方法签名如下：
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue
ThreadFactory threadFactory,
RejectedExecutionHandler handler
)
各参数作用和常见配置建议：
-
corePoolSize：核心线程数。线程池会一直保留这些线程（即使空闲），除非设置了
allowCoreThreadTimeOut(true)。建议设为 CPU 密集型任务 ≈ CPU 核数 +1，IO 密集型可适当提高（如 2×CPU） - maximumPoolSize：最大线程数。仅当工作队列满且当前线程数 LinkedBlockingQueue 无参构造），该值实际无效
- keepAliveTime & unit：非核心线程空闲后的存活时间。超过此时间未被复用则销毁。对有界队列+动态伸缩场景很重要
-
workQueue：任务缓冲队列。选型直接影响行为：
-
ArrayBlockingQueue（有界）：防止任务无限堆积，配合maximumPoolSize起作用，推荐用于可控负载场景 -
LinkedBlockingQueue（默认无界）：易导致 OOM（尤其高吞吐+慢消费时），慎用 -
SynchronousQueue（不存储任务）：每个新任务必须立刻由空闲线程处理，否则触发扩容或拒绝，适合高响应要求、短任务场景
-
-
threadFactory：用于创建线程。建议自定义，统一命名（如
"biz-task-pool-%d"），便于排查；可设为守护线程（setDaemon(true)）避免阻塞 JVM 退出 -
handler：拒绝策略。默认
AbortPolicy（抛RejectedExecutionException）。其他常用选项：-
CallerRunsPolicy：由提交任务的线程自己执行，可自然降速，适合非关键任务 -
DiscardPolicy：静默丢弃，适合允许丢失的任务 -
DiscardOldestPolicy：丢弃队列头任务，再尝试提交当前任务
-
一个典型安全配置示例
假设处理 Web 请求中的异步日志写入（IO 密集、可容忍少量丢失）：
ThreadPoolExecutor executor = new ThreadPoolExecutor(4, // core: 4 核机器，IO 多些
16, // max: 防突发流量
60L, TimeUnit.SECONDS,
new ArrayBlockingQueue(1000), // 有界队列防内存溢出
new ThreadFactoryBuilder().setNameFormat("log-writer-%d").setDaemon(true).build(),
new ThreadPoolExecutor.DiscardPolicy() // 日志可丢，不阻塞主流程
);
必须注意的几个坑
- 不要用
Executors.newCachedThreadPool()：它用SynchronousQueue+Integer.MAX_VALUE最大线程数，高并发下可能创建海量线程导致 OOM 或系统崩溃 - 避免无界队列 + 小 corePoolSize：任务持续涌入时，线程数永远卡在 core 值，所有任务排队，响应延迟飙升
- 线程池应作为单例长期持有，不要每次 new；用完不需手动 shutdown（除非是临时短生命周期线程池），但应用关闭时应调用
shutdown()或shutdownNow() - 监控很重要：可通过
getActiveCount()、getQueue().size()、getCompletedTaskCount()等方法暴露指标，接入 Prometheus 或日志告警
优雅关闭线程池
应用停机时应主动释放资源：
- 调用
shutdown()：停止接收新任务，等待已有任务完成 - 可选加超时等待：
awaitTermination(30, TimeUnit.SECONDS)，超时后调用shutdownNow()尝试中断运行中任务 - 注意：
shutdownNow()不保证立即终止，只是发中断信号，任务本身需响应Thread.interrupted()或检查中断状态
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
