17370845950

ThreadPoolExecutor是Java线程池核心类，通过构造函数配置核心线程数、最大线程数、存活时间、任务队列、线程工厂和拒绝策略；选用有界队列如ArrayBlockingQueue防资源耗尽，自定义ThreadFactory提升线程识别度，设置CallerRunsPolicy等拒绝策略保障系统稳定，结合业务需求调整参数并监控队列状态以优化性能。

在Java中，ThreadPoolExecutor 是线程池的核心实现类，提供了高度可定制的线程管理能力。通过合理配置参数，可以满足不同业务场景下的并发需求。

理解ThreadPoolExecutor构造函数参数

ThreadPoolExecutor提供了一个多参数构造函数，用于精细控制线程池行为：

• corePoolSize：核心线程数，即使空闲也不会被回收（除非设置allowCoreThreadTimeOut）
• maximumPoolSize：最大线程数，线程池允许创建的最多线程数量
• keepAliveTime：非核心线程闲置超时时间，超过此时间将被终止
• unit：keepAliveTime的时间单位
• workQueue：任务队列，用于存放待执行的任务
• threadFactory：线程工厂，用于创建新线程，可自定义线程命名和属性
• handler：拒绝策略，当任务无法提交时的处理方式

选择合适的任务队列

队列类型直接影响线程池的行为和性能：

• LinkedBlockingQueue：无界队列，可能导致内存溢出，适合负载较轻且稳定的应用
• ArrayBlockingQueue：有界队列，需指定容量，能防止资源耗尽，但可能触发拒绝策略
• SynchronousQueue：不存储元素的阻塞队列，每个插入操作必须等待另一个线程的移除操作，适合高并发短任务场景
• PriorityBlockingQueue：支持优先级排序的无界队列，适用于需要任务优先级调度的场景

自定义线程工厂ThreadFactory

默认线程工厂创建的线程名不易识别，不利于排查问题。通过自定义ThreadFactory可提升调试效率：

ThreadFactory namedFactory = new ThreadFactory() {
    private final AtomicInteger threadNumber = new AtomicInteger(1);

    public Thread newThread(Runnable r) {
        Thread t = new Thread(r, "MyPool-Thread-" + threadNumber.getAndIncrement());
        t.setDaemon(false); // 非守护线程
        t.setPriority(Thread.NORM_PRIORITY);
        return t;
    }
};

设置合理的拒绝策略

当线程池关闭或饱和时，新提交的任务会触发拒绝策略：

• AbortPolicy：默认策略，抛出RejectedExecutionException异常
• CallerRunsPolicy：由提交任务的线程直接执行任务，减缓提交速度
• DiscardPolicy：静默丢弃任务，不抛异常
• DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试重新提交当前任务

也可实现RejectedExecutionHandler接口，定制日志记录、告警或降级逻辑。

示例：构建一个生产级线程池

结合以上要素，创建一个健壮的线程池实例：

BlockingQueue queue = new ArrayBlockingQueue<>(100);
ThreadFactory factory = r -> {
    Thread t = new Thread(r, "BizWorker-" + counter.incrementAndGet());
    t.setUncaughtExceptionHandler((t, e) -> log.error("Uncaught exception in thread " + t.getName(), e));
    return t;
};
RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    5,           // 核心线程数
    20,          // 最大线程数
    60L,         // 空闲超时时间
    TimeUnit.SECONDS,
    queue,
    factory,
    handler
);
// 允许核心线程超时（可选）
executor.allowCoreThreadTimeOut(true);

基本上就这些。关键是根据实际业务特点调整参数，避免盲目使用Executors工具类提供的固定模式。监控线程池状态（如队列长度、活跃线程数）也有助于持续优化配置。