深入理解线程池：参数、流程与实战应用
一、线程池的核心价值
池化思想通过资源预分配与复用提升效率，线程池将线程预先创建并管理，避免了频繁申请/销毁线程的系统调用开销。相较于每次从内核态创建线程，线程池操作完全在用户态完成，具有更高的可控性和执行效率。
二、ThreadPoolExecutor核心参数详解
| 参数 | 作用 |
|---|---|
corePoolSize | 核心线程数（常驻线程，即使空闲也不会回收） |
maximumPoolSize | 最大线程数（核心线程+非核心线程），支持动态扩容 |
keepAliveTime | 非核心线程空闲存活时间（超时自动回收） |
workQueue | 任务队列（缓冲待执行任务），常用实现：LinkedBlockingQueue（无界队列） |
threadFactory | 线程工厂（定制线程属性如名称、优先级） |
handler | 拒绝策略（队列满且线程达上限时的处理逻辑） |
三、线程池工作流程（生产者-消费者模型）
- 任务提交：调用
submit()或execute()提交Runnable任务。 - 资源分配：
- 若核心线程未满 → 立即创建新线程执行
- 若核心线程已满 → 任务进入工作队列等待
- 若队列已满且线程未达到最大数 → 创建非核心线程执行
- 若队列已满且线程已达上限 → 触发拒绝策略
- 线程回收：非核心线程在空闲超过
keepAliveTime后被销毁。
四、Executors快速创建线程池
1. 缓存型线程池（适合短时高并发）
ExecutorService cachedPool = Executors.newCachedThreadPool();
- 特点：最大线程数
Integer.MAX_VALUE（可无限扩容），空闲线程60秒回收。 - 风险：任务量暴增时可能耗尽系统资源。
2. 固定型线程池（适合长期稳定负载）
ExecutorService fixedPool = Executors.newFixedThreadPool(8);
- 特点：核心线程数=最大线程数（无扩容），使用无界队列
LinkedBlockingQueue。 - 风险：队列无限增长可能导致OOM。
3. 其他工厂方法
- 单线程池：
Executors.newSingleThreadExecutor()（串行执行）。 - 定时任务池：
Executors.newScheduledThreadPool()（延迟/周期性任务）。
五、线程池配置
1. 线程数设置
通过实验的方式找到合适的线程池个数：给线程池设置不同的线程数，分别进行性能测试，关注响应时间/消耗的资源，挑选一个合适的数值。
2. 拒绝策略选择
| 策略 | 行为特点 | 适用场景 |
|---|---|---|
AbortPolicy（默认） | 抛出 RejectedExecutionException | 需快速感知系统过载 |
CallerRunsPolicy | 由提交任务的线程执行被拒任务 | 保证任务不丢失，降级处理 |
DiscardOldestPolicy | 丢弃队列最老任务，尝试提交新任务 | 容忍数据延迟，优先处理新请求 |
DiscardPolicy | 静默丢弃新提交任务 | 极端过载保护 |
六、线程池使用示例
// 自定义线程池（规避无界队列风险）
ThreadPoolExecutor customPool = new ThreadPoolExecutor(4, // corePoolSize8, // maximumPoolSize30, TimeUnit.SECONDS,new ArrayBlockingQueue<>(1000), // 有界队列Executors.defaultThreadFactory(),new ThreadPoolExecutor.CallerRunsPolicy()
);// 提交任务
customPool.submit(() -> {System.out.println(Thread.currentThread().getName() + "执行任务");
});// 终止线程池里的所有线程
customPool.shutdown();
结语
线程池是并发编程的基石，理解其参数与工作机理能有效避免资源耗尽与性能瓶颈。