java中应手动构造threadpoolexecutor实例而非使用executors，以精准控制核心线程数、最大线程数、队列容量等7个参数，避免资源耗尽；同时自定义threadfactory和rejectedexecutionhandler可提升可监控性与可维护性。

Java 中使用 ThreadPoolExecutor 创建线程池，核心是手动构造其实例，而非依赖 Executors 工具类的封装方法。这样能更清晰地控制线程池行为，避免资源耗尽等隐患。

明确七个构造参数的含义

ThreadPoolExecutor 最常用的构造器有 7 个参数，缺一不可：

• corePoolSize：核心线程数，即使空闲也不会被回收（除非允许核心线程超时）
• maximumPoolSize：最大线程数，当任务队列满且当前线程数
• keepAliveTime：非核心线程空闲后最多存活时间，超时即终止
• unit：keepAliveTime 的时间单位，如 TimeUnit.SECONDS
• workQueue：阻塞任务队列，常用 LinkedBlockingQueue（无界）、ArrayBlockingQueue（有界）、SynchronousQueue（不存任务，直接转发）
• threadFactory：线程创建工厂，用于自定义线程命名、是否为守护线程等
• handler：拒绝策略，当线程数达上限且队列已满时执行，常见有：AbortPolicy（抛异常）、CallerRunsPolicy（由调用线程执行任务）、DiscardPolicy（静默丢弃）、DiscardOldestPolicy（丢弃队首任务再尝试提交）

推荐的基础创建方式（有界队列 + 拒绝策略）

避免使用 Executors.newFixedThreadPool()（内部用无界队列）或 newCachedThreadPool()（无界最大线程数），容易引发 OOM 或资源失控。应显式指定有界队列和拒绝策略：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    2,                    // corePoolSize
    4,                    // maximumPoolSize
    60L,                  // keepAliveTime
    TimeUnit.SECONDS,
    new ArrayBlockingQueue(10),  // 有界队列，容量 10
    new ThreadFactory() {
        private final AtomicInteger count = new AtomicInteger(0);
        @Override
        public Thread newThread(Runnable r) {
            return new Thread(r, "my-pool-thread-" + count.incrementAndGet());
        }
    },
    new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝时由主线程执行
);

关键操作与生命周期管理

创建后需注意启动、提交任务、优雅关闭等环节：

• 提交任务用 execute(Runnable) 或 submit(Callable)，后者可获取 Future 结果
• 不再接受新任务：调用 shutdown()（已提交任务继续执行）
• 立即停止所有运行中任务：调用 shutdownNow()（返回未执行的任务列表，尝试中断正在运行的线程）
• 等待所有任务完成：配合 awaitTermination(long, TimeUnit) 使用，建议加超时判断
• 务必在合适时机调用 shutdown()，否则 JVM 不会退出（因线程池默认线程是非守护线程）

一个实用的封装建议

为避免重复写构造逻辑，可封装成工具方法或 Bean（Spring 环境下建议声明为 @Bean）：

public static ThreadPoolExecutor createMyPool() {
    return new ThreadPoolExecutor(
        4, 8,
        30, TimeUnit.SECONDS,
        new LinkedBlockingQueue(100),
        r -> {
            Thread t = new Thread(r);
            t.setName("biz-task-" + counter.incrementAndGet());
            t.setDaemon(false);
            return t;
        },
        new ThreadPoolExecutor.AbortPolicy()
    );
}

这样既可控又易复用，也方便统一监控和治理。

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南