ThreadPoolExecutor中corePoolSize和maximumPoolSize

### ThreadPoolExecutor 中 `corePoolSize` 和 `maximumPoolSize` 的区别及作用 #### 参数定义 `corePoolSize` 是指线程池的核心线程数，这些线程一旦被创建就会持续存在，即使它们当前没有任何任务要处理[^1]。而 `maximumPoolSize` 则表示线程池中允许存在的最大线程数量，这个数值决定了在线程池忙碌时能够额外创建多少非核心线程来处理更多的任务[^2]。 #### 工作机制 当向线程池提交任务时，如果当前运行的线程数少于 `corePoolSize`，则会优先创建新的线程去执行该任务；如果已有线程的数量达到了 `corePoolSize`，那么后续的任务将会被放入工作队列等待执行。只有当工作队列已满且正在运行的线程数小于 `maximumPoolSize` 时，才会继续创建新的非核心线程来执行任务[^3]。 #### 非核心线程管理 对于超出 `corePoolSize` 而创建的非核心线程，如果有空闲时间超过设定的 `keepAliveTime` 值，则会被终止并移除，以此实现资源的有效利用。然而，核心线程不会受到此限制的影响，除非显式调用了某些方法（如 shutdown() 或者 allowCoreThreadTimeOut(true)），否则它们始终保留在线程池中。 #### 实际应用案例分析 以固定大小线程池为例 (`Executors.newFixedThreadPool(nThreads)`)，其内部实际上就是基于 `ThreadPoolExecutor` 构建而成，其中设置了相同的 `corePoolSize` 和 `maximumPoolSize` 数值，并采用了无界的 LinkedBlockingQueue 来存储待处理任务。尽管这种配置简单易用，但由于缺乏对任务排队长度或者并发线程上限的有效控制，《阿里巴巴 Java 开发手册》建议避免直接使用此类预定义工厂方法构建线程池，转而采用更灵活可控的方式自定义实例化 `ThreadPoolExecutor` 对象[^4]。 ```java // 自定义线程池示例代码 import java.util.concurrent.*; public class CustomThreadPool { public static void main(String[] args) { int corePoolSize = 5; int maxPoolSize = 10; long keepAliveTime = 60L; BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10); ThreadFactory threadFactory = Executors.defaultThreadFactory(); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, threadFactory, handler); System.out.println("Custom ThreadPool created with Core Pool Size: " + corePoolSize + ", Maximum Pool Size: " + maxPoolSize); } } ``` 上述代码展示了如何手动定制一个具有特定行为模式的线程池，包括但不限于指定核心/最大线程数目、保持活动期限以及拒绝策略等方面的内容。