面试线程池原理深度解析
从源码底层到生产环境调优，全方位掌握 ThreadPoolExecutor 核心机制，助你从容应对高薪面试。
一、 为什么需要线程池？
在Java并发编程中，线程池（ThreadPool）是一个至关重要的概念。很多初学者可能会问：“既然 new Thread() 这么方便，为什么还要引入复杂的线程池？” 答案在于资源控制和性能优化。频繁创建和销毁线程是非常消耗系统资源的操作，尤其是在高并发场景下。线程池通过复用已创建的线程，降低了资源消耗，提高了响应速度，并且提供了对线程的集中管理功能。
在面试中，考察 线程池原理 不仅仅是考察你是否知道如何创建线程池，更考察你是否理解其背后的设计思想，例如：如何平衡并发度与系统负载？如何处理突发流量？如何保证任务的安全执行？
1.1 线程池的优势
- ⚡ 降低资源消耗：通过重复利用已创建的线程降低线程创建和销毁造成的消耗。
- ⚡ 提高响应速度：当任务到达时，任务可以不需要等到线程创建就能立即执行。
- ⚡ 提高线程的可管理性：线程是稀缺资源，如果无限制创建，不仅会消耗系统资源，还会因为资源的不均匀分配导致负载不均，如果进行统一管理，可以提高线程的可管理性。
二、 ThreadPoolExecutor 七大参数详解
Java 中常用的线程池创建方式是通过 ThreadPoolExecutor 类。面试官经常会要求手写线程池的初始化代码，因此必须牢记这七个核心参数。这七个参数决定了线程池的行为模式。
| 参数名 | 类型 | 描述 |
|---|---|---|
| corePoolSize | int | 核心线程数。线程池中的常驻核心线程数。 |
| maximumPoolSize | int | 最大线程数。线程池能够创建的最大线程数。 |
| keepAliveTime | long | 存活时间。超过 corePoolSize 的多余空闲线程，在等待新任务时的最大存活时间。 |
| unit | TimeUnit | 时间单位。用于指定 keepAliveTime 的单位。 |
| workQueue | BlockingQueue | 任务队列。用于存储等待执行的任务。 |
| threadFactory | ThreadFactory | 线程工厂。用于指定为线程池创建新线程的方式。 |
| handler | RejectedExecutionHandler | 拒绝策略。当任务无法被执行时采取的对策。 |
2.1 核心线程与空闲线程
理解 corePoolSize 和 maximumPoolSize 的区别至关重要。默认情况下，核心线程会一直存活，即使处于闲置状态也不会被回收。只有将 allowCoreThreadTimeOut 设置为 true 时，核心线程才会超时回收。而超出核心线程数的线程（即救急线程），在空闲时间超过 keepAliveTime 后会被回收。
三、 任务提交与执行流程（核心考点）
这是面试中最高频的问题：“当一个任务提交给线程池时，线程池是如何处理的？” 理解这个流程是掌握 线程池原理 的关键。流程可以分为以下几个步骤：
当一个新的任务提交到线程池中，线程池会检查当前运行的线程数是否小于 corePoolSize。如果小于，则创建一个新线程（核心线程）来执行该任务。
如果当前运行的线程数等于或大于 corePoolSize，则尝试将任务放入 workQueue（任务队列）中等待。
如果任务队列已满（例如使用了有界队列），则检查当前运行的线程数是否小于 maximumPoolSize。如果小于，则创建一个新线程（非核心线程）来执行该任务。
如果任务队列已满，且当前运行的线程数等于 maximumPoolSize，则触发 handler（拒绝策略）。
3.1 流程图代码示例
// 伪代码逻辑展示
if (currentPoolSize < corePoolSize) {
startCoreThread(task);
} else if (workQueue.offer(task)) {
// 任务进入队列等待
} else if (currentPoolSize < maximumPoolSize) {
startNonCoreThread(task);
} else {
reject(task); // 执行拒绝策略
}
四、 四种拒绝策略解析
当线程池达到饱和状态时，必须采取相应的措施来处理无法执行的任务。JDK 提供了四种默认的拒绝策略，但生产环境中我们通常建议使用自定义策略。
① AbortPolicy（默认）
直接抛出 RejectedExecutionException 异常，阻止系统正常运行。这是 JDK 的默认策略，简单粗暴，适合对数据一致性要求极高、不允许丢失任务的场景。
② CallerRunsPolicy
由调用线程（提交任务的线程）处理该任务。这提供了一种简单的反馈控制机制，能够减缓新任务的提交速度，给线程池一点喘息时间。
③ DiscardPolicy
直接丢弃任务，但不抛出异常。适用于对任务结果不敏感、允许部分丢失的场景，如日志收集。
④ DiscardOldestPolicy
丢弃队列中最老的一个任务（即下一个将被执行的任务），然后尝试重新提交当前任务。这种方式可能会导致大量任务被丢弃，需谨慎使用。
五、 线程池参数调优实战
在实际工作中，如何设置 corePoolSize 和 maximumPoolSize 是一个难题。这取决于任务的类型：
5.1 CPU 密集型任务
CPU 密集型任务意味着该任务几乎不做 I/O 操作，只进行计算。此时，线程数应尽可能少，以减少上下文切换的开销。
建议配置： corePoolSize = N + 1，其中 N 为 CPU 核数。加 1 是为了防止某个线程偶尔因缺页中断或其他原因导致暂时停止工作。
5.2 IO 密集型任务
IO 密集型任务涉及大量的 I/O 操作，线程大部分时间都在等待 I/O 完成。此时，可以设置更多的线程以提高 CPU 利用率。
建议配置： corePoolSize = 2 N + 1 或者根据具体 I/O 延迟进行调整，通常可以设置得较大，如 N 2 到 N (1 + 1/等待时间比)。
5.3 混合型任务
可以通过将任务分解为 CPU 密集型和 IO 密集型两部分，分别使用不同的线程池处理。
// CPU 密集型线程池创建示例
int cpuCore = Runtime.getRuntime().availableProcessors();
ExecutorService cpuPool = new ThreadPoolExecutor(
cpuCore + 1,
cpuCore + 1,
0L,
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(100),
new ThreadFactoryBuilder().setNameFormat("cpu-pool-%d").build(),
new ThreadPoolExecutor.AbortPolicy()
);
// IO 密集型线程池创建示例
// 假设平均等待时间与运算时间之比为 1:1，则线程数可设为 CPU核数 2
int ioCore = Runtime.getRuntime().availableProcessors() 2;
ExecutorService ioPool = new ThreadPoolExecutor(
ioCore,
ioCore 2,
60L,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(1000),
new ThreadFactoryBuilder().setNameFormat("io-pool-%d").build(),
new ThreadPoolExecutor.CallerRunsPolicy()
);