ThreadPoolExecutor是Java中管理线程池的核心类，通过合理配置corePoolSize、maximumPoolSize、keepAliveTime、workQueue、threadFactory和handler等参数，可优化系统性能并防止资源耗尽。核心线程数保持常驻，最大线程数控制并发上限，存活时间管理非核心线程生命周期，任务队列建议使用有界ArrayBlockingQueue避免内存溢出，自定义线程工厂便于监控，拒绝策略可根据场景选择CallerRunsPolicy等以提升系统稳定性。实际配置需根据CPU密集型或I/O密集型任务调整，避免使用Executors创建无界队列线程池，防止OOM，并在使用后正确关闭线程池。
在Java中，ThreadPoolExecutor 是 java.util.concurrent 包中用于创建和管理线程池的核心类。通过它，我们可以灵活地自定义线程池的行为，以适应不同的业务场景。合理配置线程池参数不仅能提升系统性能，还能避免资源耗尽。
ThreadPoolExecutor 构造函数详解
ThreadPoolExecutor 提供了多个构造方法，最完整的一个如下：
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
下面逐个解析这些参数的作用及配置建议：
核心参数说明与配置建议
corePoolSize（核心线程数）
线程池中始终保持存活的线程数量，即使它们处于空闲状态。除非设置了 allowCoreThreadTimeOut(true)，否则这些线程不会被回收。
- 适用于稳定并发任务的场景，可设为 CPU 核心数或略高
- I/O 密集型任务可适当提高，如 2 * CPU 数
maximumPoolSize（最大线程数）
线程池允许创建的最大线程数量。当任务队列已满且当前线程数小于该值时，会创建新线程处理任务。
- 应结合系统资源和任务类型设定，避免过度占用内存和CPU
- 通常设置为核心线程数的 2~4 倍，视负载情况而定
keepAliveTime 与 unit（非核心线程空闲存活时间）
超过 corePoolSize 的线程在空闲时等待新任务的最长时间。超时后会被终止。
- 适用于控制临时线程的生命周期
- 一般设置为 30~60 秒，可根据任务突发频率调整
workQueue（任务队列）
用于存放待执行任务的阻塞队列。常见实现有：
- LinkedBlockingQueue：无界队列，可能导致内存溢出
- ArrayBlockingQueue：有界队列，推荐使用，防止资源耗尽
- SynchronousQueue：不存储元素，每个插入必须等待取出，适合高并发短任务
threadFactory（线程工厂）
用于创建新线程。可通过自定义 ThreadFactory 设置线程名称、优先级、是否为守护线程等。
- 便于调试和监控，建议命名规则清晰，如 "task-pool-%d"
- 可使用
Executors.defaultThreadFactory()作为基础
handler（拒绝策略）
当线程池关闭或任务队列已满且线程数达到最大值时，新提交的任务将被拒绝。
- AbortPolicy：默认策略，抛出 RejectedExecutionException
- CallerRunsPolicy：由调用线程直接执行任务，减缓提交速度
- DiscardPolicy：静默丢弃任务
- DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试提交当前任务
实际配置示例
以下是一个适用于 Web 后台服务的自定义线程池配置：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.*;
public class CustomThreadPool { public static ExecutorService newCustomPool() { return new ThreadPoolExecutor( 4, // corePoolSize 8, // maximumPoolSize 60L, // keepAliveTime TimeUnit.SECONDS, // unit new ArrayBlockingQueue<>(100), // workQueue new CustomThreadFactory(), // threadFactory new ThreadPoolExecutor.CallerRunsPolicy() // handler ); }
static class CustomThreadFactory implements ThreadFactory {
private int count = 0;
public Thread newThread(Runnable r) {
return new Thread(r, "custom-task-" + count++);
}
}}
这个配置特点：
- 核心线程 4 个，适合中等并发
- 最大线程 8 个，防止单机资源过载
- 使用有界队列（100 容量），避免内存无限增长
- 拒绝策略采用调用者运行，保护系统稳定性
注意事项与最佳实践
使用 ThreadPoolExecutor 时需要注意以下几点：
- 避免使用
Executors工具类创建无界队列的线程池（如 newFixedThreadPool），容易导致 OOM - 根据任务类型（CPU 密集 / I/O 密集）合理设置 corePoolSize 和 maxPoolSize
- 生产环境建议监控线程池状态（活跃线程数、队列大小等）
- 使用完毕后应调用 shutdown() 或 shutdownNow() 正确关闭线程池
基本上就这些。掌握 ThreadPoolExecutor 的参数含义和配置逻辑，才能真正发挥线程池的优势，构建高效稳定的并发程序。
