线程池状态
ThreadPoolExecutor源码:
代码语言:javascript复制 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
private static final int COUNT_BITS = Integer.SIZE - 3;
private static final int CAPACITY = (1 << COUNT_BITS) - 1;
// runState is stored in the high-order bits
private static final int RUNNING = -1 << COUNT_BITS;
private static final int SHUTDOWN = 0 << COUNT_BITS;
private static final int STOP = 1 << COUNT_BITS;
private static final int TIDYING = 2 << COUNT_BITS;
private static final int TERMINATED = 3 << COUNT_BITS;
// Packing and unpacking ctl
private static int runStateOf(int c) { return c & ~CAPACITY; }
private static int workerCountOf(int c) { return c & CAPACITY; }
private static int ctlOf(int rs, int wc) { return rs | wc; }
主池控制状态 ctl 是一个原子整数,封装了两个概念字段:
1、workerCount 表示线程的有效数量 2、runState 表示是否正在运行、关闭等 为了把它们包装成一个int类型,workerCount 被限制在(2^29)-1)(约5亿) 而不是(2^31)-1(20亿),这在将来如果成为一个问题,可以将变量更改为 AtomicLong,并调整下面的 移位/掩码常量,但是现在,使用 int 会更快更简单。workerCount 是允许启动和不允许停止的工作队列数量,该值可能与实际活动线程数暂时不同,例如,当提交任务时ThreadFactory创建线程失败,或者当正在退出的现在在终止之前仍在进行统计工作。用户可见的线程池大小为当前工作队列设置的大小。可以看到线程池的初始状态是RUNNING。
线程池生命周期:
- RUNNING:运行中,接收新的任务并且处理队列任务
- SHUTDOWN:关闭,不接收新的任务但是处理队列任务
- STOP:停止,不接收新的任务、不处理队列任务 并且中断进行中的任务
- TIDYING:调整,所有的任务已经终止,workerCount变成0,线程过渡到TIDYING状态将会运行terminated()方法
- TERMINATED:终止,terminated()执行完成,线程池over了
这些值之间的数字顺序很重要,以允许有序比较。runState 会随着时间单调增加,但不需要每个状态都命中。
状态之间转变
1、RUNNING -> SHUTDOWN :调用 shutdown() 2、(RUNNING or SHUTDOWN) -> STOP:调用 shutdownNow() 3、SHUTDOWN -> TIDYING:队列和线程池都空的时候,没有进行的任务,也没有新任务提交 4、STOP -> TIDYING:线程池空的的时候 5、TIDYING -> TERMINATED:terminated() 方法执行完成
当状态变成TERMINATED时,awaitTermination()方法中等待的线程将会return。检测从 SHUTDOWN 到 TIDYING 的转换并不像想要的那么简单,因为在 SHUTDOWN 状态期间队列可能会在非空之后变空,反之亦然,但是我们只能在看到它为空之后才能终止,我们看到的是 workerCount 是 0(有时需要重新检查) 线程池状态流程图:
能力一般,水平有限,如有错误,请多指出。