彻底搞懂 Java 线程池,干啥都不再发憷
作为 Java 程序员,无论是技术面试、项目研发或者是学习框架源码,不彻底掌握 Java 多线程的知识,做不到心中有数,干啥都没底气,尤其是技术深究时往往略显发憷。
1
回顾:创建线程的几种方式?
在 Java 的世界里,大家最熟悉的线程的创建方式,莫过于 Java 提供的 Thread 类和 Runnable 接口。
核心知识点(一):继承 Thread 类 VS 实现 Runnable 接口的区别?
从 JDK1.5 开始,Java 提供了 Callable 接口,提供另一种创建线程的方式。
核心知识点(二):实现 Callable 接口创建线程,有啥独特?
使用实现 Callable 接口的方式创建的线程,相对于继承 Thread 类和实现 Runnable 接口来创建线程的方式而言,可以获取到线程执行的返回值、以及是否执行完成等信息。
2
思考:无限制的创建线程,会带来什么问题?
在项目开发中,为了提高系统的吞吐量和性能,很多同学都会随手写出如下最简单的线程创建代码。
new Thread(new Runnable() {
@Override
public void run() {
System.out.println("我是一个孤独的线程");
// do something
}
}).start();
有的同学,会采用 Lambda 表达式,写出如下稍显高 B 格的代码。
new Thread(() -> System.out.println("我是一个孤独的线程")).start();
在简单的应用中,上面的代码没有太大的问题。但是如果在业务量较大,可能要开启很多线程来处理,而当线程数量过大时,反而会耗尽 CPU 和内存资源,如果处理不当,可能会导致 Out of Memory 异常。
写段代码,简单示意一下内存溢出。
// 待通知的消息
List<String> notifyMsgList = new ArrayList<String>(10000);
for (int i = 0; i < 10000; i++) {
notifyMsgList.add("发工资啦" + i);
}
// 通知用户
for (String msg : notifyMsgList) {
// 多线程发送
new Thread(new Runnable() {
@Override
public void run() {
System.out.println("通知:" + msg);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
程序跑起来,大概率会出现内存溢出的异常。
java.lang.OutOfMemoryError: unable to create new native thread
贴一效果图,真的不诳你。
这么看,线(劲)程(酒)虽好,不能贪多(杯)呀。在生产环境中,线程的数量必须要进行控制,不然盲目的创建大量线程会对系统性能造成伤害,甚至会导致内存溢出,拖垮应用。
那该怎么办?这就很有必要引入线程池啦。
3
Executor 框架入门:别造轮子啦,JDK 都给你提供啦!
线程池的基本功能就是进行线程的复用,当系统接受一个提交的任务,需要一个线程时,并不立即去创建线程,而是先去线程池查找是否有空余的线程,若有,则直接使用线程池中的线程进行工作,若没有,再去创建新的线程。待任务完成后,也销毁线程,而是将线程放入线程池的空闲对列,等待下次使用。
在线程频繁调度的场景中,JDK1.5 以前,攻城狮必须手动打造线程池,来节约系统开销;而从 JDK1.5 开始,Java 提供了一个 Excutors 工厂类来生产线程池,可以帮助攻城狮有效的进行线程控制。
核心知识点(一):Excutors 工厂类的主要方法有哪些?
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newSingleThreadExecutor()
public static ExecutorService newCachedThreadPool()
public static ScheduledExecutorService newSingleThreadScheduledExecutor()
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
上面列举的方法中,分别返回了不同工作特性的线程池,下面简单介绍一下每个方法。
1. newFixedThreadPool(int nThreads)
用途:创建一个可重用的、具有固定线程数的线程池。
备注:该线程池中的线程数量始终不变,当有一个新的任务提交时,线程中若有空闲线程,则立即执行,若没有则空闲线程,新的任务会被暂存在一个任务队列中,待有线程空闲时,便处理在任务队列中的任务。
2. newSingleThreadExecutor()
用途:创建一个只有一个线程的线程池,相当于 newFixedThreadPool(int nThreads) 方法调用时传入的参数为 1。
备注:该线程池中的线程数量为 1。
3. newCachedThreadPool()
用途:创建一个具有缓存功能的线程池,系统根据需要创建线程,这些线程会被缓存在线程池中。
备注:该线程池中的线程数量不确定,但若有空闲线程可以复用,则会优先使用可复用的线程,若所有线程均在工作,又有新的任务提交,则会创建新的线程处理任务。所有线程在当前任务执行完毕后,将返回线程池进行复用。
4. newSingleThreadScheduledExecutor()
用途:创建只有一条线程的线程池,它可以在指定延迟后执行线程任务。
备注:线程池大小为 1,并且可以在固定的延时之后执行或者周期性执行某个任务。
5. newScheduledThreadPool(int corePoolSize)
用途:创建具有指定线程数的线程池,它可以在指定延迟后执行线程任务。
备注:corePoolSize 指池中所保存的线程数,即使线程是空闲的,也被保存在线程池内。
上面列举了 Excutors 类中的一些方法,仔细去看,会发现前三个返回一个 ExcutorService 对象,而后两个方法返回 ScheduledExecutorService 对象。
核心知识点(二):ExcutorService 与 ScheduledExecutorService 啥区别?
走进源码,从方法定义上着重分析一下区别。
首先截取 ExcutorService 的部分方法定义,重点关注 submit 重载的方法。
上面截图释义:
- 标注 1 的方法释义:将一个 Callable 对象提交给指定的线程池,Future 代表 Callable 对象里 call 方法的返回值。
- 标注 2 的方法释义:将一个 Runnable 对象提交给指定的线程池,result 显示指定线程执行结束后的返回值,所以 Future 对象将在 run 方法执行结束后返回 result。
- 标注 3 的方法释义:将一个 Runnable 对象提交给指定的线程池,其中 Future 对象是 Runnable 任务的返回值(但是 run方法没有返回值,不过可以借用 Future 的方法来获取任务执行的状态)。
了解完 ExcutorService,那么来看看 ScheduledExecutorService 的方法定义。
上面截图释义:
- 标注 1 的方法与标注 2 的方法,主要功能是在指定 delay 延迟后执行任务。区别是入参一个接受 Runnable 任务,一个接受 Callable 任务。
- 标注 3 的方法,功能是在 initialDelay 后开始执行 command,而且以固定频率重复执行,依次是 initialDelay + period、initialDelay + 2*period ...。
- 标注 4 的方法,功能是在 initialDelay 后开始执行 command,随后在每一次执行终止和下一次执行开始之前都存在给定的延迟,如果任务执行时遇到异常,就会取消后续执行。
了解完方法定义,区别就很简单了:
- ExcutorService 代表一个线程池,可以执行 Runnable 对象或者 Callable 对象所代表的线程;
- ScheduledExecutorService 是 ExcutorService 的子类,可以在指定延迟后执行线程任务或者周期性的执行某个任务。
4
Executor 框架使用:说的再多,都不如写一行代码!
还是以开篇发工资的场景为例,若借助线程池来实现,假设允许开启 10 个线程来进行发工资(理解成 10 个人同时干活就行),代码改造如下。
// 待通知的消息
List<String> notifyMsgList = new ArrayList<String>(10000);
for (int i = 0; i < 10000; i++) {
notifyMsgList.add("发工资啦" + i);
}
// 1. 调用 Excutors 类的静态工厂方法创建一个 ExcutorService 对象(线程池);
ExecutorService executorService = Executors.newFixedThreadPool(100);
// 通知用户
for (String msg : notifyMsgList) {
// 2. 创建 Runnable 实现类或者 Callable 实现类的实例,作为线程执行任务。
// 3. 调用 ExcutorService 对象的 submit 方法来提交 Runnable 实例或 Callable 实例。
executorService.submit(new Runnable() {
@Override
public void run() {
System.out.println("通知:" + msg);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
//4. 调用 ExcutorService 对象的 shutdown 方法来关闭线程池。
executorService.shutdown();
程序跑起来,很清晰的能看出有 10 个线程同时在处理任务。
好了,到这简单总结一下,使用线程池来编程时的步骤(仔细看代码注释就行啦)。
- 调用 Excutors 类的静态工厂方法创建一个 ExcutorService 对象(线程池);
- 创建 Runnable 实现类或者 Callable 实现类的实例,作为线程执行任务;
- 调用 ExcutorService 对象的 submit 方法来提交 Runnable 实例或 Callable 实例;
- 调用 ExcutorService 对象的 shutdown 方法来关闭线程池。
既然提到了关闭线程池的 shutdown 方法,那再抛一知识点:shutdown 与 shutdownNow 的区别是啥?
写段程序很容易发现结论,还是借助上面发工资通知的代码,把通知的消息改为 11,把线程数改为 10。
首先调用 shutdown 方法关闭线程池,代码如下。
// 待通知的消息
List<String> notifyMsgList = new ArrayList<String>(10000);
for (int i = 0; i < 11; i++) {
notifyMsgList.add("发工资啦" + i);
}
// 1. 调用 Excutors 类的静态工厂方法创建一个 ExcutorService 对象(线程池);
ExecutorService executorService = Executors.newFixedThreadPool(10);
// 通知用户
for (String msg : notifyMsgList) {
// 2. 创建 Runnable 实现类或者 Callable 实现类的实例,作为线程执行任务。
// 3. 调用 ExcutorService 对象的 submit 方法来提交 Runnable 实例或 Callable 实例。
executorService.submit(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+ "-->通知:" + msg);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
//4. 调用 ExcutorService 对象的 shutdown 方法来关闭线程池。
executorService.shutdown();
输出截图(执行完了,才优雅的终止):
接着改造代码,调用 shutdownNow 方法来关闭线程池,代码如下。
//4. 调用 ExcutorService 对象的 shutdownNow 方法来关闭线程池。
List<Runnable> tasks = executorService.shutdownNow();
System.out.println(tasks);
输出截图:
结论:
- 当程序调用 shutdown 方法时,线程池将不再接受新的任务,但会将以前所有已提交的任务执行完成(优雅停服的背后支撑者);
- 当调用 shutdownNow 方法来关闭线程池时,该方法会试图停止所有正在执行的活动任务,暂停处理正在等待的任务,并返回等待执行的任务列表。
5
寄语写最后
本次,本次主要回顾了创建线程的方式,并对 JDK 对任务执行框架 Excutor 进行初步讲解,后续会带你一起走进这个框架背后隐藏的 ThreadPoolExecutor 类,一起去探寻线程池背后的奥秘。
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- 12岁小读者使用Python暴力破解Wi-Fi密码
- 深度学习入门Fast.ai 2.0上线!自带中文字幕,所有笔记、资源全部免费!
- 七夕节脱单“神助攻”!AI教你写情话
- Python初学者请注意!别这样直接运行python命令,否则电脑等于“裸奔”
- 一篇文章构建你的 Node.js 知识体系
- MySQL:The CHAR and VARCHAR Types
- 更新一个10年有效期的 Kubernetes 证书
- 哇,ElasticSearch多字段权重排序居然可以这么玩
- Python 自动化,Appium 凭什么使用 UiAutomator2?
- 我用几行 Python 自动化脚本完美解决掉了小姐姐的微信焦虑感
- 【设计模式】692- TypeScript 设计模式之发布-订阅模式
- 强网杯-upload
- 基于暗通道去雾算法
- 全套 | 人脸检测 & 人脸关键点检测 & 人脸卡通化
- 使用Jenkins Dashboard插件可视化部署