码迷,mamicode.com
首页 > 编程语言 > 详细

JDK1.8中的线程池

时间:2018-01-07 00:45:56      阅读:169      评论:0      收藏:0      [点我收藏+]

标签:tor   图片   shutdown   状态   linked   整型   返回   循环   final   

 

技术分享图片

上面这段代码一直在用,面试的时候也经常被问到,却从未深究过,不知道线程池到底是怎么回事,今天看看源代码,一探其究竟

技术分享图片

技术分享图片

线程池主要控制的状态是ctl,它是一个原子的整数,其包含两个概念字段:

  • workerCount:有效的线程数量
  • runState:线程池的状态

为了在一个整型值里面包含这两个字段,我们限制workerCount最多2的29次方减1

runState的值有这样几种:

  • RUNNING:  接受新的任务,并处理队列中的任务
  • SHUTDOWN:不接受新的任务,继续处理队列中的任务
  • STOP:           不接受新的任务,也不处理队列中的任务,并且中断正在处理的任务
  • TIDYING:      所有任务都结束了,workerCount是0,通过调用terminated()方法转换状态
  • TERMINATED:terminated()方法已经完成

状态之间的转换时这样的:

RUNNING -> SHUTDOWN

  调用shutdown()方法,或者隐式的调用finalize()方法

(RUNNING or SHUTDOWN) -> STOP

  调用shoutdownNow()方法

SHUTDOWN -> TIDYING

  当队列和池都是空的时候

STOP -> TIDYING

  当池是空的时候

TIDYING -> TERMINATED

  当terminated()方法调用完成时

 

Integer.SIZE=31

Integer.SIZE - 3 = 29

所以,COUNT_BITS = 29

高3位存储runState

 

接下来看最复杂的那个构造方法

技术分享图片

参数详解

  • corePoolSize:保持在池中的线程数(PS:即使它们处于空闲状态)
  • maximumPoolSize:池中允许的最大线程数
  • keepAliveTime:当线程数超过核心线程数的时候,超出的线程的最大生存时间
  • unit:keepAliveTime的单位
  • workQueue:维护待处理的任务的队列
  • threadFactory:创建线程的工厂

 

技术分享图片

技术分享图片

1、如果正在运行的线程数少于核心线程数,则新建一个线程去运行这个任务

2、如果工作队列没有满,则放到工作队列中

3、如果工作队列已满(PS:workQueue.offer(command)返回false),则再新建线程

4、若线程数已经达到最大线程数则reject(command)

技术分享图片

技术分享图片

在前面execute方法中,有3处调用了addWork()方法

第一处,如果当前有效线程数少于核心线程数,则调用之,此时线程数的边界是核心线程数

第二处,如果当前有效线程数超过核心线程数,并且将新任务放到队列中,此时有效线程数是0,则创建一个新线程

第三处,如果当前有效线程数超过核心线程数,并且队列已经放满了,并且有效线程数小于最大线程数,此时调用以创建新线程,

 

当前的有效线程都在works里面,而works里面放的是Worker对象,接下来看Worker

技术分享图片

前一步中,线程的start()方法,线程运行的时候执行run()方法,而Worker继承Runnable并重新run()方法,run()方法又调用外部的runWorker()方法,所以,在线程池中新创建的线程运行时调用的是runWorker()方法

技术分享图片

runWorker()方法循环的从队列中取出任务并执行它。也就是说,池中所有的线程都是在创建的时候如果传进来新任务,则先执行新任务,然后循环从队列中取出任务并执行

 

接下来,看Executors中常见的几种线程池的区别

技术分享图片

技术分享图片

技术分享图片

可以看到

newSingleThreadExecutor:核心线程数和最大线程数都是1,队列是LinkedBlockingQueue

newFixedThreadPool:核心线程数和最大线程数相等,超过核心线程数的空闲线程生存时间是0,队列是LinkedBlockingQueue

newCachedThreadPool:核心线程数是0,最大线程数是Integer.MAX_VALUE,空闲线程生存时间是1min,队列是SynchronousQueue

 

JDK1.8中的线程池

标签:tor   图片   shutdown   状态   linked   整型   返回   循环   final   

原文地址:https://www.cnblogs.com/cjsblog/p/8214921.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!