Java中应手动构造ThreadPoolExecutor实例而非使用Executors，以精准控制核心线程数、最大线程数、队列容量等7个参数，避免资源耗尽；同时自定义ThreadFactory和RejectedExecutionHandler可提升可监控性与可维护性。
Java 中使用 ThreadPoolExecutor 创建线程池，核心是手动构造其实例，而非依赖 Executors 工具类的封装方法。这样能更清晰地控制线程池行为，避免资源耗尽等隐患。
明确七个构造参数的含义
ThreadPoolExecutor 最常用的构造器有 7 个参数，缺一不可：
- corePoolSize：核心线程数，即使空闲也不会被回收（除非允许核心线程超时）
- maximumPoolSize：最大线程数，当任务队列满且当前线程数
- keepAliveTime：非核心线程空闲后最多存活时间，超时即终止
-
unit：
keepAliveTime的时间单位，如TimeUnit.SECONDS -
workQueue：阻塞任务队列，常用
LinkedBlockingQueue（无界）、ArrayBlockingQueue（有界）、SynchronousQueue（不存任务，直接转发） - threadFactory：线程创建工厂，用于自定义线程命名、是否为守护线程等
-
handler：拒绝策略，当线程数达上限且队列已满时执行，常见有：
AbortPolicy（抛异常）、CallerRunsPolicy（由调用线程执行任务）、DiscardPolicy（静默丢弃）、DiscardOldestPolicy（丢弃队首任务再尝试提交）
推荐的基础创建方式（有界队列 + 拒绝策略）
避免使用 Executors.newFixedThreadPool()（内部用无界队列）或 newCachedThreadPool()（无界最大线程数），容易引发 OOM 或资源失控。应显式指定有界队列和拒绝策略：
ThreadPoolExecutor executor = new ThreadPoolExecutor(
2, // corePoolSize
4, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(10), // 有界队列，容量 10
new ThreadFactory() {
private final AtomicInteger count = new AtomicInteger(0);
@Override
public Thread newThread(Runnable r) {
return new Thread(r, "my-pool-thread-" + count.incrementAndGet());
}
},
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝时由主线程执行
);
关键操作与生命周期管理
创建后需注意启动、提交任务、优雅关闭等环节：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
- 提交任务用
execute(Runnable)或submit(Callable)，后者可获取Future结果 - 不再接受新任务：调用
shutdown()（已提交任务继续执行） - 立即停止所有运行中任务：调用
shutdownNow()（返回未执行的任务列表，尝试中断正在运行的线程） - 等待所有任务完成：配合
awaitTermination(long, TimeUnit)使用，建议加超时判断 - 务必在合适时机调用
shutdown()，否则 JVM 不会退出（因线程池默认线程是非守护线程）
一个实用的封装建议
为避免重复写构造逻辑，可封装成工具方法或 Bean（Spring 环境下建议声明为 @Bean）：
public static ThreadPoolExecutor createMyPool() {
return new ThreadPoolExecutor(
4, 8,
30, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100),
r -> {
Thread t = new Thread(r);
t.setName("biz-task-" + counter.incrementAndGet());
t.setDaemon(false);
return t;
},
new ThreadPoolExecutor.AbortPolicy()
);
}
这样既可控又易复用，也方便统一监控和治理。
