在Java并发编程中，线程池是管理线程资源的核心工具。以下是几种常见线程池（通过Executors工具类创建）及其深度对比：

---

1. FixedThreadPool（固定大小线程池）

ExecutorService executor = Executors.newFixedThreadPool(5); // 固定5个线程

• 队列：LinkedBlockingQueue（无界队列）
• 特点：
  • 固定线程数，任务超出时进入无界队列等待
  • 线程长期存活，无超时机制
• 风险：任务激增时可能引发内存溢出（OOM）
• 场景：已知并发量的稳定负载任务（如内部系统）

---

2. CachedThreadPool（缓存线程池）

ExecutorService executor = Executors.newCachedThreadPool();

• 队列：SynchronousQueue（不存任务的直接传递队列）
• 特点：
  • 线程数无上限（Integer.MAX_VALUE），60秒超时销毁
  • 新任务到来时：
    • 有空闲线程 → 复用
    • 无空闲线程 → 立即创建新线程
• 风险：突发高并发时可能无限创建线程（CPU/内存耗尽）
• 场景：短生命周期的异步任务（如HTTP请求响应）

---

3. SingleThreadExecutor（单线程池）

ExecutorService executor = Executors.newSingleThreadExecutor();

• 队列：LinkedBlockingQueue（无界队列）
• 特点：
  • 仅1个工作线程，任务严格按顺序执行
  • 保证任务执行的串行化
• 风险：任务堆积时可能内存溢出
• 场景：需顺序执行的异步任务（如日志写入）

---

4. ScheduledThreadPool（定时任务线程池）

ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
executor.scheduleAtFixedRate(task, initialDelay, period, unit);

• 队列：DelayedWorkQueue（优先级队列）
• 特点：
  • 支持定时/周期性执行任务
  • 核心线程数固定，但任务延迟执行
• 场景：定时调度任务（如心跳检测、数据备份）

---

5. WorkStealingPool（工作窃取线程池）

ExecutorService executor = Executors.newWorkStealingPool();
// Java 8+ 基于ForkJoinPool

• 特点：
  • 并行度=CPU核心数（默认）
  • 采用Work-Stealing算法：空闲线程从其他线程队列窃取任务
• 优势：减少线程竞争，提高吞吐量
• 场景：大任务拆解分治（如并行计算）

---

线程池关键参数对比

线程池类型	核心线程数	最大线程数	任务队列	超时机制	风险点
FixedThreadPool	固定（自定义）	=核心线程数	无界队列	❌	无界队列OOM
CachedThreadPool	0	Integer.MAX_VALUE	同步队列（无容量）	60秒	线程数量爆炸
SingleThreadExecutor	1	1	无界队列	❌	无界队列OOM
ScheduledThreadPool	固定（自定义）	Integer.MAX_VALUE	延迟队列	❌	定时任务堆积
WorkStealingPool	=CPU核心数	无上限	分治任务队列	❌	任务依赖导致死锁

---

手动创建线程池（推荐方案）

直接使用ThreadPoolExecutor构造器是最佳实践：

ExecutorService customPool = new ThreadPoolExecutor(
    5,                             // 核心线程数
    20,                            // 最大线程数 (core < max)
    60, TimeUnit.SECONDS,           // 非核心线程空闲60秒销毁
    new ArrayBlockingQueue<>(100),  // 有界队列（容量100）
    new CustomThreadFactory(),      // 自定义线程工厂（命名/守护线程）
    new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略
);

核心参数解析：

1. 队列选择：

   • 有界队列（ArrayBlockingQueue）：控制资源，避免OOM
   • 无界队列：仅当任务量绝对可控时使用

2. 拒绝策略：

   策略名	行为
   AbortPolicy（默认）	抛出RejectedExecutionException
   CallerRunsPolicy	由提交任务的线程自己执行
   DiscardOldestPolicy	丢弃队列最旧的任务，重新提交当前任务
   DiscardPolicy	静默丢弃新任务

3. 线程工厂：

   • 自定义线程命名（排查问题）和守护属性

---

生产环境建议

1. 禁止使用无界队列

   • 用new ArrayBlockingQueue(capacity)替代无界队列

2. 线程数计算公式：

   • CPU密集型：核心数 = CPU核数 + 1（或Runtime.getRuntime().availableProcessors()）
   • IO密集型：核心数 = CPU核数 × [1 + (IO耗时/CPU耗时)]
     （经验值：常设为CPU核数 × 2）

3. 监控与调优：

   • 通过JMX监控ThreadPoolExecutor的：
     • getActiveCount()：活跃线程数
     • getQueue().size()：队列堆积量
   • 动态调整参数（如开源项目DynamicTp）

⚠️ 《阿里巴巴Java开发手册》强制要求：
线程池不允许使用Executors创建，必须通过ThreadPoolExecutor自定义参数，避免资源耗尽风险。

---

线程池选择流程图

最终结论：在复杂生产系统中，自定义ThreadPoolExecutor 是唯一可靠选择。