关键词：
前言:ThreadPoolExecutor(线程池) 是早些年的东西,但是很久时间不用就会忘记怎么用,仅此篇来记录一下!
要想搞懂ThreadPoolExecutor 那么就得从实际场景出发
并且对比原始new Thread() 看看他们有什么区别
假设现在需要下载100张图片:
普通写法:
public class TPEClient1
private static final int COUNT = 100;
public static void main(String[] args)
for (int i = 0; i < COUNT; i++)
new Thread(new Runnable()
@Override
public void run()
try
Thread.sleep(2000);
catch (InterruptedException e)
e.printStackTrace();
finally
System.out.println("线程:" + Thread.currentThread().getName());
).start();
可以看出,睡眠2秒之后, 确实是创建了100个线程,然后执行了任务
但是这里线程的执行顺序为啥是无序的呢?
那是因为在 Thread#start() 时候,线程不会立刻执行,
而是告诉CPU我需要执行,然后等待CPU去调度
简单的说就是: Thread#start() 只是通知CPU我准备好了, CPU什么时候用,怎么用,都是CPU说了算.
直接new Thread()不足的地方:
很明显, 直接new Thread() 每次都会创建一个单独的线程来执行相同的任务,
看起来代码十分的丑陋,并且也很浪费资源,
最重要的是不好管理, 如果代码中到处是new thread(),维护起来肯定十分的不爽
那么来看看ThreadPoolExecutor是怎么做的
ThreadPoolExecutor
先来看如何创建一个ThreadPoolExecutor()
LinkedBlockingQueue<Runnable> blockQueue = new LinkedBlockingQueue<>(100); // 最多存放100个数据
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(4, // 核心线程数
10, // 最大线程数
10, // 失效时间
TimeUnit.SECONDS, // 失效时间单位
blockQueue, // 队列
new ThreadFactory() // 线程工厂
@Override
public Thread newThread(Runnable r)
return new Thread(r);
,
// 失败策略
new ThreadPoolExecutor.AbortPolicy()
);
这里有最大争议的恐怕是
- 核心线程数
- 最大线程数
还是上面的需求: 假设现在需要下载100张图片,来看看线程池是怎么做的:
首先需要100个任务
创建线程池,正常情况下线程池中的线程是由核心线程数决定的, 我们设置核心线程数为4,那么就创建4个线程
在构建线程池的时候,还需要传入一个队列
这个队列的作用就是来管理100个任务,
当任务来临的时候,将任务加入到队列中,因为有100个任务,
并且在创建队列的时候,我们设置队列的容量为100,刚好可以存放这100个任务
因为在创建线程时只创建4了个线程,所以只能从队列中取出4个任务来执行,
当有任务执行完成后,在判断队列中是否还有任务,如果还有任务,那么就继续执行新的任务
从此以来,反复的利用这4个线程,并不会创建额外的线程!
这是比较理想状态的的线程池,再来回顾一下构建ThreadPoolExecutor的参数
// 只能存放100个任务
LinkedBlockingQueue<Runnable> blockQueue = new LinkedBlockingQueue<>(100);
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(4, // 核心线程数
10, // 最大线程数
10, //
TimeUnit.SECONDS,
blockQueue,
new ThreadFactory()
@Override
public Thread newThread(Runnable r)
return new Thread(r);
);
@param corePoolSize(核心线程数) 4: 在线程池中创建4个线程
@param maxMumPoolSize(最大线程数) 10: 最多可以使用10个线程
@param keepAliveTime(线程等待时间):10
@param TimeUnit(TimeUnit.SECONDS): 线程等待单位
@param BlockQueue: 存放任务的队列
@param ThreadFactory:线程工厂: 用来创建线程
在上面图解中,我们使用到了核心线程数和 队列,知道了线程池运行的基础逻辑
那么先来看一眼上面图解对应的代码:
public class TPEClient2
private static final int COUNT = 10;
public static void main(String[] args)
// 只能存放100个任务
LinkedBlockingQueue<Runnable> blockQueue = new LinkedBlockingQueue<>(10);
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(
4, // 核心线程数
10, // 最大线程数
3, // 等待3秒
TimeUnit.SECONDS,
blockQueue,
new ThreadFactory()
@Override
public Thread newThread(Runnable r)
return new Thread(r);
);
for (int i = 0; i < COUNT; i++)
int finalI = i;
Runnable runnable = () ->
try
Thread.sleep(2000);
catch (Exception e)
e.printStackTrace();
finally
System.out.println("i:" + finalI + "\\t线程:" + Thread.currentThread().getName());
;
threadPoolExecutor.execute(runnable);
tips: 这里就不创建100个任务,创建10个任务也是同样的道理
可以看出,这里线程是每4个一起执行的,因为 Thread.sleep(2000);
并且通过Thread.currentThread().getName() 可以看出,只创建了4个线程, 线程对象都在重复利用
但是有一个奇怪的一点,为什么我设置了3秒等待时间,10个任务结束之后,为什么我等了3秒,他还是在运行状态呢?
在线程池执行过程中分别有5种状态,(在源码中可以搜索到)
- RUNNING：接受新任务并处理排队的任务。
- SHUTDOWN：不接受新任务，但处理排队的任务。
- STOP：不接受新任务，不处理排队的任务，中断正在进行的任务。 (隐含：此状态下，队列已为空)
- TIDYING：所有任务都已终止，workerCount 为零，转换到状态 TIDYING 的线程将运行 terminate() 钩子方法。
- TERMINATED：终止（）已完成。
如果当队列中没有没有任务,并且等待keepAliveTime后
需要通过 ThreadPoolExecutor#allowCoreThreadTimeOut(true); 将状态设置为 终止状态(TERMINATED)
这样一来,当任务执行完成之后,并且等待keepAliveTime后就会自动终止了
最大线程数和核心线程数以及失败策略
首先吧最大线程数和核心线程数放到一边, 先来看看失败策略
创建一个线程池
LinkedBlockingQueue<Runnable> blockQueue = new LinkedBlockingQueue<>(100); // 最多存放100个数据
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(4, // 核心线程数
10, // 最大线程数
10, // 失效时间
TimeUnit.SECONDS, // 失效时间单位
blockQueue, // 队列
new ThreadFactory() // 线程工厂
@Override
public Thread newThread(Runnable r)
return new Thread(r);
,
// 失败策略
new ThreadPoolExecutor.AbortPolicy()
);
在线程池中的最后一个参数,就是失败策略 即 ThreadPoolExecutor.AbortPolicy()
首先要考虑的当然是什么东西失败了? 为什么会失败?
在这个ThreadPoolExecutor中, 队列最多可存放100个任务
假设当前需要执行200个任务, 那么200个任务就放不到100的队列中, 这时候失败策略就起作用了!
如果一旦失败,最大线程数也会发挥作用
我们知道,
- 核心线程数为 4
- 最大线程数为10
那么非核心线程数 = 6
一旦当前需要执行的任务 > 队列最大容量,那么就会创建所有的线程来共同执行任务,也就是会创建10个线程(4个核心线程,6个非核心线程)来共同执行任务
即使是创建10个线程,也不会吧这200个任务全部执行完, 因为这200个任务没有完全添加到队列中
来看一眼代码:
public class TPEClient3
private static final int COUNT = 200;
public static void main(String[] args)
LinkedBlockingQueue<Runnable> blockQueue = new LinkedBlockingQueue<>(100);
ThreadPoolExecutor threadPoolExecutor =
new ThreadPoolExecutor(4, // 核心线程数
10, // 最大线程数
10, // 失效时间
TimeUnit.SECONDS, // 失效单位
blockQueue, // 队列
new ThreadFactory() // 线程工厂
@Override
public Thread newThread(Runnable r)
return new Thread(r);
,
// 失败策略
new ThreadPoolExecutor.AbortPolicy()
);
for (int i = 0; i < COUNT; i++)
int finalI = i;
Runnable runnable = new Runnable()
@Override
public void run()
try
Thread.sleep(2000);
catch (Exception e)
e.printStackTrace();
finally
System.out.println("i:" + finalI + "\\t线程:" + Thread.currentThread().getName());
;
threadPoolExecutor.execute(runnable);
常见的队列
- BlockingQueue() 先进先出队列
- SynchronousQueue() 线程安全队列
- PriorityBlockingQueue() 优先阻塞队列 无序队列,可以根据优先级排序
总结
其实ThreadPoolExecutor 很简单,
通过核心线程数来创建默认的线程, 如果任务过多,超出队列的个数,那么就会触发失败策略
触发失败策略的同时 就会创建最大线程数个线程, 唤醒所有的线程来执行任务!
原创不易,您的点赞就是对我最大的支持!
推荐文章:
javathreadpoolexecutor-3.java(代码片段)
javathreadpoolexecutor-1.java(代码片段)
javathreadpoolexecutor-2.java(代码片段)
javathreadpoolexecutor
ThreadPoolExecutor机制 一、概述 1、ThreadPoolExecutor作为java.util.concurrent包对外提供基础实现，以内部线程池的形式对外提供管理任务执行，线程调度，线程池管理等等服务； 2、Executors方法提供的线程服务，都是... 查看详情
Java 线程池执行器
】Java线程池执行器【英文标题】：JavaThreadPoolExecutor【发布时间】：2014-08-2701:40:05【问题描述】：我在理解JavaThreadPoolExecutor时遇到了很大的麻烦。例如，我想计算数字1-1000的平方：publicstaticvoidmain(String[]args)throwsInterruptedException,Ex... 查看详情
如何使用 Retrofit / OkHttp 更快地发出并发请求？
...T请求。我正在使用带有OkHttp的改造。目前，Retrofit与普通JavaThreadPoolExecutor和Htt 查看详情
论文写作中的分析框架与模型有啥区别
分析框架是构思是蓝图，而模型是具体解决问题的指导手册！大概这么个比喻模型是解决问题的，框架是为解决问题提出的方法方案！参考技术A一、战略分析工具介绍SWOT分析矩阵PESTEL大环境分析GE矩阵分析法区域战略分析平衡... 查看详情
静态分析与动态分析
静态分析关注系统的要素和组织（联系）；强调的是部分如何组成整体；着重于要素的局部联系。动态分析关于于系统的功能：前调的是要素与联系如何组成链条，完成事务的处理。 动态分析依靠静态分析支持；静态分析依... 查看详情
如何做好数据分析报告
大家都知道，我们分析数据的时候，还需要对数据分析做出报告的。做数据分析报告也是一个技术活，那么大家知道不知道数据分析报告需要做什么呢？我们在这篇文章中给大家介绍了数据分析报告的概况、数据分析报告的特点... 查看详情
数据分析数据分析方法：相关分析&群组分析
数据分析方法（六）：相关分析&群组分析1.相关分析方法当我们研究两种或者两种以上数据之间有什么关系的时候，就要用到相关分析。在解决问题的过程中，相关分析可以帮助我们扩大思路，将视野... 查看详情
常见用户行为分析模型：漏斗分析模型
用户行为分析之漏斗分析模型是企业实现精细化运营、进行用户行为分析的重要数据分析模型，其精细化程度影响着营销管理的成败，以及用户行为分析的精准度。现代营销观念认为：“营销管理重在过程，控制了过程就控制了... 查看详情
数据特征分析：1.分布分析(代码片段)
几个基础分析思路：分布分析、对比分析、统计分析、帕累托分析、正态性检测、相关性分析分布分析分布分析是研究数据的分布特征和分布类型，分定量数据、定性数据区分基本统计量。 importnumpyasnpimportpandasaspdimportma... 查看详情
词法分析
1.词法分析的功能 词法分析（英语：lexicalanalysis）是计算机科学中将字符序列转换为单词（Token）序列的过程。进行词法分析的程序或者函数叫作词法分析器（Lexicalanalyzer，简称Lexer），也叫扫描器（Scanner）。词法分析器一... 查看详情
项目分析：日志分析
日志分析目的：生产中会生成大量的系统日志、应用程序日志、安全日志等日志，通过对日志的分析可以了解数据库的负载、健康状况，可以分析客户的分布情况、客户的行为，甚至基于这些分析可以做出预测。 一般流程：... 查看详情
大数据分析师主要是做啥的？没有基础能学吗？
1、懂业务。从事数据分析工作的前提就会需要懂业务，即熟悉行业知识、公司业务及流程，最好有自己独到的见解，若脱离行业认知和公司业务背景，分析的结果只会是脱了线的风筝，没有太大的使用价值。2、懂管理。一方面... 查看详情
如何用sql分析电商用户行为数据（案例）
... 本文以“淘宝用户行为数据集”的分析全过程为例，展示数据分析的全过程——使用工具：MySQL，Excel，Navicat，PowerBI——分析类型：描述分析，诊断分析——分析方法：漏斗分析，用户路径分析，RFM用户价... 查看详情
数据分析的方法
对比分析，交叉分析，相关分析，回归分析，聚类分析等数据分析方法。数据分析方法论的重要性： 指导数据分析师进行一次完整性的数据分析，而只有在营销，管理等方法和理论指导下，结合实际业务情况，才能确保数据... 查看详情
竞品分析-邮箱产品竞品分析
概述竞品分析的背景竞品分析的主要目标竞品分析覆盖的产品范围2.竞品分析的主要结论3.重点邮箱竞品的详细分析 查看详情