题目详细答案

1. 线程池刚创建时，里面没有一个线程。任务队列是作为参数传进来的。不过，就算队列里面有任务，线程池也不会马上执行它们。

1. 当调用 execute() 方法添加一个任务时，线程池会做如下判断：

a) 如果正在运行的线程数量小于 corePoolSize，那么马上创建线程运行这个任务；

b) 如果正在运行的线程数量大于或等于 corePoolSize，那么将这个任务放入队列；

c) 如果这时候队列满了，而且正在运行的线程数量小于 maximumPoolSize，那么还是要创建非核心线程立刻运行这个任务；

d) 如果队列满了，而且正在运行的线程数量大于或等于 maximumPoolSize，那么线程池会抛出异常 RejectExecutionException。

1. 当一个线程完成任务时，它会从队列中取下一个任务来执行。

1. 当一个线程无事可做，超过一定的时间（keepAliveTime）时，线程池会判断，如果当前运行的线程数大于 corePoolSize，那么这个线程就被停掉。所以线程池的所有任务完成后，它最终会收缩到 corePoolSize 的大小。

Java 线程池工作原理：从设计到实践

在 Java 并发编程中，线程池是一种高效管理线程资源的机制。它通过复用线程、控制并发规模和缓冲任务峰值，显著提升了多线程应用的性能与稳定性。本文将深入解析 Java 线程池的工作原理，从核心参数到完整工作流程，帮助开发者更好地理解和应用这一重要组件。

线程池的核心设计思想

线程池的本质是一种 "池化" 技术，其核心目标是解决线程创建销毁的高昂成本问题。在传统多线程编程中，为每个任务创建新线程会带来三个主要问题：

• 线程创建和销毁需要操作系统内核参与，开销较大
• 大量线程会消耗过多内存资源，可能导致 OOM
• 过多线程上下文切换会严重影响系统性能

线程池通过预先创建一定数量的线程，复用它们处理多个任务，从而有效解决了上述问题。同时，它还提供了任务队列和拒绝策略等机制，实现了对系统资源的精细化控制。

核心参数解析

Java 线程池的核心实现类ThreadPoolExecutor通过七个参数定义其行为特性：

public ThreadPoolExecutor(
    int corePoolSize,                  // 核心线程数
    int maximumPoolSize,               // 最大线程数
    long keepAliveTime,                // 空闲线程存活时间
    TimeUnit unit,                     // 时间单位
    BlockingQueue<Runnable> workQueue, // 任务等待队列
    ThreadFactory threadFactory,       // 线程工厂
    RejectedExecutionHandler handler   // 拒绝策略
)

这些参数共同构成了线程池的工作模型，理解它们是掌握线程池原理的关键：
 

1. corePoolSize（核心线程数）：线程池长期维持的最小线程数量，核心线程创建后不会被轻易销毁（除非设置allowCoreThreadTimeOut(true)）
2. maximumPoolSize（最大线程数）：线程池允许创建的最大线程数量，包含核心线程和临时线程
3. keepAliveTime + unit：非核心线程的空闲存活时间，超时后会被销毁以释放资源
4. workQueue（任务队列）：用于缓存等待执行的任务，常见实现有：

• • LinkedBlockingQueue：无界队列，可缓存大量任务
  • ArrayBlockingQueue：有界队列，需指定固定容量
  • SynchronousQueue：直接传递队列，不缓存任务

1. threadFactory（线程工厂）：用于创建新线程，可自定义线程名称、优先级等属性
2. handler（拒绝策略）：当任务无法被处理时的应对策略，JDK 提供四种默认实现：

• • AbortPolicy：抛出RejectExecutionException（默认）
  • CallerRunsPolicy：让提交任务的线程自己执行
  • DiscardPolicy：直接丢弃新任务
  • DiscardOldestPolicy：丢弃队列中最旧的任务

完整工作流程

线程池处理任务的过程可分为四个关键阶段，严格按照顺序执行：

阶段一：核心线程池判断

当通过execute()方法提交任务时，线程池首先检查当前运行的线程数是否小于核心线程数（corePoolSize）：

• 如果是，立即创建新的核心线程执行该任务
• 如果否，进入下一阶段判断

这一阶段确保了线程池始终维持核心数量的线程，以应对日常任务负载。

阶段二：任务队列判断

当核心线程池已满时，线程池会检查任务队列是否还有空间：

• 如果队列未满，将任务加入队列等待执行
• 如果队列已满，进入下一阶段判断

任务队列起到了缓冲作用，避免了在任务峰值时立即创建大量线程。

阶段三：最大线程池判断

当任务队列已满时，线程池会检查当前运行的线程数是否小于最大线程数（maximumPoolSize）：

• 如果是，创建非核心线程（临时线程）执行该任务
• 如果否，进入下一阶段处理

这一阶段允许线程池在任务峰值时临时扩容，提高处理能力。

阶段四：执行拒绝策略

当所有线程都在忙碌且队列已满时，线程池将触发预设的拒绝策略：

• 默认情况下会抛出RejectExecutionException
• 也可根据业务需求选择其他策略，如让提交者自行处理

拒绝策略是系统的最后一道防线，防止任务无限制堆积导致系统崩溃。

线程生命周期管理

线程池对线程的创建和销毁有精细化的管理机制：

1. 线程创建：

• • 核心线程：随任务提交逐步创建，直到达到 corePoolSize
  • 非核心线程：仅在队列满且需要处理超额任务时创建

1. 线程销毁：

• • 非核心线程：当空闲时间超过 keepAliveTime 时自动销毁
  • 核心线程：默认不会销毁，除非设置allowCoreThreadTimeOut(true)

1. 任务执行循环：
   线程完成当前任务后，会从队列中获取下一个任务继续执行，实现线程复用

这种机制确保了线程池在负载变化时能够弹性伸缩，平衡资源消耗和处理能力。

实际应用中的注意事项

1. 参数配置原则：

• • 对于 CPU 密集型任务：核心线程数不宜过多，通常设为 CPU 核心数 + 1
  • 对于 IO 密集型任务：核心线程数可以多些，通常设为 CPU 核心数 * 2

1. 队列选择：

• • 无界队列可能导致内存溢出，需谨慎使用
  • 有界队列配合合适的拒绝策略，可更好地控制系统负载

1. 异常处理：

• • 线程池不会主动捕获任务中的异常，需自行处理
  • 可通过ThreadPoolExecutor.submit()获取返回结果和异常信息

1. 监控与调优：

• • 利用线程池的getPoolSize()、getActiveCount()等方法监控状态
  • 根据实际运行情况动态调整核心参数