Java线程池ThreadPoolExecutor详解与最佳实践
线程池的核心优势
线程池是池化技术在并发编程中的典型应用，旨在提升资源利用率并降低系统开销。相比频繁创建和销毁线程，线程池通过复用已有线程来执行任务，具有以下显著优点：
- 减少资源消耗：避免重复创建和销毁线程带来的性能损耗。
- 提升响应速度：任务到达时可立即由空闲线程处理，无需等待线程初始化。
- 增强可控性：统一管理线程生命周期，防止无限制创建导致系统不稳定或内存溢出（OOM）。
Executor 框架结构解析
自JDK 5起引入的 Executor 框架为线程管理提供了高级抽象，其核心组件包括任务定义、执行机制与结果获取三部分。
任务类型：Runnable 与 Callable
两类任务接口用于提交给线程池执行：
@FunctionalInterface
public interface Runnable {
void run(); // 无返回值，不抛异常
}
@FunctionalInterface
public interface Callable<T> {
T call() throws Exception; // 支持返回值和异常抛出
}
推荐对无需返回结果的任务使用 Runnable；若需获取执行结果或捕获检查异常，则应选用 Callable。两者可通过 Executors.callable() 方法相互转换。
执行引擎：ExecutorService 接口
Executor 是最顶层接口，仅包含一个 execute(Runnable) 方法。扩展后的 ExecutorService 提供了更丰富的控制能力，如任务提交、关闭管理和异步结果获取。
关键实现类包括：
ThreadPoolExecutor：通用线程池实现。ScheduledThreadPoolExecutor：支持定时/周期性任务调度，继承自ThreadPoolExecutor。
类继承关系如下：
interface Executor
└── interface ExecutorService extends Executor
└── abstract class AbstractExecutorService implements ExecutorService
└── class ThreadPoolExecutor extends AbstractExecutorService
└── class ScheduledThreadPoolExecutor extends ThreadPoolExecutor
异步结果：Future 接口
当通过 submit() 提交任务时，会返回一个 Future 对象，代表尚未完成的计算结果。常用方法包括：
get()：阻塞当前线程直至任务完成。get(long timeout, TimeUnit unit)：设定最长等待时间。cancel(boolean mayInterruptIfRunning)：尝试取消任务执行。
FutureTask 是 Future 的具体实现，同时实现了 Runnable 接口，可用于直接提交到线程池。
ThreadPoolExecutor 构造参数详解
推荐通过构造函数显式创建线程池，而非使用 Executors 工具类，以明确运行规则并规避风险。主要参数如下：
public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
- corePoolSize：核心线程数，即使空闲也不会被回收（除非设置允许）。
- maximumPoolSize：最大线程数，限定了线程池能容纳的总线程上限。
- workQueue：任务队列，用于暂存待处理任务。常见实现有
LinkedBlockingQueue、SynchronousQueue等。 - keepAliveTime + unit：非核心线程空闲存活时间，超时后将被终止。
- threadFactory：自定义线程创建方式，便于命名或设置优先级。
- handler：拒绝策略，当任务无法提交时触发。
内置拒绝策略说明
| 策略 | 行为描述 |
|---|---|
AbortPolicy | 默认策略，抛出 RejectedExecutionException 异常。 |
CallerRunsPolicy | 由调用者线程直接执行该任务，减缓提交速率。 |
DiscardPolicy | 静默丢弃新任务。 |
DiscardOldestPolicy | 丢弃队列中最旧的任务，然后重试提交新任务。 |
对于高可用系统，建议采用 CallerRunsPolicy 防止请求丢失，同时起到流量削峰作用。
为什么不推荐使用 Executors 创建线程池？
根据《阿里巴巴 Java 开发手册》，禁止使用 Executors 工厂方法创建线程池，原因如下：
- FixedThreadPool / SingleThreadExecutor：底层使用
LinkedBlockingQueue，其容量为Integer.MAX_VALUE，可能导致大量任务积压引发 OOM。 - CachedThreadPool：最大线程数为
Integer.MAX_VALUE，在高负载下可能创建过多线程，耗尽系统资源。
因此，应当始终使用 ThreadPoolExecutor 显式指定参数，确保资源可控。
线程池状态控制方法对比
| 方法 | 功能说明 |
|---|---|
shutdown() | 进入 SHUTDOWN 状态，不再接收新任务，但会完成已提交任务。 |
shutdownNow() | 进入 STOP 状态，尝试中断正在运行的任务，并返回未执行的任务列表。 |
isShutdown() | 判断是否已调用 shutdown 方法。 |
isTerminated() | 判断所有任务是否均已结束（需配合 awaitTermination 使用）。 |
execute 与 submit 方法差异
execute(Runnable)：适用于无需关注执行结果的任务，无法得知任务是否成功执行。submit(Callable/Runnable)：返回Future对象，支持获取结果或判断执行状态，适合需要同步等待结果的场景。
合理设置线程池大小
线程数量配置不当会导致资源浪费或上下文切换频繁，影响整体性能。应根据任务类型选择合适公式：
CPU 密集型任务
此类任务主要消耗 CPU 资源，例如大数据排序、加密运算等。建议设置线程数为：
N + 1
其中 N 为 CPU 核心数，+1 是为了应对可能出现的页缺失等情况，保证 CPU 始终处于忙碌状态。
I/O 密集型任务
涉及网络请求、文件读写等操作，线程大部分时间处于等待 I/O 完成的状态。此时可适当增加线程数以提高吞吐量：
2 * N
也可基于以下经验公式估算：
线程数 = CPU核心数 × (1 + 平均等待时间 / 平均CPU处理时间)
如何区分任务类型？
- CPU密集型：程序主要进行内存计算，如数值计算、图像处理。
- I/O密集型：程序频繁进行外部设备交互，如数据库查询、HTTP调用、磁盘读写。
实际开发中可通过监控工具观察 CPU 使用率与线程阻塞情况辅助判断。
