java ExecutorService如何调优

在 Java 中，ExecutorService 的“调优”本质上是在 吞吐量、延迟、资源占用、稳定性 之间做权衡。下面从 核心参数、队列、拒绝策略、监控、常见场景 几个维度系统讲一下。

一、先理解关键参数（以 ThreadPoolExecutor 为例）

new ThreadPoolExecutor(
    corePoolSize,
    maximumPoolSize,
    keepAliveTime,
    TimeUnit.SECONDS,
    workQueue,
    threadFactory,
    rejectedExecutionHandler
)

1. corePoolSize（核心线程数）

• 常驻线程
• 适合：稳定、持续的并发任务
• 经验值：
  • CPU 密集型：≈ CPU 核数
  • IO 密集型：CPU 核数 × (1 + IO等待时间 / CPU计算时间)

2. maximumPoolSize（最大线程数）

• 队列满了之后才会创建
• 不宜过大，避免：
  • 上下文切换开销
  • 内存暴涨（每个线程默认 1MB 栈）

3. keepAliveTime

• 非核心线程空闲回收时间
• IO 任务可设大一点（如 30–60s）
• CPU 任务可设小一点（如 10s）

二、工作队列选择（非常关键）

1. SynchronousQueue（不缓存）

new ThreadPoolExecutor(..., new SynchronousQueue<>())

• 来一个任务，必须马上有线程处理
• 线程数容易膨胀
• 适合：低延迟、短任务

2. LinkedBlockingQueue（无界）

new LinkedBlockingQueue<>()

• 任务无限堆积
• 风险：OOM
• 适合：任务量可控、重视稳定性

3. ArrayBlockingQueue（有界）

new ArrayBlockingQueue<>(1024)

• 推荐生产环境使用
• 配合拒绝策略更稳妥

✅ 调优建议：生产环境优先使用有界队列

三、拒绝策略（保护系统）

✅ 高并发系统常用：

new ThreadPoolExecutor.CallerRunsPolicy()

四、线程工厂（容易被忽视）

new ThreadFactory() {
    public Thread newThread(Runnable r) {
        Thread t = new Thread(r);
        t.setName("biz-pool-" + t.getId());
        t.setDaemon(false);
        return t;
    }
}

作用：

• 方便排查问题（线程名）
• 统一异常处理

五、根据任务类型调优

1. CPU 密集型

corePoolSize = Ncpu
maximumPoolSize = Ncpu
queue = 有界队列

示例：

new ThreadPoolExecutor(
   4, 4, 0L, TimeUnit.MILLISECONDS,
   new ArrayBlockingQueue<>(1000)
)

2. IO 密集型（DB / HTTP / RPC）

corePoolSize = Ncpu * 2
maximumPoolSize = Ncpu * 4~10
queue = 有界队列

3. 混合型任务

• 拆分线程池（强烈推荐）
  • CPU 池
  • IO 池

六、监控与动态调优（非常重要）

1. 关键监控指标

executor.getActiveCount();
executor.getQueue().size();
executor.getCompletedTaskCount();
executor.getPoolSize();

2. 动态调参（Tomcat / Spring）

executor.setCorePoolSize(10);
executor.setMaximumPoolSize(50);

3. 结合 Micrometer / Prometheus

• 线程池使用率
• 队列堆积
• 拒绝次数

七、常见坑

❌ 使用 Executors.newFixedThreadPool()

• 无界队列 → OOM

❌ 线程池数量“拍脑袋”

• 必须压测

❌ 所有任务用一个线程池

• 互相影响

❌ 忽略异常

• 任务异常会“吞掉”

八、推荐模板（生产可用）

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    8,
    32,
    60L,
    TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(2000),
    new NamedThreadFactory("order-pool"),
    new ThreadPoolExecutor.CallerRunsPolicy()
);

如果你愿意，可以告诉我：

• 任务类型（CPU / IO）
• QPS
• 单任务耗时
• 是否 Spring / Spring Boot

我可以直接帮你 算一套具体参数。