安全线程池需有界队列、显式容量、拒绝策略兜底；禁用Executors工厂，用ArrayBlockingQueue；CPU密集型设core=核数，IO密集型按阻塞系数放大；生产推荐CallerRunsPolicy；封装为SafeThreadPoolBuilder并强制传queueSize。
直接上手写一个安全、可复用、防 OOM 的线程池基础类，关键不是堆参数，而是把“边界意识”刻进设计里。核心就三点：有界队列 + 显式容量 + 拒绝策略兜底。
一、为什么默认线程池会 OOM？根源在队列
Executors.newFixedThreadPool(5) 看似稳妥，实则暗藏风险——它底层用的是 无界 LinkedBlockingQueue（容量默认 Integer.MAX_VALUE）。任务提交速度 > 处理速度时，队列无限膨胀，内存迟早爆掉。
这不是理论风险。真实案例中，一个日志异步写入线程池因下游磁盘慢，10 分钟积压 200 万条日志对象，JVM 堆直接打满。
所以第一步必须打破“无界”惯性：
- 禁用所有 Executors.xxx 静态工厂方法
- 强制使用 ThreadPoolExecutor 构造器，显式传入有界队列
- 队列类型首选 ArrayBlockingQueue（线程安全、容量固定、内存占用可控）
二、7 个参数怎么设？按业务类型分两档
别背口诀，看场景选值：
CPU 密集型任务（如加解密、图像压缩）：
→ corePoolSize = CPU 核数（或 +1）
→ maximumPoolSize = corePoolSize（不建议扩容，避免上下文切换开销）
→ keepAliveTime = 60L，unit = TimeUnit.SECONDS（非核心线程空闲 1 分钟回收）
→ workQueue = new ArrayBlockingQueue<>(1024)（队列大小建议 512～2048，根据任务平均耗时和吞吐预估）
I/O 密集型任务（如 HTTP 调用、DB 查询）：
→ corePoolSize = CPU 核数 × (1 + 平均阻塞系数)，例如阻塞系数为 4，4 核机器设为 20
→ maximumPoolSize 可略高于 corePoolSize（如 +20%），留一点弹性
→ keepAliveTime 可缩短至 10～30 秒（I/O 线程空闲更频繁）
→ workQueue 同样用 ArrayBlockingQueue，但容量可稍大（如 2048～4096），因 I/O 等待时间长，排队更常见
三、拒绝策略不能用默认，必须主动兜底
AbortPolicy（默认）一出错就抛异常，线上服务可能雪崩；DiscardPolicy 直接丢任务，用户请求无声失败。
生产环境推荐：CallerRunsPolicy —— 当队列满 + 线程满时，让提交任务的主线程自己执行该任务。
好处很实在：
- 不丢任务，保障业务语义完整性
- 主线程执行会自然减速，反向抑制上游提交速度（天然限流）
- 无需额外监控告警，异常堆栈直接暴露在调用方，问题定位快
如果业务允许丢弃，可自定义策略，比如记录被拒任务 ID 到日志或 Kafka，供事后补偿。
四、封装成团队可复用的基础类：命名 + 注释 + 默认约束
不要只给一个 new ThreadPoolExecutor(...)，要封装成带语义的工具类：
示例 Java 类骨架（精简版）：
// 安全线程池工厂，强制要求传入队列容量与拒绝策略public class SafeThreadPoolBuilder {
public static ExecutorService buildIoPool(String name, int core, int max, int queueSize) {
return new ThreadPoolExecutor(
core, max,
30L, TimeUnit.SECONDS,
new ArrayBlockingQueue<>(queueSize),
new NamedThreadFactory(name), // 自定义线程名，便于排查
new ThreadPoolExecutor.CallerRunsPolicy()
);
}
}
关键点：
- 类名含 “Safe” 或 “Bounded”，团队一眼识别其安全属性
- 构造方法不接受无界队列，queueSize 必填且为 int（杜绝传 null 或 Integer.MAX_VALUE）
- 内置 NamedThreadFactory，所有线程带业务前缀（如 “io-order-1”），避免线程名混乱
- Javadoc 明确标注适用场景、典型配置、OOM 风险规避说明
做到这四步，你的线程池就不再是“能跑就行”的脚本级代码，而是团队可信、上线安心、故障可溯的基础设施组件。
