为什么阿里巴巴禁止使用 Executors 创建线程池?

2024-01-01 17:18

本文主要是介绍为什么阿里巴巴禁止使用 Executors 创建线程池?,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

点击上方 Java旅途,选择 设为星标

优质文章,每日送达


阿里巴巴开发手册关于线程池有这样一条规定:

线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。

一、线程池原理

1.1 为什么使用线程池

池化技术的思想主要是为了减少在创建和销毁线程上所消耗的时间及系统资源的开销,解决资源不足的问题。

1.2 线程池是如何实现的

本文只讨论通过ThreadPoolExecutor创建的线程池。ThreadPoolExecutor的构造器代码如下,里面涉及到的主要参数有corePoolSizemaximumPoolSizekeepAliveTimeunitworkQueuethreadFactoryhandler

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {if (corePoolSize < 0 ||maximumPoolSize <= 0 ||maximumPoolSize < corePoolSize ||keepAliveTime < 0)throw new IllegalArgumentException();if (workQueue == null || threadFactory == null || handler == null)throw new NullPointerException();this.corePoolSize = corePoolSize;this.maximumPoolSize = maximumPoolSize;this.workQueue = workQueue;this.keepAliveTime = unit.toNanos(keepAliveTime);this.threadFactory = threadFactory;this.handler = handler;
}

这些参数的含义为:

  1. corePoolSize:核心线程数

  2. maximumPoolSize:最大线程数

  3. keepAliveTime:当线程池线程数量大于corePoolSize时候,多出来的空闲线程的存活时间

  4. unit:参数keepAliveTime的时间单位,TimeUnit枚举类有小时毫秒微秒纳秒7种可以选择。

  5. workQueue:线程池使用的缓冲队列,可供选择的有以下几种。

参数描述
ArrayBlockingQueue一个由数组结构组成的有界阻塞队列。
LinkedBlockingQueue一个由链表结构组成的有界阻塞队列。常用
SynchronousQueue一个不存储元素的阻塞队列,即直接提交给线程不保持它们。常用
PriorityBlockingQueue一个支持优先级排序的无界阻塞队列。
DelayQueue一个使用优先级队列实现的无界阻塞队列,只有在延迟期满时才能从中提取元素。
LinkedTransferQueue一个由链表结构组成的无界阻塞队列。与SynchronousQueue类似,还含有非阻塞方法。
LinkedBlockingDeque一个由链表结构组成的双向阻塞队列。

  1. threadFactory:线程工厂,主要用来创建线程

  2. handler:拒绝策略,拒绝处理任务时的策略,可供选择的有以下几种。

参数描述
AbortPolicy拒绝并抛出异常。默认的
CallerRunsPolicy重试提交当前的任务,即再次调用运行该任务的execute()方法。
DiscardOldestPolicy抛弃队列头部(最旧)的一个任务,并执行当前任务。
DiscardPolicy抛弃当前任务。

1.3 线程池执行规则

  1. 执行任务时,如果线程池中的线程数量小于corePoolSize,即使池中有空闲的线程数,也会创建新的线程来执行任务。

  2. 线程池中的线程数量等于corePoolSize,并且缓冲队列未满时,则任务被放入缓冲队列中

  3. 线程池中的线程数量大于等于corePoolSize,并且缓冲队列已满,同时线程数量小于maximumPoolSize,则会创建新的线程来执行任务。

  4. 线程池中的线程数量已满时,则执行拒绝策略处理这些任务。

二、阿里巴巴手册为什么禁止用Exectors创建线程池

Exectors提供了几种工厂方法用来创建线程池,其中newCachedThreadPool()newFixedThreadPool()newSingleThreadExecutor()三种方法最终是通过实现类ThreadPoolExecutor来创建的。接下来一起看看这三种方法到底有什么问题,为什么阿里巴巴会禁止使用Exectors来创建线程池!

