ThreadPoolExecutor可精细控制线程池，避免OOM，适合生产环境。1. 构造参数包括核心线程数、最大线程数、空闲时间、任务队列、线程工厂和拒绝策略。2. 实际使用需自定义命名线程、设置有界队列及拒绝策略。3. 提交任务用execute或submit，关闭时先shutdown再awaitTermination。4. 最佳实践：禁用Executors快捷方式，合理配置参数，命名线程池，结合@Async注入自定义实例，提升系统稳定性。
在Java后端开发中，ThreadPoolExecutor 是创建和管理线程池的核心类，相比 Executors 工具类，它能更精细地控制线程池行为，避免潜在风险（如OOM），适合生产环境。
1. ThreadPoolExecutor 构造参数说明
创建线程池前，先理解其核心构造函数：
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
- corePoolSize：核心线程数，即使空闲也不会被回收（除非设置 allowCoreThreadTimeOut）
- maximumPoolSize：最大线程数，线程池允许创建的最大线程数量
- keepAliveTime：非核心线程空闲超时时间，超时后会被销毁
- unit：时间单位，如 TimeUnit.SECONDS
- workQueue：任务队列，用于保存等待执行的任务，常用 LinkedBlockingQueue、ArrayBlockingQueue、SynchronousQueue
- threadFactory：创建线程的工厂，可自定义线程命名、优先级等
- handler：拒绝策略，当线程池无法处理新任务时的应对方式
2. 实际使用示例
以下是一个典型的后端服务中创建线程池的代码：
// 自定义线程工厂，便于排查问题ThreadFactory namedFactory = new ThreadFactory() {
private final AtomicInteger threadNumber = new AtomicInteger(1);
public Thread newThread(Runnable r) {
return new Thread(r, "MyTaskThread-" + threadNumber.getAndIncrement());
}
};
// 使用有界队列防止资源耗尽
BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(100);
// 拒绝策略：记录日志并抛出异常
RejectedExecutionHandler rejectionHandler = (r, executor) -> {
System.err.println("Task rejected: " + r.toString());
throw new RuntimeException("Thread pool is full!");
};
// 创建线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(
5, // 核心线程数
10, // 最大线程数
60L, // 空闲线程存活时间
TimeUnit.SECONDS,
workQueue,
namedFactory,
rejectionHandler
);
3. 提交任务与关闭线程池
使用 execute 或 submit 提交任务：
立即学习“Java免费学习笔记（深入）”；
// 执行无返回值任务executor.execute(() -> {
System.out.println("Task running in " + Thread.currentThread().getName());
});
// 提交有返回值任务
Future<String> future = executor.submit(() -> {
return "Task result";
});
try {
String result = future.get(3, TimeUnit.SECONDS);
} catch (Exception e) {
e.printStackTrace();
}
服务关闭时，务必优雅关闭线程池：
// 先拒绝新任务，再等待已提交任务完成executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 强制中断
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
4. 后端开发中的最佳实践
- 避免使用 Executors 创建的“快捷线程池”，它们可能使用无界队列导致内存溢出
- 根据业务场景设置合理的 core/max 线程数和队列大小，比如CPU密集型设为 CPU核数+1，IO密集型可适当增大
- 为线程池命名，方便在日志和监控中识别
- 配置合适的拒绝策略，如记录日志、降级处理或通知告警系统
- 结合 Spring 的 @Async 使用时，建议通过配置类注入自定义 ThreadPoolTaskExecutor
