Java 线程池核心原理与实战配置

四、任务队列的选择

队列的选择直接影响系统的稳定性，尤其是内存风险。

代码建议：

// 推荐：有界队列，防止 OOM
new ArrayBlockingQueue<>(100)

// 谨慎：无界队列可能导致内存溢出
new LinkedBlockingQueue<>()

// 同步队列：适合对延迟敏感的场景
new SynchronousQueue<>()

五、拒绝策略详解

当系统过载无法处理新任务时，必须明确告知调用方或业务层。

六、线程工厂的重要性

默认的线程工厂创建的线程名称难以追踪，调试困难。自定义工厂可以设置命名规范和非守护属性。

ThreadFactory factory = new ThreadFactory() {
    private AtomicInteger count = new AtomicInteger(1);
    
    @Override
    public Thread newThread(Runnable r) {
        Thread thread = new Thread(r);
        thread.setName("MyThread-" + count.getAndIncrement());
        thread.setDaemon(false); // 确保是非守护线程
        return thread;
    }
};

最佳实践：

• 统一线程命名，方便排查堆栈。
• 避免使用守护线程，防止进程退出时任务中断。

七、避坑指南：Executors 工具类

阿里巴巴开发规范明确禁止直接使用 Executors 创建线程池，原因如下：

正确做法：

// ❌ 不推荐：可能引发 OOM
ExecutorService pool = Executors.newFixedThreadPool(10);

// ✅ 推荐：手动配置所有参数
ExecutorService pool = new ThreadPoolExecutor(
    10, 50, 60L, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(100),
    new ThreadPoolExecutor.AbortPolicy()
);

八、线程池状态流转

理解状态有助于监控和关闭线程池。

九、实战参数配置

根据任务类型调整参数是调优的关键。

1. CPU 密集型任务

计算密集，线程竞争 CPU 资源。

int cpuCores = Runtime.getRuntime().availableProcessors();
new ThreadPoolExecutor(
    cpuCores + 1, cpuCores + 1, 0L, TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>(1000)
);

2. IO 密集型任务

线程大部分时间在等待 IO，可适当增加线程数。

int cpuCores = Runtime.getRuntime().availableProcessors();
new ThreadPoolExecutor(
    cpuCores * 2, cpuCores * 2, 60L, TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(1000)
);

3. 混合型任务

混合场景下，通常取中间值。

new ThreadPoolExecutor(
    cpuCores + 1, cpuCores * 2, 60L, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(500)
);

十、监控与优雅关闭

1. 常用监控指标

ThreadPoolExecutor executor = ...;

// 活跃线程数
executor.getActiveCount();

// 队列中积压任务数
executor.getQueue().size();

// 已完成任务数
executor.getCompletedTaskCount();

// 是否已终止
executor.isTerminated();

2. 优雅关闭流程

不要直接 System.exit，要确保正在执行的任务完成。

ThreadPoolExecutor executor = ...;

// 1. 拒绝新任务
executor.shutdown();

// 2. 等待任务完成（带超时）
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
    // 3. 超时后强制中断
    executor.shutdownNow();
}

十一、常见问题速查

Q: 线程池会 OOM 吗？ A: 会。最常见原因是使用了无界队列（如 LinkedBlockingQueue 默认值），或者任务执行过慢导致堆积。解决方案是使用有界队列并配合合理的拒绝策略。

Q: 核心线程会被回收吗？ A: 默认不会。如果需要，可调用 executor.allowCoreThreadTimeOut(true)。

Q: 队列容量怎么设？ A: 经验公式：队列容量 = 核心线程数 * 期望响应时间 (秒) * 2。具体需结合压测结果调整。

十二、总结

掌握线程池不仅仅是记住参数，更要理解背后的权衡。

• 参数配置：根据任务类型（CPU/IO）选择核心数和最大数。
• 队列选择：优先使用有界队列，杜绝无界队列带来的 OOM 隐患。
• 拒绝策略：根据业务容忍度选择，核心业务建议抛异常以便告警。
• 监控调优：定期查看队列大小和活跃线程数，发现瓶颈及时调整。
• 关闭机制：先 shutdown 等待完成，再视情况 shutdownNow，防止任务丢失。