2.1 FixedThreadPool 解析
public static ExecutorService newFixedThreadPool(int nThreads) {return new ThreadPoolExecutor(nThreads, nThreads,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());
}

具体参数如下:

  • corePoolSize:nThreads

  • maximumPoolSize:nThreads

  • keepAliveTime:0L

  • unit:毫秒

  • workQueue:LinkedBlockingQueue,一个由链表结构组成的有界阻塞队列,并且使用了最大长度的队列。

public LinkedBlockingQueue() {this(Integer.MAX_VALUE);
}

这种方式创建的线程池由于核心线程数和最大线程数相同,所以线程池中线程的数量是固定的,并且没有限制队列大小,所以多余的任务均会被放到队列中排队,在资源有限时容易出现内存溢出。

2.2 SingleThreadPool 解析
public static ExecutorService newSingleThreadExecutor() {return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()));
}

具体参数如下:

  • corePoolSize:1

  • maximumPoolSize:1

  • keepAliveTime:0L

  • unit:毫秒

  • workQueue:LinkedBlockingQueue,一个由链表结构组成的有界阻塞队列,并且使用了最大长度的队列。

public LinkedBlockingQueue() {this(Integer.MAX_VALUE);
}

这种方式创建的线程池是单线程线程池,核心线程数和最大线程数都是1,多余的任务都将会被放到缓冲队列中去,所以在资源优先的情况下容易出现内存溢出。

2.3 CachedThreadPool 解析
public static ExecutorService newCachedThreadPool() {return new ThreadPoolExecutor(0, Integer.MAX_VALUE,60L, TimeUnit.SECONDS,new SynchronousQueue<Runnable>());
}

具体参数如下:

  • corePoolSize:0

  • maximumPoolSize:Integer.MAX_VALUE

  • keepAliveTime:60L

  • unit:秒

  • workQueue:SynchronousQueue,一个不存储元素的阻塞队列,即直接提交给线程不保持它们。

这种方式创建的线程池核心线程数为0,并且使用了SynchronousQueue队列,这个队列不存储元素,也就是任务直接会直接通过创建非核心线程来执行,核心线程数为Integer.MAX_VALUE,可以任务能无限创建队列,因此在资源优先的情况下容易发生内存溢出。

2.4 测试OOM异常

既然我们已经分析了三种创建线程池可能会出现OOM异常,那么我们测试一下到底会不会发生OOM呢?这里我将选择newSingleThreadExecutor()来进行测试,其他两个方法测试流程也是一样的。为了尽快出现OOM,我们将JVM的内存调小一点。

  • -Xmx5M :最大内存值5M

  • -Xms5M:初始内存大小5M

测试代码

public static void main(String[] args) {ExecutorService service = Executors.newSingleThreadExecutor();while (true){service.execute(() -> {System.out.println("我是一个任务,运行时间:"+System.currentTimeMillis()+"\n");});}
}

测试结果

任务跑了1分钟左右,就发生了OOM异常

三、总结

阿里巴巴开发手册为什么禁止使用 Executors 去创建线程池,原因就是 newFixedThreadPool()newSingleThreadExecutor()两个方法允许请求的最大队列长度是 Integer.MAX_VALUE ,可能会出现任务堆积,出现OOM。newCachedThreadPool()允许创建的线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,导致发生OOM。它建议使用ThreadPoolExecutor方式去创建线程池,通过上面的分析我们也知道了其实Executors 三种创建线程池的方式最终就是通过ThreadPoolExecutor来创建的,只不过有些参数我们无法控制,如果通过ThreadPoolExecutor的构造器去创建,我们就可以根据实际需求控制线程池需要的任何参数,避免发生OOM异常。

推荐阅读
最近聊了一些高P,我慌了
十年老码农,现场教你写简历
为了让你看技术文章,我们操碎了心。。。
编程·思维·职场
欢迎扫码关注

这篇关于为什么阿里巴巴禁止使用 Executors 创建线程池?的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/559968

相关文章

如何使用CSS3实现波浪式图片墙

