Java 线程池通过复用线程、控制并发数及管理任务队列，解决高并发场景下频繁创建销毁线程的性能开销问题。核心类为 ThreadPoolExecutor，包含 7 个关键参数：corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory 及 handler。工作流程遵循核心线程→任务队列→非核心线程→拒绝策略的顺序。生产环境建议自定义线程池而非使用 Executors 工具类，需根据 CPU 密集型或 IO 密集型任务类型合理配置参数，并妥善处理生命周期关闭与拒绝策略，以避免内存溢出或系统过载。
在高并发场景下，频繁创建和销毁线程会带来巨大的性能开销 —— 线程的创建需要分配栈空间、寄存器等系统资源，销毁需要回收这些资源，大量的线程还会引发 CPU 上下文切换的成本飙升。线程池作为 Java 并发编程的核心工具，通过复用线程、控制并发数、管理任务队列，有效解决了上述问题，是提升高并发程序性能的关键手段。
本文将深入剖析线程池的核心原理、ThreadPoolExecutor 的 7 个核心参数、工作流程，并结合实战案例讲解线程池的配置与使用。
Java 线程池的核心接口和类位于 java.util.concurrent 包下，核心结构如下：
ThreadPoolExecutor 的核心构造方法如下：
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
这 7 个参数决定了线程池的运行机制，缺一不可，下面逐一解析：
**定义：**线程池长期维持的线程数量，即使线程处于空闲状态，也不会被销毁（除非设置了 allowCoreThreadTimeOut(true)）。
工作机制：
**定义：**线程池允许创建的最大线程数量，是线程池的容量上限。
**工作机制：**当任务队列已满，且提交的任务数 > corePoolSize 时，线程池会创建新的非核心线程执行任务，直到线程数达到 maximumPoolSize。
**定义：**keepAliveTime 表示非核心线程的空闲存活时长，unit 是时间单位（如 TimeUnit.SECONDS）。
**工作机制：**当非核心线程的空闲时间超过 keepAliveTime，该线程会被销毁，直到线程池中的线程数等于 corePoolSize。
扩展：通过 allowCoreThreadTimeOut(true) 可以让核心线程也遵循该存活时间规则。
**定义：**用于存放等待执行的任务的阻塞队列，必须是 BlockingQueue 的实现类。
常用队列类型：
| 队列类型 | 核心特点 | 适用场景 |
|---|---|---|
| ArrayBlockingQueue | 有界队列，初始化时指定容量，基于数组实现 | 任务量可控，需要限制队列长度的场景 |
| LinkedBlockingQueue | 可选有界/无界队列，基于链表实现，默认容量为 Integer.MAX_VALUE | 任务量不确定，需要缓冲大量任务的场景 |
| SynchronousQueue | 同步队列，不存储任务，提交的任务必须有线程立即接收 | 任务需要立即执行，无缓冲需求的场景（如 newCachedThreadPool） |
| PriorityBlockingQueue | 优先级队列，任务按优先级排序执行 | 需要按任务优先级处理的场景 |
**定义：**用于创建线程的工厂类，实现 ThreadFactory 接口，默认使用 Executors.defaultThreadFactory()。
核心作用：
ThreadFactory customThreadFactory = new ThreadFactory() {
private final AtomicInteger count = new AtomicInteger(1);
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r);
thread.setName("custom-thread-" + count.getAndIncrement());
thread.setPriority(Thread.NORM_PRIORITY);
return thread;
}
};
**定义：**当任务队列已满且线程数达到 maximumPoolSize 时，线程池对新提交任务的处理策略，实现 RejectedExecutionHandler 接口。
JDK 默认提供 4 种拒绝策略：
| 拒绝策略 | 核心逻辑 | 适用场景 |
|---|---|---|
| AbortPolicy（默认） | 直接抛出 RejectedExecutionException 异常，拒绝任务 | 不允许任务丢失，需要快速感知系统过载的场景 |
| CallerRunsPolicy | 由提交任务的线程（如主线程）直接执行该任务 | 任务重要性低，允许主线程承担任务执行的场景 |
| DiscardPolicy | 直接丢弃新提交的任务，不抛出异常 | 允许任务丢失，对任务完整性要求不高的场景 |
| DiscardOldestPolicy | 丢弃任务队列中最旧的任务，然后尝试提交新任务 | 任务具有时效性，新任务比旧任务更重要的场景 |
线程池处理任务的流程遵循核心线程→任务队列→非核心线程→拒绝策略的顺序，具体步骤如下：
核心流程示意图：
生产环境中，不推荐使用 Executors 工具类创建线程池（如 newFixedThreadPool 使用无界队列，可能导致内存溢出；newCachedThreadPool 最大线程数为 Integer.MAX_VALUE，可能创建大量线程），而是通过 ThreadPoolExecutor 自定义线程池，精准控制参数。
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
/**
* 自定义线程池：处理高并发订单任务
*/
public class OrderThreadPoolDemo {
// 自定义线程工厂
private static final ThreadFactory ORDER_THREAD_FACTORY = new ThreadFactory() {
private final AtomicInteger threadCount = new AtomicInteger(1);
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r);
thread.setName("order-handle-thread-" + threadCount.getAndIncrement());
thread.setDaemon(false); // 非守护线程
thread.setPriority(Thread.NORM_PRIORITY);
return thread;
}
};
// 自定义拒绝策略：记录日志 + 抛出异常
private static final RejectedExecutionHandler ORDER_REJECT_HANDLER = (r, executor) -> {
System.out.println("任务" + r.toString() + "被拒绝，线程池状态：" +
"核心线程数=" + executor.getCorePoolSize() +
",最大线程数=" + executor.getMaximumPoolSize() +
",活跃线程数=" + executor.getActiveCount() +
",任务队列数=" + executor.getQueue().size());
throw new RejectedExecutionException("订单任务处理过载，任务被拒绝");
};
// 初始化线程池
private static final ThreadPoolExecutor ORDER_THREAD_POOL = new ThreadPoolExecutor(
5, // 核心线程数：CPU 核心数*2（假设 CPU 为 4 核，可根据实际调整）
10, // 最大线程数：核心线程数*2
60, // 非核心线程空闲存活时间：60 秒
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(100), // 有界任务队列：容量 100
ORDER_THREAD_FACTORY,
ORDER_REJECT_HANDLER
);
// 订单处理任务
static class OrderHandleTask implements Runnable {
private final String orderId;
public OrderHandleTask(String orderId) {
this.orderId = orderId;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + " 处理订单：" + orderId);
try {
// 模拟订单处理耗时
Thread.sleep(500);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
@Override
public String toString() {
return "OrderHandleTask{" + "orderId='" + orderId + '\'' + '}';
}
}
public static void main(String[] args) {
try {
// 提交 150 个订单任务，测试线程池处理能力
for (int i = 1; i <= 150; i++) {
ORDER_THREAD_POOL.submit(new OrderHandleTask("ORDER_" + i));
}
} finally {
// 关闭线程池：等待所有任务执行完毕后关闭
ORDER_THREAD_POOL.shutdown();
try {
// 等待线程池关闭，超时时间 10 秒
if (!ORDER_THREAD_POOL.awaitTermination(10, TimeUnit.SECONDS)) {
// 超时后强制关闭
ORDER_THREAD_POOL.shutdownNow();
}
} catch (InterruptedException e) {
ORDER_THREAD_POOL.shutdownNow();
}
}
}
}
线程池参数的配置需要结合任务类型和硬件资源，核心参考公式如下：
线程池的生命期分为 RUNNING→SHUTDOWN→STOP→TIDYING→TERMINATED 五个状态，核心管理方法如下：
**核心注意点：**线程池使用完毕后必须关闭，否则核心线程会一直存活，导致 JVM 无法正常退出。
本文深入讲解了线程池的核心原理、ThreadPoolExecutor 的 7 个核心参数、工作流程与实战配置。线程池是高并发开发中必不可少的工具，合理配置线程池参数能显著提升程序的性能和稳定性。在实际开发中，应避免使用 Executors 工具类，而是通过 ThreadPoolExecutor 自定义线程池，结合业务场景精准控制核心线程数、最大线程数、任务队列和拒绝策略。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online