推荐直接使用 ThreadPoolExecutor 而非 Executors,因其可显式配置核心线程数、最大线程数、队列容量和拒绝策略,避免 newCachedThreadPool 和 newFixedThreadPool 因无界队列导致的 OOM 风险。

ThreadPoolExecutor 是 Java 中最核心的线程池实现类,它提供了对线程池的精细控制能力,比 Executors 工厂方法更透明、更安全。
为什么推荐直接用 ThreadPoolExecutor 而不是 Executors?
Executors 提供的 newFixedThreadPool、newCachedThreadPool 等方法虽然写起来简单,但存在隐患:比如 newCachedThreadPool 使用无界队列(SynchronousQueue 实际上是“无缓冲”但配合无限线程数),可能引发 OOM;newFixedThreadPool 使用无界 LinkedBlockingQueue,任务堆积时内存持续增长。而 ThreadPoolExecutor 让你明确指定核心线程数、最大线程数、队列容量、拒绝策略等关键参数,避免隐式风险。
创建 ThreadPoolExecutor 的关键参数
构造函数有 7 个参数,最常用的是以下 4 个核心组合:
- corePoolSize:核心线程数,即使空闲也不会被回收(除非 allowCoreThreadTimeOut=true)
- maximumPoolSize:线程池允许的最大线程数,只有当队列满且当前线程数
- keepAliveTime & unit:非核心线程空闲超时后被终止的时间
- workQueue:用于保存待执行任务的阻塞队列,推荐使用有界队列(如 ArrayBlockingQueue)
- threadFactory:用于创建新线程,建议自定义以统一命名和设置守护属性
- handler:拒绝策略,常见有 AbortPolicy(抛异常)、CallerRunsPolicy(由提交线程自己执行)、DiscardPolicy(静默丢弃)、DiscardOldestPolicy(丢弃队首任务)
一个安全、可监控的创建示例
下面是一个生产环境推荐的写法:
千博购物系统.Net能够适合不同类型商品,为您提供了一个完整的在线开店解决方案。千博购物系统.Net除了拥有一般网上商店系统所具有的所有功能,还拥有着其它网店系统没有的许多超强功能。千博购物系统.Net适合中小企业和个人快速构建个性化的网上商店。强劲、安全、稳定、易用、免费是它的主要特性。系统由C#及Access/MS SQL开发,是B/S(浏览器/服务器)结构Asp.Net程序。多种独创的技术使
立即学习“Java免费学习笔记(深入)”;
ThreadFactory namedFactory = r -> {
Thread t = new Thread(r, "biz-task-pool-" + System.currentTimeMillis());
t.setDaemon(false);
return t;
};
BlockingQueue queue = new ArrayBlockingQueue<>(1024);
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, // corePoolSize
16, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
queue,
namedFactory,
new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝时由调用方执行,缓解压力
);
// 可选:启用线程池统计(如通过 JMX 或 Micrometer)
executor.prestartAllCoreThreads(); // 预热,避免首次任务延迟
使用中要注意的细节
- 不要忘记在应用关闭时调用 shutdown() 或 shutdownNow(),否则 JVM 无法正常退出
- 监控 queue.size() 和 getActiveCount(),能及时发现任务积压或线程争用
- 避免在线程池中执行阻塞 I/O 或长时间任务,应拆分或改用专用池
- 慎用 allowCoreThreadTimeOut(true),它会让所有线程都可能被回收,适合流量波动极大的场景
基本上就这些。用好 ThreadPoolExecutor 不复杂,但容易忽略边界和生命周期管理。










