Thread Pool

线程池 / ThreadLocal

When to Invoke

自定义线程池、报表和下单抢线程、ThreadLocal 用户上下文在异步后串号、JDK21 虚拟线程。

When NOT

Feign 超时数值 → rpc-remote。GC 堆分析 → jvm-prod。

风险（面试考点）

Executors.newFixedThreadPool / newCachedThreadPool：前者 无界队列（max 线程永远不创建，堆积 OOM），后者线程无界。阿里规约禁止用它们生产。

参数：core、max、keepAlive、有界队列、拒绝策略、线程名。

CallerRunsPolicy 会把任务打回调用线程，可能拖接口；AbortPolicy 要有降级。IO 密集用更大 max + 有界队列；CPU 密集约核数。

ThreadLocal：线程池里线程长期活着，value 强引用 → 泄漏；异步线程不 remove 会串用户。必须 try/finally remove。

虚拟线程（JDK21）：适合阻塞 IO 多；synchronized 可能 pinning；不要拿它当「不用再隔离线程池」的理由。CPU 忙任务仍要限制并行。

方案选型（轻量优先）

默认方案

ThreadPoolExecutor orderPool = new ThreadPoolExecutor(
    8, 16, 60, TimeUnit.SECONDS,
    new ArrayBlockingQueue<>(200),
    new ThreadFactoryBuilder().setNameFormat("order-%d").build(),
    new ThreadPoolExecutor.AbortPolicy());

try {
    UserContext.set(uid);
    handle();
} finally {
    UserContext.remove(); // 线程池必须
}

反例

错误：Executors.newFixedThreadPool(8) 跑导出。 正确：有界队列 + 独立池。

错误：网关线程里 set ThreadLocal，丢给线程池不传、不 remove。 正确：任务入参显式传 userId，或装饰器拷贝并 finally 清。

错误：虚拟线程无限提交 CPU 计算。 正确：信号量/信号限制并行。

验证

• 报表打满时下单 RT 不明显上升。
• 压测队列满走拒绝策略，有监控。
• 线程池任务后 ThreadLocal 为空。

评审清单

• 不是 Executors 无界包装
• 核心与非核心池隔离
• ThreadLocal 有 remove