ThreadPoolExecutor在java中创建线程池-java教程-PHP中文网

ThreadPoolExecutor在java中创建线程池

舞姬之光

发布： 2025-12-05 12:14:40

原创

404人浏览过

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

threadpoolexecutor在java中创建线程池

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除了拥有一般网上商店系统所具有的所有功能，还拥有着其它网店系统没有的许多超强功能。千博购物系统.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<Runnable> 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(); // 预热，避免首次任务延迟

登录后复制