java线程池参数

### Java线程池核心参数详解 Java线程池的核心参数定义了其行为模式和资源分配策略。以下是这些参数的具体含义及其作用： #### 1. **corePoolSize** `corePoolSize` 是线程池中保持的最小线程数，即使它们处于空闲状态[^1]。当提交的任务数量超过 `corePoolSize` 并且当前线程数小于最大线程数时，会创建新的线程来处理任务。 #### 2. **maximumPoolSize** `maximumPoolSize` 定义了线程池中允许的最大线程数[^2]。如果队列已满并且当前线程数低于此值，则会创建新线程继续执行任务。 #### 3. **keepAliveTime** `keepAliveTime` 表示线程池中的空闲线程等待新任务的时间长度。一旦超出这个时间，多余的线程会被终止，直到线程总数降至 `corePoolSize`[^3]。 #### 4. **workQueue** 工作队列 (`workQueue`) 存储待执行的任务对象。常见的实现有： - **SynchronousQueue**: 不存储任务，直接将任务传递给可用线程。 - **LinkedBlockingQueue**: 基于链表的无界阻塞队列。 - **ArrayBlockingQueue**: 基于数组的有界阻塞队列。 不同的队列类型会影响线程池的行为和性能表现[^1]。 #### 5. **threadFactory** `ThreadFactory` 接口用于自定义线程的创建方式。可以通过它设置线程名称、优先级或其他属性[^2]。 #### 6. **handler (RejectedExecutionHandler)** 当线程池无法容纳更多任务时（即达到最大线程数且队列已满），会触发拒绝策略。常用的拒绝策略包括： - **AbortPolicy**: 抛出异常并丢弃任务。 - **CallerRunsPolicy**: 调用者所在的线程执行被拒绝的任务。 - **DiscardOldestPolicy**: 扔掉最老的任务以便为新任务腾出空间。 - **DiscardPolicy**: 静默丢弃任务而不做任何处理。 --- ### 使用场景分析 根据实际需求选择合适的参数组合可以显著提升应用性能。以下是一些典型的应用场景： #### 场景一：高吞吐量服务 对于需要快速响应大量请求的服务，可以选择较大的 `corePoolSize` 和较小的 `keepAliveTime` 来动态调整线程数量。同时搭配一个容量适中的 `LinkedBlockingQueue` 或 `ArrayBlockingQueue`。 #### 场景二：计算密集型任务 在这种情况下，应减少线程竞争以充分利用 CPU 核心。通常建议将 `corePoolSize` 设置为 `(CPU核数 - 1)` 左右，并采用同步队列如 `SynchronousQueue`[^1]。 #### 场景三：I/O 密集型操作 由于 I/O 操作会导致线程长时间挂起，因此可适当增加线程数目以弥补这一缺陷。推荐使用更大的 `corePoolSize` 结合缓冲区大小合理的阻塞队列[^2]。 --- ```java import java.util.concurrent.*; public class ThreadPoolExample { public static void main(String[] args) { int corePoolSize = 5; int maximumPoolSize = 10; long keepAliveTime = 1L; BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(10); ThreadFactory threadFactory = Executors.defaultThreadFactory(); RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); ThreadPoolExecutor executor = new ThreadPoolExecutor( corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS, workQueue, threadFactory, handler); for(int i=0; i<15; ++i){ Runnable task = () -> System.out.println(Thread.currentThread().getName() + ": Executing Task"); executor.execute(task); } executor.shutdown(); } } ``` 以上代码展示了如何基于具体业务逻辑配置线程池实例。 ---