在 Java 线程池（ThreadPoolExecutor）中，corePoolSize（核心线程数）、maximumPoolSize（最大线程数）和任务队列（workQueue）共同决定了任务的调度和执行逻辑。以下是它们的核心关系和工作流程：

1. 核心参数定义

2. 任务提交流程

当向线程池提交任务时，线程池的调度逻辑如下：

1. 核心线程处理
2. 如果当前运行的线程数 < corePoolSize，则立即创建新线程处理任务（即使有空闲线程）。
3. 如果运行的线程数 ≥ corePoolSize，则尝试将任务加入队列。
4. 队列缓存
5. 如果队列未满，任务被放入队列等待执行。
6. 如果队列已满，则尝试创建非核心线程处理任务（不超过maximumPoolSize）。
7. 触发拒绝策略
8. 如果队列已满且线程数已达到maximumPoolSize，则触发拒绝策略（如抛出异常、丢弃任务等）。

3. 参数关系示意图

4. 队列类型的影响

不同的队列类型会显著改变线程池的行为：

无界队列（如 LinkedBlockingQueue）

• 特点：队列容量为 Integer.MAX_VALUE（约21亿），永远不会满。
• 行为：
• 线程数最多为 corePoolSize，maximumPoolSize 参数无效。
• 任务会无限堆积，可能导致内存溢出（OOM）。
• 典型场景：Executors.newFixedThreadPool(n) 使用无界队列。

有界队列（如 ArrayBlockingQueue）

• 特点：队列容量固定，当队列满时触发扩容或拒绝策略。
• 行为：
• 当队列满且线程数 < maximumPoolSize 时，创建新线程处理任务。
• 当队列满且线程数 = maximumPoolSize 时，触发拒绝策略。
• 典型场景：需要控制资源使用的场景（如高并发请求限流）。

同步移交队列（如 SynchronousQueue）

• 特点：队列不缓存任务，直接移交任务给线程。
• 行为：
• 如果没有空闲线程且线程数 < maximumPoolSize，则创建新线程。
• 如果线程数 = maximumPoolSize，立即触发拒绝策略。
• 典型场景：Executors.newCachedThreadPool() 使用该队列。

5. 参数配置建议

CPU 密集型任务

• 特点：任务主要消耗 CPU 资源（如计算、循环）。
• 配置：
• corePoolSize = maximumPoolSize = CPU核心数（防止过多线程竞争 CPU）。
• 使用有界队列（避免任务堆积，需配合拒绝策略）。

IO 密集型任务

• 特点：任务涉及网络、磁盘等阻塞操作（如数据库查询、HTTP 请求）。
• 配置：
• maximumPoolSize > corePoolSize（利用非核心线程处理阻塞时的堆积任务）。
• 使用无界队列或有界队列（根据场景选择，需注意资源限制）。

混合型任务

• 特点：既有 CPU 计算，又有 IO 阻塞。
• 配置：
• 根据实际场景调整 corePoolSize 和 maximumPoolSize。
• 使用有界队列 + 合理的拒绝策略（如降级、重试）。

6. 示例代码

7. 常见问题

Q1：为什么任务没有被拒绝，但线程数一直不增加？

• 原因：使用了无界队列（如 LinkedBlockingQueue），队列永远不会满，因此不会触发创建非核心线程。

Q2：如何避免任务堆积导致 OOM？

• 方案：
• 使用有界队列。
• 设置合理的 maximumPoolSize。
• 配合拒绝策略（如记录日志、降级处理）。

Q3：如何监控线程池状态？

• 方法：
• 通过 executor.getQueue().size() 监控队列大小。
• 通过 executor.getActiveCount() 监控活跃线程数。

总结

• corePoolSize 是线程池的“基准容量”，maximumPoolSize 是“弹性扩容上限”，队列是任务的“缓冲区”。
• 队列类型和容量决定了线程池的弹性策略，需根据任务特性（CPU/IO 密集型）合理选择。
• 配置线程池时，需平衡吞吐量、资源占用和任务响应时间，避免内存溢出或任务饥饿。