Java高并发27-ThreadPoolExecutor原理剖析(1)
程序员文章站
2022-03-11 12:54:57
类图 27.1 线程池的好处: (1)性能好;(2)工厂方法便捷创建线程,个数自定义指定 类图描述 Excutors其实是一个工具类,ThreadPoolExecutor继承了AbstractExecutorService,成员变量ctl是一个Integer的原子变量,用来记录线程池的状态和线程池中 ......
类图
27.1
线程池的好处:
(1)性能好;(2)工厂方法便捷创建线程,个数自定义指定
类图描述
excutors其实是一个工具类,threadpoolexecutor继承了abstractexecutorservice,成员变量ctl是一个integer的原子变量,用来记录线程池的状态和线程池中的线程个数 这个integer原子变量,前三位代表的是线程池的状态,后面29位代表的是线程池中线程的个数
private final atomicinteger ctl = new atomicinteger(ctlof(running,0);
// 默认状况下是running状态,现成的个数为0
private static final int count_bits = integer.size - 3;
// 线程池的最大个数
private static final int capacity = (1 << count_bits) - 1;
// 下面是线程池的状态
// 11100000000000000000000000000
private static final int running = -1 << count_bits;
// 00000000000000000000000000000
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;
private static int runstateof(int c) {
return c & ~capacity;
} // 该函数用于获取线程池的运行状态
private static int ctlof(int c) {
return c & capacity;
} // 获取线程池中线程的个数
private static int ctlof(int rc,int wc) {
return rs | wc;
} // 计算ctl新值
线程池的状态含义
running:接收新任务并且处理阻塞队列中的任务 shutdown:拒绝新任务但是处理阻塞队列中的任务 stop:拒绝新任务并且放弃阻塞队列中的任务,同时中断正在处理的业务 tidying:所有任务都处理完(包括处于阻塞队列中的任务)后线程池中的活动线程为0,将要调用terminate方法 treminated:终止状态,调用terminate方法之后的状态