Java线程池参数设置与优化指南

一、创建线程有几种方式

在 Java 里，本质只有一条路径：创建 Thread 对象并 start()。但写法/封装常见有 4 种：

补充：

• Runnable：无返回值，void run()
• Callable<V>：有返回值，配合 FutureTask 或线程池的 submit()

// 1. 继承 Thread（不推荐，扩展性差）
class MyThread extends Thread {
    public void run() { /* ... */ }
}

// 2. Runnable（常用）
new Thread(() -> System.out.println("task")).start();

// 3. Callable
FutureTask<String> future = new FutureTask<>(() -> "result");
new Thread(future).start();

// 4. 线程池（生产推荐）
ExecutorService pool = new ThreadPoolExecutor(...);
pool.submit(() -> "result");

二、自定义线程池核心参数（ThreadPoolExecutor）

生产环境不要用 Executors.newFixedThreadPool() 等工厂方法（队列可能无界、线程数固定不合理），应显式 new ThreadPoolExecutor(...)：

new ThreadPoolExecutor(
    corePoolSize,      // 核心线程数
    maximumPoolSize,   // 最大线程数
    keepAliveTime,     // 非核心线程空闲存活时间
    unit,              // 时间单位
    workQueue,         // 任务队列
    threadFactory,     // 线程工厂（命名、优先级等）
    handler            // 拒绝策略
);

各参数含义

任务提交流程（简化）

提交任务

→ 当前线程数 < corePoolSize？→ 新建核心线程执行

→ 否则尝试入队

→ 队列满 且 线程数 < maximumPoolSize？→ 新建非核心线程执行

→ 否则走拒绝策略

四种拒绝策略

三、如何根据机器和业务设置参数

先分清任务类型：

CPU 密集型

目标：线程数 ≈ CPU 核心数，避免过多线程导致上下文切换。

经验公式：

线程数 ≈ N_cpu + 1

或

线程数 ≈ N_cpu

• N_cpu = Runtime.getRuntime().availableProcessors() 或容器里的 CPU quota
• +1 是为了某个线程偶尔阻塞（如缺页）时，其它核仍能跑满

示例（8 核）：

int cpu = Runtime.getRuntime().availableProcessors();
int core = cpu;
int max = cpu + 1;
// 队列可以小一点，有界队列 + CallerRunsPolicy

IO 密集型

目标：线程在等 IO 时，其它线程继续用 CPU。

常见估算（假设线程约 %wait 时间在等待 IO）：

线程数 ≈ N_cpu × (1 + W/C)

• W：等待时间（IO）
• C：计算时间
• 若 IO 占 90%：N_cpu × (1 + 9) ≈ 10 × N_cpu

更实用的经验范围（无精确 profiling 时）：

线程数 ≈ N_cpu × 2  ~  N_cpu × (1 + 平均阻塞时间/平均CPU时间)

例如 8 核、大量 HTTP/DB：

int cpu = Runtime.getRuntime().availableProcessors();
int core = cpu * 2;
int max  = cpu * 4;   // 上限要设，并结合压测调

注意：不是越大越好，线程过多会增加内存、调度开销，还要受连接池、DB 最大连接数等限制。

四、实操建议（结合机器）

1. 先搞清楚“机器”是多少核

int n = Runtime.getRuntime().availableProcessors();

• 物理机：看 CPU 核心数
• Docker/K8s：看 CPU limit（availableProcessors 通常已按 limit 返回）
• 混合部署：按该进程实际能用的核数算，不是整机核数

2. 分池，不要一个大池包天下

CPU 池：计算、报表、加密 → 小池，≈ N_cpu

IO 池：HTTP、DB、MQ → 大池，≈ N_cpu × 2~4（压测微调）

3. 队列要有界

new ArrayBlockingQueue<>(1000)  // 或 LinkedBlockingQueue(capacity)

无界队列会导致任务堆积、OOM，且 maximumPoolSize 几乎用不上。

4. 用压测定参，而不是只套公式

5. 快速对照表

五、一句话总结

• 创建线程：继承 Thread、Runnable、Callable、线程池（生产用自定义 ThreadPoolExecutor）。
• 核心参数：core 常驻、max 上限、keepAlive 回收非核心线程、有界 queue、handler 拒绝策略。
• CPU 密集：线程数 ≈ CPU 核数；IO 密集：线程数 ≈ 核数 × (2~4 或按 W/C 估算)，最终以压测和下游连接数为上限。