【threadpoolexecutor】在Java并发编程中，`ThreadPoolExecutor` 是一个非常重要的类，它属于 `java.util.concurrent` 包，用于管理线程池，提高程序的执行效率和资源利用率。通过合理配置线程池参数，开发者可以更好地控制多线程任务的执行方式。
一、总结
`ThreadPoolExecutor` 是 Java 中实现线程池的核心类，支持灵活的线程管理策略。它可以有效减少线程创建和销毁的开销，避免系统资源浪费，同时还能防止过多线程导致的资源竞争和性能下降。其主要功能包括：
- 管理一组工作线程
- 接收并调度任务
- 控制线程数量和队列容量
- 提供任务拒绝策略
二、关键参数说明（表格）
| 参数名称 | 类型 | 说明 |
| corePoolSize | int | 线程池中保持的最小线程数，即使这些线程处于空闲状态 |
| maximumPoolSize | int | 线程池中允许的最大线程数 |
| keepAliveTime | long | 当线程数超过 corePoolSize 时，空闲线程等待新任务的最长时间 |
| unit | TimeUnit | keepAliveTime 的时间单位（如秒、毫秒等） |
| workQueue | BlockingQueue | 用于保存待执行任务的阻塞队列 |
| threadFactory | ThreadFactory | 用于创建新线程的工厂对象 |
| handler | RejectedExecutionHandler | 当任务被拒绝时的处理策略 |
三、使用场景
| 场景 | 说明 |
| 高并发请求处理 | 如 Web 服务器处理 HTTP 请求 |
| 耗时任务异步执行 | 如文件上传、数据计算等 |
| 任务调度与管理 | 如定时任务、批量处理等 |
| 资源受限环境 | 避免线程爆炸，控制资源消耗 |
四、常见拒绝策略
| 策略名称 | 说明 |
| AbortPolicy | 默认策略，抛出 `RejectedExecutionException` 异常 |
| CallerRunsPolicy | 由调用线程直接执行该任务 |
| DiscardPolicy | 直接丢弃任务，不抛出异常 |
| DiscardOldestPolicy | 丢弃队列中最老的任务，然后重试添加当前任务 |
五、示例代码
```java
import java.util.concurrent.;
public class ThreadPoolExample {
public static void main(String[] args) {
int corePoolSize = 2;
int maxPoolSize = 4;
long keepAliveTime = 10;
TimeUnit unit = TimeUnit.SECONDS;
BlockingQueue
ThreadFactory threadFactory = Executors.defaultThreadFactory();
RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue, threadFactory, handler);
for (int i = 0; i < 15; i++) {
final int taskId = i;
executor.execute(() -> {
System.out.println("Task " + taskId + " is running on thread: " + Thread.currentThread().getName());
});
}
executor.shutdown();
}
}
```
六、注意事项
- 合理设置 `corePoolSize` 和 `maximumPoolSize`，避免资源浪费或不足。
- 队列类型选择要根据任务特性（如 `LinkedBlockingQueue` 适合缓冲大量任务）。
- 拒绝策略应根据业务需求进行选择，避免数据丢失或系统崩溃。
- 使用 `shutdown()` 或 `shutdownNow()` 来优雅关闭线程池。
通过合理配置和使用 `ThreadPoolExecutor`，可以显著提升应用程序的并发性能和稳定性。它是构建高性能 Java 应用的重要工具之一。
