【Java并发编程】面试必备之线程池
什么是线程池
是一种基于池化思想管理线程的工具。池化技术:池化技术简单点来说,就是提前保存大量的资源,以备不时之需。比如我们的对象池,数据库连接池等。
线程池好处
我们为什么要使用线程池,直接new thread start
不好吗?
「降低资源消耗」: 通过重复利用已创建的线程来降低线程创建和销毁所造成的消耗。
「提高响应速度:」 任务到达时,可以立即执行,不需要等到线程创建再来执行任务。
「提高线程的可管理性:」 线程是稀缺资源,如果无限制创建,不仅会消耗系统资源,还会因为线程的不合理分布导致资源调度失衡,降低系统的稳定性。使用线程池可以进行统一的分配、调优和监控。
线程池的执行流程
我们先来看看线程池的一个执行流程图,此图来自文末参考1
通过上述图我们可以得出线程池执行任务可以有以下几种情况:
如果当前的运行线程小于
coreSize
,则创建新线程来执行任务。如果当前运行的线程等于
coreSize
或多余coreSize
(动态修改了coreSize
才会出现这种情况),把任务放到阻塞队列中。如果队列已满无法将新加入的任务放进去的话,则需要创建新的线程来执行任务。
如果新创建线程已经达到了最大线程数,任务将会被拒绝。
怎么用线程池
在java jdk
的Executors
有提供创建不同线程池的方法(一般不推荐这种做法)阿里巴巴的开发手册也明确强制规定不让通过Executors
来创建的,在一些公司的开发规范里面应该也会有这么一条吧。
newFixedThreadPool
newSingleThreadExecutor
newCachedThreadPool
newScheduledThreadPool
newWorkStealingPool (jdk1.8新增的) 我们可以使用ThreadPoolExecutor来创建线程池
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler)
我们可以看出创建线程池有七个参数,而上述我们通过Executors
工具类来创建的线程池就一两个参数,其他参数它都帮我们默认写死了,我们只有真正理解了这几个参数才能更好的去使用线程池。下面我们来看看这七个参数(线程池参数)。
corePoolSize
核心线程数(线程池的基本大小)当我们提交一个任务到线程池时就会创建一个线程来执行任务.当我们需要执行的任务数大于核心线程数了就不再创建, 如果我们调用了
prestartAllCoreThreads
()方法线程池就会为我们提前创建好所有的基本线程。
maximumPoolSize
最大线程数:线程池允许创建的最大线程数。如果队列已经满了,且已创建的线程数小于最大线程数,则线程池就会创建新的线程来执行任务。这里有个小知识点,如果我们的队列是用的无界队列,这个参数是不会起作用的,因为我们的任务会一直往队列中加,队列永远不会满(内存允许的情况)。
keepAliveTime
空闲线程最大生存时间。当前线程数大于核心线程数时,结束多余的空闲线程等待新任务的最长时间。默认情况下,只有当线程池中的线程数大于
corePoolSize
时,keepAliveTime
才会起作用,直到线程池中的线程数不大于corePoolSize
,即当线程池中的线程数大于corePoolSize
时,如果一个线程空闲的时间达到keepAliveTime
,则会终止,直到线程池中的线程数不超过corePoolSize
。但是如果调用了allowCoreThreadTimeOut
(boolean)方法,在线程池中的线程数不大于corePoolSize
时,keepAliveTime
参数也会起作用,直到线程池中的线程数为0;比如当前线程池中最大线程数(maximumPoolSize)为50,核心线程数(corePoolSize)为10,当前正在跑任务的线程数为30.然后是不是空出了20个线程没活干,所以这20个线程就要被消毁,有点卸磨杀驴的感觉。如果剩下的30个线程干完活了也休息了keepAliveTime这么久,然后这30个线程里面也要被销毁20个,就保留个核心线程。如果设置了allowCoreThreadTimeOut
等于true
核心线程也会被销毁。就跟我们做外包项目一样,甲方项目完成了就得去另外一个甲方,如果短时间内都没有甲方接纳你的话,你就要被辞退了,只会留下几个核心人员维护下项目,如果甲方项目维护的话用自己的人的话,所有的外包人会都会被辞退。
unit
线程存活时间的的单位。可选的单位有
days
、hours
等。
workQueue
任务队列。可以选择以下这些队列
threadFactory
用户设置创建线程的工厂,我们可以通过这个工厂来创建有业务意义的线程名字。我们可以对比下自定义的线程工厂和默认的线程工厂创建的名字。
默认产生线程的名字 | 自定义线程工厂产生名字 |
---|---|
pool-5-thread-1 | testPool-1-thread-1 |
阿里开发手册也有明确说到,需要指定有意义的线程名字。
RejectedExecutionHandler
线程池拒绝策略。当队列和线程池都满了说明线程池已经处于饱和状态。必须要采取一定的策略来处理新提交的任务。jdk默认提供了四种拒绝策略:其实我们也可以自定义任务拒绝策略(实现下
RejectedExecutionHandler
接口),比如说如果任务拒绝了我们可以记录下日志,或者重试等,根据自己的业务需求来实现。dubbo
任务拒绝策略
@Overridepublic void rejectedExecution(Runnable r, ThreadPoolExecutor e) {String msg = String.format("Thread pool is EXHAUSTED!" +" Thread Name: %s, Pool Size: %d (active: %d, core: %d, max: %d, largest: %d), Task: %d (completed: "+ "%d)," +" Executor status:(isShutdown:%s, isTerminated:%s, isTerminating:%s), in %s://%s:%d!",threadName, e.getPoolSize(), e.getActiveCount(), e.getCorePoolSize(), e.getMaximumPoolSize(),e.getLargestPoolSize(),e.getTaskCount(), e.getCompletedTaskCount(), e.isShutdown(), e.isTerminated(), e.isTerminating(),url.getProtocol(), url.getIp(), url.getPort());logger.warn(msg);dumpJStack();dispatchThreadPoolExhaustedEvent(msg);throw new RejectedExecutionException(msg);}
我们可以看出dubbo
的拒绝策略主要记录了详细的级别为warm的日志、输出当前线程堆栈详情、继续抛出拒绝任务异常。
线程池参数如何设置?
线程池既然有这么多参数那么我们如何去根据自己的业务实际情况来去合理的设置每个参数?
一般我们如果任务为耗时
IO
型比如读取数据库、文件读写以及网略通信的的话这些任务不会占据很多cpu
的资源但是会比较耗时:线程数设置为2倍CPU数以上,充分的来利用CPU
资源。一般我们如果任务为CPU密集型的话比如大量计算、解压、压缩等这些操作都会占据大量的cpu。所以针对于这种情况的话一般设置线程数为:1倍cpu+1。为啥要加1,很多说法是备份线程。
如果既有IO密集型任务,又有
CPU
密集型任务,这种该怎么设置线程大小?这种的话最好分开用线程池处理,IO
密集的用IO
密集型线程池处理,CPU
密集型的用cpu密集型处理。以上都只是理算情况下的估算而已,真正的合理参数还是需要看看实际生产运行的效果来合理的调整的。
监控线程池
线程池工作是否饱和?线程的情况如何?总共执行了多少个任务?现在线程池的运行情况如何?队列里面是否有堆积任务?面对上面这些问题,线程池也有提供一些方法可以让我们来查看上面这些指标。有了这些参数我们是不是调整线程池的参数就更加方便了。或者根据线程池的活跃程度我们自动来调节(动态调整下篇再来说)线程池的参数。
关于线程池的几个问题
线程池是否区分核心线程和非核心线程?
如何保证核心线程不被销毁?
线程池的线程是如何做到复用的?以上几个小问题我们去看看线程池的源码,这几个问题应该就不成问题了,我们下篇见。
特别推荐一个分享架构+算法的优质内容,还没关注的小伙伴,可以长按关注一下:
长按订阅更多精彩▼如有收获,点个在看,诚挚感谢
【Java并发编程】面试必备之线程池相关推荐
- [Java并发编程(一)] 线程池 FixedThreadPool vs CachedThreadPool ...
[Java并发编程(一)] 线程池 FixedThreadPool vs CachedThreadPool ... 摘要 介绍 Java 并发包里的几个主要 ExecutorService . 正文 ...
- Java 并发编程——Executor框架和线程池原理
Java 并发编程系列文章 Java 并发基础--线程安全性 Java 并发编程--Callable+Future+FutureTask java 并发编程--Thread 源码重新学习 java并发 ...
- [Java并发编程(二)] 线程池 FixedThreadPool、CachedThreadPool、ForkJoinPool?为后台任务选择合适的 Java executors...
[Java并发编程(二)] 线程池 FixedThreadPool.CachedThreadPool.ForkJoinPool?为后台任务选择合适的 Java executors ... 摘要 Jav ...
- Java并发编程(08):Executor线程池框架
本文源码:GitHub·点这里 || GitEE·点这里 一.Executor框架简介 1.基础简介 Executor系统中,将线程任务提交和任务执行进行了解耦的设计,Executor有各种功能强大的 ...
- Java并发编程:4种线程池和缓冲队列BlockingQueue
一. 线程池简介 1. 线程池的概念: 线程池就是首先创建一些线程,它们的集合称为线程池.使用线程池可以很好地提高性能,线程池在系统启动时即创建大量空闲的线程,程序将一个任务传给线程池,线程池就会启动 ...
- java 线程钩子_高级并发编程系列六(线程池钩子函数)
1.考考你 国庆假期快要结束了,准备回到工作岗位的你,是不是已经开始撸起袖子敲代码,反正发完文章我就要准备去加班了,程序员就这样,有干劲对吧 那么来吧,让我们一起分享完高级并发编程系列中,线程池小节的 ...
- 高并发编程-自定义简易的线程池(2),体会原理
文章目录 概述 示例 概述 高并发编程-自定义简易的线程池(1),体会原理 中只实现了任务队列,我们这里把其余的几个也补充进来 拒绝策略 关闭线程池 最小 最大 活动线程数 - 示例 比较简单,直接上 ...
- 《Java并发编程的艺术》——线程(笔记)
文章目录 四.Java并发编程基础 4.1 线程简介 4.1.1 什么是线程 4.1.2 为什么要使用多线程 4.1.3 线程优先级 4.1.4 线程的状态 4.1.5 Daemon线程 4.2 启动 ...
- Java并发编程|第二篇:线程生命周期
文章目录 系列文章 1.线程的状态 2.线程生命周期 3.状态测试代码 4.线程终止 4.1 线程执行完成 4.2 interrupt 5.线程复位 5.1interrupted 5.2抛出异常 6. ...
- 【Java 并发编程】多线程、线程同步、死锁、线程间通信(生产者消费者模型)、可重入锁、线程池
并发编程(Concurrent Programming) 进程(Process).线程(Thread).线程的串行 多线程 多线程的原理 多线程的优缺点 Java并发编程 默认线程 开启新线程 `Ru ...
最新文章
- 菜鸟实时数仓2.0进阶之路
- 使用stm32的ADC得到准确的电压
- 【Android开发】文本框、按钮、文本编辑框、提交登录、单选框
- leetcode739 每日温度
- LeetCode 1119. 删去字符串中的元音
- python屏幕文字识别_python中使用OCR 技术进行《文字识别》
- iframe并没有错
- 如何检查视频画面延迟的时间
- 智能读物产品优化、运营方案
- 树莓派PICO:DS1302时钟芯片(MicroPython)
- 嵌入式linux摄像头录像存储,韦东山嵌入式Linux_3期之USB摄像头监控_手机App增添录像功效(二)...
- 电子秤称东西用计算机怎么算,电子秤怎么连接电脑?
- Dhtmlx Gantt 快速入门至精通
- python适合创业吗-python创业
- [高项]管理沟通VS控制沟通
- menu在python中的意思_Python-Tkinter 组件之Menu
- 泰勒(Taylor)展开式(泰勒级数)
- 淘宝API-天天特价
- 泛泛而谈的菜鸟学习记录(二)—— unity静态和动态批处理
- MobileNetV2:Inverted Residuals and Linear BottleNecks
热门文章
- LINUX按照物理地址预取,linux – 如何以编程方式禁用硬件预取?
- 河南城建学院linux期末试题,河南城建学院09-10(上)期末试题.ppt
- 关于贝叶斯统计的一点总结
- java中字节输入流和输出流的简单使用例子
- 单调栈 or 线段树扫描线 ---- E. Delete a Segment [单调栈+二分] [扫描线处理空白位置的技巧乘2]
- js 去掉地址栏内参数_JS获取网站地址栏URL中的参数值并转换成json对象
- 4一20ma电流有源与无源区别_4-20 mA电流环的工作原理是怎么样的
- 语言舒尔特方格程序_注意力训练神器——舒尔特方格(成人、孩子均适用)
- 解题报告(十三)中国剩余定理(ACM / OI)
- HDU - 6486 Flower(思维)