Java中应显式使用ThreadPoolExecutor自定义线程池，明确配置7个核心参数（corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler），避免Executors快捷方法引发OOM或资源耗尽；需根据业务选择有界队列、合理拒绝策略，并通过shutdown()与awaitTermination()优雅关闭。
Java 中使用 ThreadPoolExecutor 自定义线程池，核心是明确线程池的运行参数、拒绝策略和任务队列行为，而不是简单调用 Executors 工具类的快捷方法。
理解七个核心构造参数
ThreadPoolExecutor 提供了最灵活的构造器，需传入 7 个参数：
- corePoolSize：核心线程数，即使空闲也保留的线程数量
- maximumPoolSize：线程池允许的最大线程数
- keepAliveTime：非核心线程空闲时的存活时间（单位由 timeUnit 指定）
-
unit：
keepAliveTime的时间单位，如TimeUnit.SECONDS -
workQueue：用于存放待执行任务的阻塞队列（如
LinkedBlockingQueue、ArrayBlockingQueue、SynchronousQueue） - threadFactory：创建新线程的工厂，可用于统一命名、设置守护线程等
-
handler：当队列满且线程数已达最大值时，触发的拒绝策略（如
AbortPolicy、CallerRunsPolicy）
避免直接用 Executors 创建线程池
Executors 提供的 newFixedThreadPool、newCachedThreadPool 等方法内部封装了 ThreadPoolExecutor，但存在隐患：
-
newFixedThreadPool使用无界队列（LinkedBlockingQueue），可能导致 OOM -
newCachedThreadPool允许创建无限线程，高峰时易耗尽系统资源 - 无法显式控制拒绝策略、线程命名、异常处理等细节
因此，生产环境应显式构造 ThreadPoolExecutor，并根据业务场景合理配置参数。
立即学习“Java免费学习笔记（深入）”；
Java注释规范Skills
下载
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
一个安全可用的自定义示例
比如处理后台异步通知任务，希望最多 10 个线程并发，队列容量为 100，超时后丢弃任务：
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, // corePoolSize：常驻 4 个线程
10, // maximumPoolSize：最多扩容到 10 个
60L, // keepAliveTime：非核心线程空闲 60 秒后回收
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(100), // 有界队列，避免内存溢出
new ThreadFactoryBuilder()
.setNameFormat("notify-pool-%d")
.setDaemon(true)
.build(), // 使用 Guava 的 ThreadFactoryBuilder 或自定义实现
new ThreadPoolExecutor.DiscardOldestPolicy() // 队列满时丢弃最早的任务
);
注意：ThreadFactoryBuilder 来自 Guava，若不用第三方库，可手写实现 ThreadFactory 接口；拒绝策略也可选 CallerRunsPolicy 让调用线程自己执行任务，缓解压力。
正确关闭线程池
不再使用时，应主动关闭以释放资源：
-
shutdown()：停止接收新任务，等待已有任务执行完成 -
shutdownNow()：尝试中断所有正在执行的线程，并返回未执行的任务列表 - 建议配合
awaitTermination()等待优雅终止：
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow();
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
不关闭会导致 JVM 无法正常退出，尤其在 Spring Boot 应用中可能引发上下文销毁问题。
