做欧美网站网站优化推广教程

一、线程池的核心价值

池化思想通过资源预分配与复用提升效率，线程池将线程预先创建并管理，避免了频繁申请/销毁线程的系统调用开销。相较于每次从内核态创建线程，线程池操作完全在用户态完成，具有更高的可控性和执行效率。

---

二、ThreadPoolExecutor核心参数详解

参数	作用
corePoolSize	核心线程数（常驻线程，即使空闲也不会回收）
maximumPoolSize	最大线程数（核心线程+非核心线程），支持动态扩容
keepAliveTime	非核心线程空闲存活时间（超时自动回收）
workQueue	任务队列（缓冲待执行任务），常用实现：LinkedBlockingQueue（无界队列）
threadFactory	线程工厂（定制线程属性如名称、优先级）
handler	拒绝策略（队列满且线程达上限时的处理逻辑）

---

三、线程池工作流程（生产者-消费者模型）

1. 任务提交：调用 submit() 或 execute() 提交 Runnable 任务。
2. 资源分配：
   • 若核心线程未满 → 立即创建新线程执行
   • 若核心线程已满 → 任务进入工作队列等待
   • 若队列已满且线程未达到最大数 → 创建非核心线程执行
   • 若队列已满且线程已达上限 → 触发拒绝策略
3. 线程回收：非核心线程在空闲超过 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();

---

结语

线程池是并发编程的基石，理解其参数与工作机理能有效避免资源耗尽与性能瓶颈。