线程池参数与拒绝策略实战

线程池参数与拒绝策略实战

一句话结论

• 线程池不是越大越好：CPU 密集型 ≈ 核数 +1，IO 密集型 ≈ 核数 × (1 + 平均等待/平均计算)
• 拒绝策略要匹配业务：核心请求用 CallerRunsPolicy，可丢弃用 DiscardPolicy

面试标准答法

ThreadPoolExecutor 七大参数

ThreadPoolExecutor(
    int corePoolSize,      // 核心线程数
    int maximumPoolSize,   // 最大线程数
    long keepAliveTime,    // 空闲线程存活时间
    TimeUnit unit,
    BlockingQueue<Runnable> workQueue,  // 任务队列
    ThreadFactory threadFactory,        // 线程工厂
    RejectedExecutionHandler handler    // 拒绝策略
)

执行流程：

1. 核心线程未满 → 直接创建核心线程执行
2. 核心线程已满 → 入队
3. 队列已满 → 创建非核心线程
4. 最大线程已满 → 触发拒绝策略

四种拒绝策略

队列选择

• SynchronousQueue：不存储，直接交接（CachedThreadPool）
• LinkedBlockingQueue：无界，可能 OOM（FixedThreadPool）
• ArrayBlockingQueue：有界，推荐生产使用
• PriorityBlockingQueue：优先级调度

线程数估算

• CPU 密集型：N_cpu + 1（如加密、压缩、算法）
• IO 密集型：N_cpu × (1 + W/C)，W=等待时间，C=计算时间（如 RPC、DB、文件）

经验值：Web 服务常配 N_cpu × 2 到 N_cpu × 4，再结合压测调整。

常见追问

面试回答模板（30 秒版）

延伸准备

• 能手写自定义线程池 + 拒绝策略（进 MQ）
• 能解释 ThreadLocal 在线程池中的内存泄漏风险
• 能对比 ForkJoinPool 和 ThreadPoolExecutor 适用场景