ThreadPoolExecutor线程池状态你知道吗?

2022-09-20 18:37:29 浏览数 (1)

线程池状态

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。

线程池生命周期:

  1. RUNNING:运行中,接收新的任务并且处理队列任务
  2. SHUTDOWN:关闭,不接收新的任务但是处理队列任务
  3. STOP:停止,不接收新的任务、不处理队列任务 并且中断进行中的任务
  4. TIDYING:调整,所有的任务已经终止,workerCount变成0,线程过渡到TIDYING状态将会运行terminated()方法
  5. 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(有时需要重新检查) 线程池状态流程图:

能力一般,水平有限,如有错误,请多指出。

0 人点赞