Java线程池框架核心代码分析
前言
多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和资源消耗都是很高的。线程池应运而生,成为我们管理线程的利器。Java 通过Executor
接口,提供了一种标准的方法将任务的提交过程和执行过程解耦开来,并用Runnable
表示任务。
下面,我们来分析一下 Java 线程池框架的实现ThreadPoolExecutor
。
下面的分析基于JDK1.7
生命周期
ThreadPoolExecutor
中,使用CAPACITY
的高3位来表示运行状态,分别是:
- RUNNING:接收新任务,并且处理任务队列中的任务
- SHUTDOWN:不接收新任务,但是处理任务队列的任务
- STOP:不接收新任务,不出来任务队列,同时中断所有进行中的任务
- TIDYING:所有任务已经被终止,工作线程数量为 0,到达该状态会执行
terminated()
- TERMINATED:
terminated()
执行完毕
状态转换图
ThreadPoolExecutor
中用原子类来表示状态位
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
线程池模型
核心参数
corePoolSize
:最小存活的工作线程数量(如果设置allowCoreThreadTimeOut
,那么该值为 0)maximumPoolSize
:最大的线程数量,受限于CAPACITY
keepAliveTime
:对应线程的存活时间,时间单位由TimeUnit指定workQueue
:工作队列,存储待执行的任务RejectExecutionHandler
:拒绝策略,线程池满后会触发
线程池的最大容量:CAPACITY
中的前三位用作标志位,也就是说工作线程的最大容量为(2^29)-1
四种模型
CachedThreadPool
:一个可缓存的线程池,如果线程池的当前规模超过了处理需求时,那么将回收空闲的线程,当需求增加时,则可以添加新的线程,线程池的规模不存在任何的限制。FixedThreadPool
:一个固定大小的线程池,提交一个任务时就创建一个线程,直到达到线程池的最大数量,这时线程池的大小将不再变化。SingleThreadPool
:一个单线程的线程池,它只有一个工作线程来执行任务,可以确保按照任务在队列中的顺序来串行执行,如果这个线程异常结束将创建一个新的线程来执行任务。ScheduledThreadPool
:一个固定大小的线程池,并且以延迟或者定时的方式来执行任务,类似于Timer。
执行任务 execute
核心逻辑:
- 当前线程数量 <
corePoolSize
,直接开启新的核心线程执行任务addWorker(command, true)
- 当前线程数量 >=
corePoolSize
,且任务加入工作队列成功- 检查线程池当前状态是否处于
RUNNING
- 如果否,则拒绝该任务
- 如果是,判断当前线程数量是否为 0,如果为 0,就增加一个工作线程。
- 检查线程池当前状态是否处于
- 开启普通线程执行任务
addWorker(command, false)
,开启失败就拒绝该任务
从上面的分析可以总结出线程池运行的四个阶段:
poolSize < corePoolSize
且队列为空,此时会新建线程来处理提交的任务poolSize == corePoolSize
,此时提交的任务进入工作队列,工作线程从队列中获取任务执行,此时队列不为空且未满。poolSize == corePoolSize
,并且队列已满,此时也会新建线程来处理提交的任务,但是poolSize < maxPoolSize
poolSize == maxPoolSize
,并且队列已满,此时会触发拒绝策略
拒绝策略
前面我们提到任务无法执行会被拒绝,RejectedExecutionHandler
是处理被拒绝任务的接口。下面是四种拒绝策略。
AbortPolicy
:默认策略,终止任务,抛出RejectedExceptionCallerRunsPolicy
:在调用者线程执行当前任务,不抛异常DiscardPolicy
: 抛弃策略,直接丢弃任务,不抛异常DiscardOldersPolicy
:抛弃最老的任务,执行当前任务,不抛异常
线程池中的 Worker
Worker
继承了AbstractQueuedSynchronizer
和Runnable
,前者给Worker
提供锁的功能,后者执行工作线程的主要方法runWorker(Worker w)
(从任务队列捞任务执行)。Worker 引用存在workers
集合里面,用mainLock
守护。
private final ReentrantLock mainLock = new ReentrantLock();
private final HashSet<Worker> workers = new HashSet<Worker>();
核心函数 runWorker
下面是简化的逻辑,注意:每个工作线程的run
都执行下面的函数
final void runWorker(Worker w) {Thread wt = Thread.currentThread();Runnable task = w.firstTask;w.firstTask = null;while (task != null || (task = getTask()) != null) {w.lock();beforeExecute(wt, task);task.run();afterExecute(task, thrown);w.unlock();}processWorkerExit(w, completedAbruptly);
}
- 从
getTask()
中获取任务 - 锁住 worker
- 执行
beforeExecute(wt, task)
,这是ThreadPoolExecutor
提供给子类的扩展方法 - 运行任务,如果该worker有配置了首次任务,则先执行首次任务且只执行一次。
- 执行
afterExecute(task, thrown);
- 解锁 worker
- 如果获取到的任务为 null,关闭 worker
获取任务 getTask
线程池内部的任务队列是一个阻塞队列,具体实现在构造时传入。
private final BlockingQueue<Runnable> workQueue;
getTask()
从任务队列中获取任务,支持阻塞和超时等待任务,四种情况会导致返回null
,让worker
关闭。
- 现有的线程数量超过最大线程数量
- 线程池处于
STOP
状态 - 线程池处于
SHUTDOWN
状态且工作队列为空 - 线程等待任务超时,且线程数量超过保留线程数量
核心逻辑:根据timed
在阻塞队列上超时等待或者阻塞等待任务,等待任务超时会导致工作线程被关闭。
timed = allowCoreThreadTimeOut || wc > corePoolSize;
Runnable r = timed ?workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :workQueue.take();
在以下两种情况下等待任务会超时:
- 允许核心线程等待超时,即
allowCoreThreadTimeOut(true)
- 当前线程是普通线程,此时
wc > corePoolSize
工作队列使用的是BlockingQueue
,这里就不展开了,后面再写一篇详细的分析。
总结
ThreadPoolExecutor
基于生产者-消费者模式,提交任务的操作相当于生产者,执行任务的线程相当于消费者。Executors
提供了四种基于ThreadPoolExecutor
构造线程池模型的方法,除此之外,我们还可以直接继承ThreadPoolExecutor
,重写beforeExecute
和afterExecute
方法来定制线程池任务执行过程。- 使用有界队列还是无界队列需要根据具体情况考虑,工作队列的大小和线程的数量也是需要好好考虑的。
- 拒绝策略推荐使用
CallerRunsPolicy
,该策略不会抛弃任务,也不会抛出异常,而是将任务回退到调用者线程中执行。
Java线程池框架核心代码分析相关推荐
- Java 线程池框架核心代码分析
转载自 Java 线程池框架核心代码分析 前言 多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和资源消耗都是很高的.线程池应运而生,成为我们管理线程的利器.Java 通过Executo ...
- Java 线程池框架核心代码分析--转
原文地址:http://www.codeceo.com/article/java-thread-pool-kernal.html 前言 多线程编程中,为每个任务分配一个线程是不现实的,线程创建的开销和 ...
- [转载] Java线程池框架源码分析
转载自http://www.linuxidc.com/Linux/2014-11/108791.htm 相关类Executor,Executors,AbstractExecutorService,Ex ...
- Java线程池ThreadPoolExecutor使用和分析(三) - 终止线程池原理
相关文章目录: Java线程池ThreadPoolExecutor使用和分析(一) Java线程池ThreadPoolExecutor使用和分析(二) - execute()原理 Java线程池Thr ...
- Java线程池ThreadPoolExecutor使用和分析
Java线程池ThreadPoolExecutor使用和分析(一) Java线程池ThreadPoolExecutor使用和分析(二) Java线程池ThreadPoolExecutor使用和分析(三 ...
- idea 线程内存_Java线程池系列之-Java线程池底层源码分析系列(一)
课程简介: 课程目标:通过本课程学习,深入理解Java线程池,提升自身技术能力与价值. 适用人群:具有Java多线程基础的人群,希望深入理解线程池底层原理的人群. 课程概述:多线程的异步执行方式,虽然 ...
- idea 线程内存_Java线程池系列之-Java线程池底层源码分析系列(二)
课程简介: 课程目标:通过本课程学习,深入理解Java线程池,提升自身技术能力与价值. 适用人群:具有Java多线程基础的人群,希望深入理解线程池底层原理的人群. 课程概述:多线程的异步执行方式,虽然 ...
- JAVA线程池(ThreadPoolExecutor)源码分析
JAVA5提供了多种类型的线程池,如果你对这些线程池的特点以及类型不太熟悉或者非常熟悉,请帮忙看看这篇文章(顺便帮忙解决里面存在的问题,谢谢!): http://xtu-xiaoxin.ite ...
- JAVA线程池 -clt设计与分析
1. 前言 ctl 是线程池源码中常常用到的一个变量. 它的主要作用是记录线程池的生命周期状态和当前工作的线程数. 作者通过巧妙的设计,将一个整型变量按二进制位分成两部分,分别表示两个信息. 2. 源 ...
最新文章
- iOS开发火了九年,这些错误你还在犯嘛?
- Data Structure_Sort Algorithm
- 【NLP】一文速览 | 对话生成预训练模型
- boost::endian::endian_arithmetic的测试程序
- 为什么我们应该担心华尔街的人工智能
- 没有什么不可能!郴州女孩江梦南,从双耳失聪到清华博士!
- openssl 升级
- log添加 oracle redo_Redo Log之一:理解Oracle redo log
- Node.js入门:文件查找机制
- 合肥工业大学数据库上机实验1
- Charles(青花瓷)抓包工具的使用
- CSS线性渐变网站记录
- 数据结构java实验_20172301 《Java软件结构与数据结构》实验一报告
- 公平的席位分配MATLAB编程(Q值法)
- 探索的动机: 爱因斯坦于1918年4月的讲话
- 极客学院 Android 系统体系教程
- 云计算、社交网络和移动互联网
- PS 切片工具的使用
- Fabric 1.0源代码分析(31) Peer
- phython 错题
热门文章
- 【模型开发】EDA探索性分析
- 【Python】对self和_init_的理解
- 腾讯企点总经理张晔:To B企业存在的价值是什么?丨鲸犀峰会
- Google和eBay在建设微服务生态系统中的深刻教训
- 深度学习入门教程UFLDL学习实验笔记三:主成分分析PCA与白化whitening
- 北京迎“豪宅元年”:四环房价将迈入8万元时代
- 转载:谢谢原作者:块设备驱动实战基础篇四 (逐渐成型,加入ioctl通信机制)
- jvm性能调优 - 03垃圾回收机制
- JVM - 解读GC中的 Safe Point Safe Region
- C++五子棋(一)——开发环境