标签: 线程池

基于 JDK 1.8 源码的线程池核心原理与执行流程分析。

一、核心架构与状态管理

1.1 CTL 变量的设计

ThreadPoolExecutor 使用一个 AtomicInteger 类型的 ctl 变量，巧妙地将线程池状态和工作线程数量打包存储：

private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

private static final int COUNT_BITS = Integer.SIZE - 3;  // 29
private static final int CAPACITY   = (1 << COUNT_BITS) - 1;  // 约 5 亿

// 状态存储在高 3 位
private static final int RUNNING    = -1 << COUNT_BITS;  // 111
private static final int SHUTDOWN   =  0 << COUNT_BITS;  // 000
private static final int STOP       =  1 << COUNT_BITS;  // 001
private static final int TIDYING    =  2 << COUNT_BITS;  // 010
private static final int TERMINATED =  3 << COUNT_BITS;  // 011

// 拆包方法
private static int runStateOf(int c)     { return c & ~CAPACITY; }  // 取高 3 位
private static int workerCountOf(int c)  { return c & CAPACITY; }   // 取低 29 位
private static int ctlOf(int rs, int wc) { return rs | wc; }        // 打包

zhangyuguai2025/12/19...大约 10 分钟