为什么阿里巴巴禁止使用 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

相关文章

Linux换行符的使用方法详解

《Linux换行符的使用方法详解》本文介绍了Linux中常用的换行符LF及其在文件中的表示,展示了如何使用sed命令替换换行符,并列举了与换行符处理相关的Linux命令,通过代码讲解的非常详细,需要的... 目录简介检测文件中的换行符使用 cat -A 查看换行符使用 od -c 检查字符换行符格式转换将

使用Jackson进行JSON生成与解析的新手指南

《使用Jackson进行JSON生成与解析的新手指南》这篇文章主要为大家详细介绍了如何使用Jackson进行JSON生成与解析处理,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 核心依赖2. 基础用法2.1 对象转 jsON(序列化)2.2 JSON 转对象(反序列化)3.

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》:本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J

使用C#代码在PDF文档中添加、删除和替换图片

《使用C#代码在PDF文档中添加、删除和替换图片》在当今数字化文档处理场景中,动态操作PDF文档中的图像已成为企业级应用开发的核心需求之一,本文将介绍如何在.NET平台使用C#代码在PDF文档中添加、... 目录引言用C#添加图片到PDF文档用C#删除PDF文档中的图片用C#替换PDF文档中的图片引言在当

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

C#使用SQLite进行大数据量高效处理的代码示例

《C#使用SQLite进行大数据量高效处理的代码示例》在软件开发中,高效处理大数据量是一个常见且具有挑战性的任务,SQLite因其零配置、嵌入式、跨平台的特性,成为许多开发者的首选数据库,本文将深入探... 目录前言准备工作数据实体核心技术批量插入:从乌龟到猎豹的蜕变分页查询:加载百万数据异步处理:拒绝界面

Android中Dialog的使用详解

《Android中Dialog的使用详解》Dialog(对话框)是Android中常用的UI组件,用于临时显示重要信息或获取用户输入,本文给大家介绍Android中Dialog的使用,感兴趣的朋友一起... 目录android中Dialog的使用详解1. 基本Dialog类型1.1 AlertDialog(

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定