线程池：ThreadPoolExcutor源码阅读

ThreadPoolExcutor源码流程图：（图片较大，下载再看比较方便）

线程池里的二进制奥秘

前言：

线程池的五种状态state（RUNNING、SHUTDOWN、STOP、TIDYING、TERMINATED）和线程池的工作线程数：workerCount,

这两个变量，可有通过一个变量ctl转成二进制后而获得。

直接看线程池ThreadPoolExecutor源码里，管理状态和工作线程数的代码

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;

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;

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; }

Integer.size为Integer类型最大值的二进制的位数：32（位），COUNT_BITS = 29（位），为啥是要要减去3，拿个29呢，因为它想用二进制高3位来表示线程池的状态（state），后面的29位用来表示工作线程数量（workerCount）。

比如RUNNINGZ状态是 -1左移29位，即：

-1的二进制算法，先取绝对值1的二进制：00000000 00000000 00000001，再取反码：11111111 11111111 11111110

再取补码（加1）：11111111 11111111 11111111 ，这就是-1的二进制表示。

左移运算：-1<<29 = 11100000 00000000 00000000 （左移29位, 移动多少位, 后面补多少个0, 高于32位的去掉）。

各个state：

-1<<29 = 11100000 00000000 00000000 => RUNNINGZ

0<< 29 = 00000000 00000000 00000000 => SHUTDOWN

1 <<29 = 00100000 00000000 00000000 => STOP

2 <<29 = 01000000 00000000 00000000 => TIDYING

3 <<29 = 01100000 00000000 00000000 => TERMINATED

线程池就是这样用高三位来表示不同的状态。

所以状态还有这样的关系： RUNNINGZ < SHUTDOWN < STOP < TIDYING < TERMINATED

不管各个状态低29位是啥，这个关系都不会变。

再看CAPACITY = (1<<29) -1：

即00100000 00000000 00000000 - 1 = 00011111 11111111 11111111 ，这是线程池最大容量线程数（536870911），

即是用1到29位可表示线程的数量，那么，ctl = state.高3位 + 低29位，如：

ctl = 11111111 11111111 11111111，表示线程池是RUNNINGZ状态，且线程数为536870911；

ctl = 00000000 00000000 00000001，表示线程池是SHUTDOWN状态，且线程数为1；

CAPACITY=536870911，表示线程池最大线程数容量为536870911，但这个最大数值可以忽略，

因为在实例化线程池的时候，已经通过传参数设置了核心线程数、允许最大线程数。

初始化为 ctl = new AtomicInteger(ctlOf(RUNNING, 0));

ctlOf(RUNNING, 0)参数中的0，意思是初始化线程池的线程数为0。然后通过ctlOf做或运算，即：

11100000 00000000 00000000 | 00000000 00000000 00000000 = 11100000 00000000 00000000

运算后的结果，把表示状态的高3位、表示线程数的低29位组合起来得到一个数ctl，

下次拿到ctl之后，就知道此时线程池的状态和线程数量了。

1、那么runStateOf(int c)方法具体是怎么知道线程池的状态的?

假设c = ctl.get() = 00100000 00000000 00000011，表示STOP状态且还有3个线程

CAPACITY = （1<<29）- 1 = 00100000 00000000 00000000 - 1 = 00011111 11111111 11111111

为啥要减1呢？因为减1后：

1、把表示状态的高3位给挪留出来了,值又可以表示线程池最大线程数。

2、把表示线程数的低29位变为了1，那 ~CAPACITY = 11100000 00000000 00000000，所以：

c &~CAPACITY =00100000 00000000 00000011 & 11100000 00000000 00000000 = 00100000 00000000 00000000，

结果00100000 00000000 00000000保持c的高3位不变，把c的低29位全变成0,这就是获得线程池是STOP状态

2、通过workerCountOf(int c)获取工作线程数，同上理

线程池：ThreadPoolExcutor源码阅读的更多相关文章