《如何使用CSS3实现波浪式图片墙》:本文主要介绍了如何使用CSS3的transform属性和动画技巧实现波浪式图片墙,通过设置图片的垂直偏移量,并使用动画使其周期性地改变位置,可以创建出动态且具有波浪效果的图片墙,同时,还强调了响应式设计的重要性,以确保图片墙在不同设备上都能良好显示,详细内容请阅读本文,希望能对你有所帮助...

Rust中的注释使用解读

《Rust中的注释使用解读》本文介绍了Rust中的行注释、块注释和文档注释的使用方法,通过示例展示了如何在实际代码中应用这些注释,以提高代码的可读性和可维护性... 目录Rust 中的注释使用指南1. 行注释示例:行注释2. 块注释示例:块注释3. 文档注释示例:文档注释4. 综合示例总结Rust 中的注释

Linux使用cut进行文本提取的操作方法

《Linux使用cut进行文本提取的操作方法》Linux中的cut命令是一个命令行实用程序,用于从文件或标准输入中提取文本行的部分,本文给大家介绍了Linux使用cut进行文本提取的操作方法,文中有详... 目录简介基础语法常用选项范围选择示例用法-f:字段选择-d:分隔符-c:字符选择-b:字节选择--c

禁止HTML页面滚动的操作方法

《禁止HTML页面滚动的操作方法》:本文主要介绍了三种禁止HTML页面滚动的方法:通过CSS的overflow属性、使用JavaScript的滚动事件监听器以及使用CSS的position:fixed属性,每种方法都有其适用场景和优缺点,详细内容请阅读本文,希望能对你有所帮助... 在前端开发中,禁止htm

使用Go语言开发一个命令行文件管理工具

《使用Go语言开发一个命令行文件管理工具》这篇文章主要为大家详细介绍了如何使用Go语言开发一款命令行文件管理工具,支持批量重命名,删除,创建,移动文件,需要的小伙伴可以了解下... 目录一、工具功能一览二、核心代码解析1. 主程序结构2. 批量重命名3. 批量删除4. 创建文件/目录5. 批量移动三、如何安

springboot的调度服务与异步服务使用详解

《springboot的调度服务与异步服务使用详解》本文主要介绍了Java的ScheduledExecutorService接口和SpringBoot中如何使用调度线程池,包括核心参数、创建方式、自定... 目录1.调度服务1.1.JDK之ScheduledExecutorService1.2.spring

Java使用Tesseract-OCR实战教程

《Java使用Tesseract-OCR实战教程》本文介绍了如何在Java中使用Tesseract-OCR进行文本提取,包括Tesseract-OCR的安装、中文训练库的配置、依赖库的引入以及具体的代... 目录Java使用Tesseract-OCRTesseract-OCR安装配置中文训练库引入依赖代码实

Java中对象的创建和销毁过程详析

《Java中对象的创建和销毁过程详析》:本文主要介绍Java中对象的创建和销毁过程,对象的创建过程包括类加载检查、内存分配、初始化零值内存、设置对象头和执行init方法,对象的销毁过程由垃圾回收机... 目录前言对象的创建过程1. 类加载检查2China编程. 分配内存3. 初始化零值4. 设置对象头5. 执行

Python使用Pandas对比两列数据取最大值的五种方法

《Python使用Pandas对比两列数据取最大值的五种方法》本文主要介绍使用Pandas对比两列数据取最大值的五种方法,包括使用max方法、apply方法结合lambda函数、函数、clip方法、w... 目录引言一、使用max方法二、使用apply方法结合lambda函数三、使用np.maximum函数

Qt 中集成mqtt协议的使用方法

《Qt中集成mqtt协议的使用方法》文章介绍了如何在工程中引入qmqtt库,并通过声明一个单例类来暴露订阅到的主题数据,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录一,引入qmqtt 库二,使用一,引入qmqtt 库我是将整个头文件/源文件都添加到了工程中进行编译,这样 跨平台