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密集型处理。以上都只是理算情况下的估算而已,真正的合理参数还是需要看看实际生产运行的效果来合理的调整的。
监控线程池
线程池工作是否饱和?线程的情况如何?总共执行了多少个任务?现在线程池的运行情况如何?队列里面是否有堆积任务?面对上面这些问题,线程池也有提供一些方法可以让我们来查看上面这些指标。有了这些参数我们是不是调整线程池的参数就更加方便了。或者根据线程池的活跃程度我们自动来调节(动态调整下篇再来说)线程池的参数。
关于线程池的几个问题
线程池是否区分核心线程和非核心线程?
如何保证核心线程不被销毁?
线程池的线程是如何做到复用的?以上几个小问题我们去看看线程池的源码,这几个问题应该就不成问题了,我们下篇见。
END推荐好文
强大,10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程!为什么MySQL不推荐使用uuid或者雪花id作为主键?为什么建议大家使用 Linux 开发?爽(外加七个感叹号)IntelliJ IDEA 15款 神级超级牛逼插件推荐(自用,真的超级牛逼)炫酷,SpringBoot+Echarts实现用户访问地图可视化(附源码)记一次由Redis分布式锁造成的重大事故,避免以后踩坑!十分钟学会使用 Elasticsearch 优雅搭建自己的搜索系统(附源码)
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 ...
最新文章
- Core Animation
- maven整合@data注解_SpringBoot 整合 Dubbo实践(实用文章)
- python不想学了-十分钟也学不会python?就不要学python了
- try catch 之后是否会继续执行
- linux系统安装后需要的有效小工具(持续更新)
- java组装树状结构数据集合_JAVA构建List集合为树形结构
- fakeapp2.2.0下载_软件下载 | SuperCuger 测量平差系统 V1.0
- linux服务器程序乱码,Linux安装GBK/GB2312程序显示乱码的五种解决方法
- xshell安装步骤
- 敏捷开发总结(2)开发过程活动
- JVM系列之深入理解JVM(三)
- 赵小楼《天道》《遥远的救世主》深度解析(39)芮小丹的恋爱态度:敞亮
- js动态添加修改删除元素
- sqlserver 默认日期格式转换为 yyyy-MM-dd
- table的样式设置
- The Journey of the Lunch Launcher and Store and Forward Messaging
- python画circos图_从零开始学Circos绘制圈图(一)
- 数据分析进阶 - 使用Pyecharts搭建数据看板
- 在线文档webOffice控件使用心得
- windows7/10中Excel以单独进程窗口打开设置方法?
热门文章
- 中国电信回应“变相涨价说”:对原畅享套餐进行的优化升级
- 华为回应“锁屏广告”事件:非官方所为
- 黄子韬现身助力公益 百度推出听障儿童手语翻译小程序
- 三星Note 10 Pro曝光:搭载骁龙855处理器 后置四摄
- 安卓倒计时 listview默认选中一项
- python数据如何保存到excel中
- 开启事物_用一支洁面慕斯,开启精致生活
- 安排计算机网络技术专业去电子厂专业对口吗,计算机网络技术专业好点的学校有哪些?...
- MMKV_微信MMKV源码分析(一) | 整体流程
- rtp发送h264和h265