Java 中怎么使用 ThreadPoolExecutor 自定义线程池-java教程-PHP中文网

Java中应显式使用ThreadPoolExecutor自定义线程池，明确配置7个核心参数（corePoolSize、maximumPoolSize、keepAliveTime、unit、workQueue、threadFactory、handler），避免Executors快捷方法引发OOM或资源耗尽；需根据业务选择有界队列、合理拒绝策略，并通过shutdown()与awaitTermination()优雅关闭。

java 中怎么使用 threadpoolexecutor 自定义线程池

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，并根据业务场景合理配置参数。

一个安全可用的自定义示例

比如处理后台异步通知任务，希望最多 10 个线程并发，队列容量为 100，超时后丢弃任务：

Java注释规范Skills

当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。

下载

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 应用中可能引发上下文销毁问题。