工作中禁止使用Executors快捷创建线程池原理详解
更新时间：2022年11月02日 08:58:58 作者：长安不及十里
这篇文章主要为大家介绍了工作中禁止使用Executors快捷创建线程池原理详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
问题？
在很多公司（如阿里、华为等）的编程规范中，非常明确地禁止使用Executors快捷创建线程池，为什么呢？这里从源码讲起，介绍使用Executors工厂方法快捷创建线程池将会面临的潜在问题。
1.1 newFixedThreadPool的潜在问题
基本使用
// 线程池
ExecutorService singleThreadExecutor = Executors.newFixedThreadPool(2);
// 批量添加线程
for (int i = 0; i < 7; i++) {
singleThreadExecutor.execute(new TargetTask());
// singleThreadExecutor.submit(new TargetTask());
}
Thread.sleep(1000);
// 线程池销毁
singleThreadExecutor.shutdown();;
查看源码
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}
/**
* Creates a {@code LinkedBlockingQueue} with a capacity of
* {@link Integer#MAX_VALUE}.
*/
public LinkedBlockingQueue() {
this(Integer.MAX_VALUE);
}
我们可以看出：
- corePoolSize(核心线程数)=maximumPoolSize（最大线程数）。
- LinkedBlockingQueue是一个无界队列，如果提交的任务过快会造成任务大量的的堆积，消耗完服务器资源。
- 如果队列很大，很有可能导致JVM出现OOM（Out Of Memory）异常，即内存资源耗尽。
1.2 newSingleThreadExecutor的潜在问题？
基本使用
// 线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
// 批量添加线程
for (int i = 0; i < 5; i++) {
singleThreadExecutor.execute(new TargetTask());
// singleThreadExecutor.submit(new TargetTask());
}
Thread.sleep(1000);
// 线程池销毁
singleThreadExecutor.shutdown();;
查看源码
public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()));
}
/**
* Creates a {@code LinkedBlockingQueue} with a capacity of
* {@link Integer#MAX_VALUE}.
*/
public LinkedBlockingQueue() {
this(Integer.MAX_VALUE);
}
尝试修改核心线程数
package ExecutorDemo.newSingleThreadExecutor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
/**
* @description:
* @author: shu
* @createDate: 2022/11/1 10:45
* @version: 1.0
*/
public class UpdateSingleThreadExecutor {
public static void main(String[] args) {
//创建一个固定大小的线程池
ExecutorService fixedExecutorService =
Executors.newFixedThreadPool(1);
ThreadPoolExecutor threadPoolExecutor =
(ThreadPoolExecutor) fixedExecutorService;
System.out.println(threadPoolExecutor.getMaximumPoolSize());
//设置核心线程数
threadPoolExecutor.setCorePoolSize(8);
//创建一个单线程化的线程池
ExecutorService singleExecutorService =
Executors.newSingleThreadExecutor();
//转换成普通线程池，会抛出运行时异常 java.lang.ClassCastException
((ThreadPoolExecutor) singleExecutorService).setCorePoolSize(8);
}
}
我们可以看出：
- 单例存在，我们无法去修改核心线程数，否则会造成异常处理。
- corePoolSize(核心线程数)=maximumPoolSize（最大线程数）=1 。
- LinkedBlockingQueue是一个无界队列，如果提交的任务过快会造成任务大量的的堆积，消耗完服务器资源。
- 如果队列很大，很有可能导致JVM出现OOM（Out Of Memory）异常，即内存资源耗尽。
1.3 newCachedThreadPool的潜在问题
基本使用
// 线程池
ExecutorService singleThreadExecutor = Executors.newCachedThreadPool();
// 批量添加线程
for (int i = 0; i < 7; i++) {
singleThreadExecutor.execute(new TargetTask());
// singleThreadExecutor.submit(new TargetTask());
}
Thread.sleep(1000);
// 线程池销毁
singleThreadExecutor.shutdown();;
源码分析
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}
* Creates a {@code SynchronousQueue} with nonfair access policy.
*/
public SynchronousQueue() {
this(false);
}
- ThreadPoolExecutor标准构造器创建一个核心线程数为0、最大线程数不设限制的线程池
- 理论上可缓存线程池可以拥有无数个工作线程，即线程数量几乎无限制。
- 可缓存线程池的workQueue为SynchronousQueue同步队列，这个队列类似于一个接力棒，入队出队必须同时传递，正因为可缓存线程池可以无限制地创建线程，不会有任务等待，所以才使用SynchronousQueue。
- 但是，maximumPoolSize的值为Integer.MAX_VALUE（非常大），可以认为可以无限创建线程，如果任务提交较多，就会造成大量的线程被启动，很有可能造成OOM异常，甚至导致CPU线程资源耗尽。
1.4 newScheduledThreadPool 潜在问题
基本使用
// 线程池
ScheduledExecutorService service = Executors.newScheduledThreadPool(2);
// 批量添加线程
for (int i = 0; i < 7; i++) {
ScheduledFuture<?> future = service.scheduleWithFixedDelay(new TargetTask(), 0, 500, TimeUnit.MILLISECONDS);
}
Thread.sleep(1000);
// 线程池销毁
service.shutdown();;
源码分析
public ScheduledThreadPoolExecutor(int corePoolSize) {
super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
new DelayedWorkQueue());
}
static class DelayedWorkQueue extends AbstractQueue<Runnable>
implements BlockingQueue<Runnable> {
private static final int INITIAL_CAPACITY = 16;
private RunnableScheduledFuture<?>[] queue =
new RunnableScheduledFuture<?>[INITIAL_CAPACITY];
private final ReentrantLock lock = new ReentrantLock();
private int size = 0;
private Thread leader = null;
private final Condition available = lock.newCondition();
}
maximumPoolSize为Integer.MAX_VALUE，表示线程数不设上限，其workQueue为一个DelayedWorkQueue实例，这是一个按到期时间升序排序的阻塞队列。
1.5 总结
虽然Executors工厂类提供了构造线程池的便捷方法，但是对于服务器程序而言，大家应该杜绝使用这些便捷方法，而是直接使用线程池ThreadPoolExecutor的构造器，从而有效避免由于使用无界队列可能导致的内存资源耗尽，或者由于对线程
以上就是工作中禁止使用Executors快捷创建线程池原理详解的详细内容，更多关于禁止用Executors创建线程池的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要介绍了浅谈Spring事务传播行为实战，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-09-09
这篇文章主要介绍了springboot中通过cors协议解决跨域问题,cors是一个w3c标准，它允许浏览器（目前ie8以下还不能被支持）像我们不同源的服务器发出xmlHttpRequest请求，我们可以继续使用ajax进行请求访问。具体内容详情大家跟随脚本之家小编一起学习吧2018-05-05
这篇文章主要介绍了java IO 文件操作方法总结的相关资料,需要的朋友可以参考下2017-04-04
这篇文章主要介绍了简单了解JAVA变量类型及代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-02-02
一个框架的运行流程从最简单的一个helloworld来看其源码就能了解到框架的原理是什么,这篇文章主要给大家介绍了关于如何一步到位部署运行MyBatis3源码的相关资料,需要的朋友可以参考下2022-06-06
这篇文章主要为大家介绍了java LeetCode题解KMP算法示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-10-10
这篇文章主要介绍了Idea如何集成Git&添加项目到git仓库,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
KMP算法是一种改进的字符串匹配算法，核心是利用之前的匹配失败时留下的信息，选择最长匹配长度直接滑动，从而减少匹配次数。本文主要介绍了KMP算法的原理与实现，需要的可以参考一下2022-12-12
本文主要介绍了Java中synchronized的4个优化技巧，synchronized在JDK 1.5 时性能是比较低的，然而在后续的版本中经过各种优化迭代，它的性能也得到了前所未有的提升，下文更多相关资料需要的小伙伴可以参考一下2022-05-05
MyBatis是支持定制化SQL、存储过程以及高级映射的优秀的持久层框架，本文重点介绍MyBatis 核心配置文件及映射文件,需要的朋友可以参考下2023-01-01
最新评论