线程池类图
56fb386a-faf5-410c-b5c6-ae2d7baf58d0.png
ps:该线程池的类图参考的是《Java 并发编程之美》。
线程池部分源码解释
如下是 ThreadPoolExecutor 的部分源码，主要是体现线程池的几种状态。
//这个是线程池中一个特别重要的原子变量类，表示线程池的状态和线程池中线程的数量，高三位表示状态，其他位表示线程的数量
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
//这个表示的是线程数量所需的位数，因为前三位是状态所以减3
//00011111111111111111111111111111
private static final int COUNT_BITS = Integer.SIZE - 3;
//线程池中线程数的最大值
private static final int CAPACITY = (1 << COUNT_BITS) - 1;
//表示线程池状态位 running
//11100000000000000000000000000000
private static final int RUNNING = -1 << COUNT_BITS;
//表示线程池状态为 shutdown
//00000000000000000000000000000000
private static final int SHUTDOWN = 0 << COUNT_BITS;
//表示线程池的状态为 stop
//00100000000000000000000000000000
private static final int STOP = 1 << COUNT_BITS;
//表示线程池的状态为 tidying
//01000000000000000000000000000000
private static final int TIDYING = 2 << COUNT_BITS;
//表示线程池的状态为 terminated
//01100000000000000000000000000000
private static final int TERMINATED = 3 << COUNT_BITS;
//获取线程池的运行状态
private static int runStateOf(int c) { return c & ~CAPACITY; }
//获取线程池中 worker 的数量，也就是线程的数量，因为一个 worker 对象对应一个线程
private static int workerCountOf(int c) { return c & CAPACITY; }
// rs：表示线程池的运行状态即 runstate
// wc：表示线程池中 worker 数量即线程数量 workerCount
// 因此这两个取或，得到的就是 ctl 变量的值
private static int ctlOf(int rs, int wc) { return rs | wc; }
// c：ctl 属性的值
// s：线程池的各种状态（RUNNING、STOP等)
//这个方法就是返回线程池当前的状态是否小于 s
//举一个例子，如果 s 为 STOP，这个方法如果返回 true 那么说明线程池是RUNNING，或者SHUTDOWN 状态；false 的话就是STOP\TiDYING\TERMINATED 其中之一
private static boolean runStateLessThan(int c, int s) {
return c < s;
}
// c：ctl 属性的值
// s：线程池的各种状态（RUNNING、STOP等)
//这个方法就是返回线程池当前的状态最小是否是 s
// 和上面的方法类似，这里就不分析了
private static boolean runStateAtLeast(int c, int s) {
return c >= s;
}
// c：ctl 属性的值
//该方法用于判断线程池的状态是否是RUNNING
// 由于 RUNNING 状态的 ctl 小于 0 所以只要小余 SHUTDOWN 则是RUNNING状态
private static boolean isRunning(int c) {
return c < SHUTDOWN;
}
线程池状态介绍
RUNNING：表示线程池正在运行，它能接受并处理任务；
SHUTDOWN：表示线程池被关闭，不能再接受任务，但是会把队列中的任务处理完；
STOP：表示线程池已经停止，它除了不接受任务，还会抛弃队列中剩下的任务，而且会中断正在被执行的任务；
TIDYING：线程在被关闭后可能会变成的状态，这个状态我觉得主要是提供给用户做一些清理的工作，因为线程池中有一个没有任何实现的 terminated 方法，因此用户可以用来做一些清理的操作。
TERMINATED：线程池在调用完 terminated 方法后，就会被设置为这个状态，这个也是线程池最后的状态了；
网友评论