深入浅出Java线程池：源码篇
前言在上一篇文章深入浅出Java线程池:理论篇中,已经介绍了什么是线程池以及基本的使用.(本来写作的思路是使用篇,但经网友建议后,感觉改为理论篇会更加合适).本文则深入线程池的源码,主要是介绍Thr ...
Java并发包源码学习系列：线程池ScheduledThreadPoolExecutor源码解析
目录 ScheduledThreadPoolExecutor概述类图结构 ScheduledExecutorService ScheduledFutureTask FutureTask schedu ...
java线程池ThreadPoolExector源码分析
java线程池ThreadPoolExector源码分析今天研究了下ThreadPoolExector源码,大致上总结了以下几点跟大家分享下: 一.ThreadPoolExector几个主要变量先 ...
linux线程池thrmgr源码解析
linux线程池thrmgr源码解析 1 thrmgr线程池的作用 thrmgr线程池的作用是提高程序的并发处理能力,在多CPU的服务器上运行程序,可以并发执行多个任务. 2 ...
Java并发包源码学习系列：线程池ThreadPoolExecutor源码解析
目录 ThreadPoolExecutor概述线程池解决的优点线程池处理流程创建线程池重要常量及字段线程池的五种状态及转换 ThreadPoolExecutor构造参数及参数意义 Work类 ...
一个python线程池的源码解析
python为了方便人们编程高度封装了很多东西,比如进程里的进程池,大大方便了人们编程的效率,但是默认却没有线程池,本人前段时间整理出一个线程池,并进行了简单的解析和注释,本人水平有限,如有错误希望高 ...
Java调度线程池ScheduledThreadPoolExecutor源码分析
最近新接手的项目里大量使用了ScheduledThreadPoolExecutor类去执行一些定时任务,之前一直没有机会研究这个类的源码,这次趁着机会好好研读一下. 该类主要还是基于ThreadPoo ...
[转载] Java线程池框架源码分析
转载自http://www.linuxidc.com/Linux/2014-11/108791.htm 相关类Executor,Executors,AbstractExecutorService,Ex ...
线程池ThreadPoolExecutor源码解读研究（JDK1.8）
一.什么是线程池为什么要使用线程池?在多线程并发开发中,线程的数量较多,且每个线程执行一定的时间后就结束了,下一个线程任务到来还需要重新创建线程,这样线程数量特别庞大的时候,频繁的创建线程和销毁线程 ...
java内置线程池ThreadPoolExecutor源码学习记录
背景公司业务性能优化,使用java自带的Executors.newFixedThreadPool()方法生成线程池.但是其内部定义的LinkedBlockingQueue容量是Integer.MAX ...

随机推荐

MySQL性能优化
当今数据库的操作越来越成为整个应用的性能瓶颈,特别是Web应用更加明显.当我们设计数据库和对数据库操作时,都要考虑到性能. 1.优化查询语句,方便查询缓存大多数MySQL服务器都开启了查询缓存,这是 ...
git 命令使用总结
聊下 git rebase -i 聊下git merge --squash 聊下git pull --rebase 聊下 git remote prune origin 聊下 git 使用前的一些注意 ...
SQLServer的学习场景（关于row_number()和COALESCE()的使用）
--使用Sql语句,统计出每辆汽车每天行驶的里程数(不是总里程) 以下为脚本 CREATE TABLE [dbo].[CarData]([CarID] [int] NULL,[Mileage] [in ...
for 穷举、迭代 while循环
1.穷举: 把所有可能的情况都走一遍,使用if条件筛选出来满足条件的情况. 2.百鸡百钱:公鸡2文钱一只,母鸡1文钱一只,小鸡半文钱一只,总共只有100文钱,如何在凑够100只鸡的情况下刚好花完100 ...
【转】iOS 删除已经配置的类库和移除CocoaPods
原文网址:http://www.jianshu.com/p/552f21a989ba 引言我们使用CocoaPods非常高效地将一些第三方类库导入到我们的项目中,但是不由得产生一个疑问:如果发现某个 ...
如何用C代码生成二维码
如何用C代码生成二维码当下因微信和支付宝等手机应用广泛使用,而基于二维码/一维条码的移动支付,也借助手机移动端席卷全国,使得越来越多的人知道有"二维码"这么一种东西. 对于普通用 ...
奇怪的JS正则之 /[A-z]/.test("\\"); // true
本文是在一个国外介绍JS的网站上转载过来的,作者很逗,先是举例JS让人XX的例子,再动手实践发现JS隐藏的黑知识.为什么 /[A-z]/.test("\\"); 是 true ,你 ...
[BZOJ 1048] [HAOI2007] 分割矩阵【记忆化搜索】
题目链接:BZOJ - 1048 题目分析感觉这种分割矩阵之类的题目很多都是这样子的. 方差中用到的平均数是可以直接算出来的,然后记忆化搜索 Solve(x, xx, y, yy, k) 表示横坐标 ...
国内常用ntp服务器ip地址
ntp.sjtu.edu.cn 202.120.2.101 (上海交通大学网络中心NTP服务器地址)s1a.time.edu.cn 北京邮电大学s1b.time.edu.cn 清华大学s1c.time ...
Microsoft Dynamics CRM 9.0 OP 版本安装的那些雷
天天讲安装过程好无聊了,还是搞点有营养的东西来,那么后面来说说刚出来的MSCRM OP 9.0 版本安装的那些雷: 雷1:操作系统要求Windows 2016 Server 这点还好,因为之前安装MS ...

当前位置：网站首页>线程池：ThreadPoolExcutor源码阅读

线程池：ThreadPoolExcutor源码阅读

线程池：ThreadPoolExcutor源码阅读的更多相关文章

随机推荐

边栏推荐

猜你喜欢

随机推荐