ThreadPoolExecutor是Java线程池核心类，通过构造函数配置核心线程数、最大线程数、存活时间、任务队列、线程工厂和拒绝策略；选用有界队列如ArrayBlockingQueue防资源耗尽，自定义ThreadFactory提升线程识别度，设置CallerRunsPolicy等拒绝策略保障系统稳定，结合业务需求调整参数并监控队列状态以优化性能。
在Java中，ThreadPoolExecutor 是线程池的核心实现类，提供了高度可定制的线程管理能力。通过合理配置参数，可以满足不同业务场景下的并发需求。
理解ThreadPoolExecutor构造函数参数
ThreadPoolExecutor提供了一个多参数构造函数，用于精细控制线程池行为：
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
- corePoolSize：核心线程数，即使空闲也不会被回收（除非设置allowCoreThreadTimeOut）
- maximumPoolSize：最大线程数，线程池允许创建的最多线程数量
- keepAliveTime：非核心线程闲置超时时间，超过此时间将被终止
- unit：keepAliveTime的时间单位
- workQueue：任务队列，用于存放待执行的任务
- threadFactory：线程工厂，用于创建新线程，可自定义线程命名和属性
- handler：拒绝策略，当任务无法提交时的处理方式
选择合适的任务队列
队列类型直接影响线程池的行为和性能：
- LinkedBlockingQueue：无界队列，可能导致内存溢出，适合负载较轻且稳定的应用
- ArrayBlockingQueue：有界队列，需指定容量，能防止资源耗尽，但可能触发拒绝策略
- SynchronousQueue：不存储元素的阻塞队列，每个插入操作必须等待另一个线程的移除操作，适合高并发短任务场景
- PriorityBlockingQueue：支持优先级排序的无界队列，适用于需要任务优先级调度的场景
自定义线程工厂ThreadFactory
默认线程工厂创建的线程名不易识别，不利于排查问题。通过自定义ThreadFactory可提升调试效率：
立即学习“Java免费学习笔记（深入）”；
ThreadFactory namedFactory = new ThreadFactory() {
private final AtomicInteger threadNumber = new AtomicInteger(1);
public Thread newThread(Runnable r) {
Thread t = new Thread(r, "MyPool-Thread-" + threadNumber.getAndIncrement());
t.setDaemon(false); // 非守护线程
t.setPriority(Thread.NORM_PRIORITY);
return t;
}
};
设置合理的拒绝策略
当线程池关闭或饱和时，新提交的任务会触发拒绝策略：
- AbortPolicy：默认策略，抛出RejectedExecutionException异常
- CallerRunsPolicy：由提交任务的线程直接执行任务，减缓提交速度
- DiscardPolicy：静默丢弃任务，不抛异常
- DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试重新提交当前任务
也可实现RejectedExecutionHandler接口，定制日志记录、告警或降级逻辑。
示例：构建一个生产级线程池
结合以上要素，创建一个健壮的线程池实例：
BlockingQueuequeue = new ArrayBlockingQueue<>(100); ThreadFactory factory = r -> { Thread t = new Thread(r, "BizWorker-" + counter.incrementAndGet()); t.setUncaughtExceptionHandler((t, e) -> log.error("Uncaught exception in thread " + t.getName(), e)); return t; }; RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, // 核心线程数 20, // 最大线程数 60L, // 空闲超时时间 TimeUnit.SECONDS, queue, factory, handler ); // 允许核心线程超时（可选） executor.allowCoreThreadTimeOut(true);
基本上就这些。关键是根据实际业务特点调整参数，避免盲目使用Executors工具类提供的固定模式。监控线程池状态（如队列长度、活跃线程数）也有助于持续优化配置。
