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

相关文章

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》:本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色(红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解

Windows下C++使用SQLitede的操作过程

《Windows下C++使用SQLitede的操作过程》本文介绍了Windows下C++使用SQLite的安装配置、CppSQLite库封装优势、核心功能(如数据库连接、事务管理)、跨平台支持及性能优... 目录Windows下C++使用SQLite1、安装2、代码示例CppSQLite:C++轻松操作SQ

Python常用命令提示符使用方法详解

《Python常用命令提示符使用方法详解》在学习python的过程中,我们需要用到命令提示符(CMD)进行环境的配置,:本文主要介绍Python常用命令提示符使用方法的相关资料,文中通过代码介绍的... 目录一、python环境基础命令【Windows】1、检查Python是否安装2、 查看Python的安

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象(如模块、类、函数等)的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(

Linux脚本(shell)的使用方式

《Linux脚本(shell)的使用方式》:本文主要介绍Linux脚本(shell)的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述语法详解数学运算表达式Shell变量变量分类环境变量Shell内部变量自定义变量:定义、赋值自定义变量:引用、修改、删

Java使用HttpClient实现图片下载与本地保存功能

《Java使用HttpClient实现图片下载与本地保存功能》在当今数字化时代,网络资源的获取与处理已成为软件开发中的常见需求,其中,图片作为网络上最常见的资源之一,其下载与保存功能在许多应用场景中都... 目录引言一、Apache HttpClient简介二、技术栈与环境准备三、实现图片下载与保存功能1.

Python中使用uv创建环境及原理举例详解

《Python中使用uv创建环境及原理举例详解》uv是Astral团队开发的高性能Python工具,整合包管理、虚拟环境、Python版本控制等功能,:本文主要介绍Python中使用uv创建环境及... 目录一、uv工具简介核心特点:二、安装uv1. 通过pip安装2. 通过脚本安装验证安装:配置镜像源(可

LiteFlow轻量级工作流引擎使用示例详解

《LiteFlow轻量级工作流引擎使用示例详解》:本文主要介绍LiteFlow是一个灵活、简洁且轻量的工作流引擎,适合用于中小型项目和微服务架构中的流程编排,本文给大家介绍LiteFlow轻量级工... 目录1. LiteFlow 主要特点2. 工作流定义方式3. LiteFlow 流程示例4. LiteF

使用Python开发一个现代化屏幕取色器

《使用Python开发一个现代化屏幕取色器》在UI设计、网页开发等场景中,颜色拾取是高频需求,:本文主要介绍如何使用Python开发一个现代化屏幕取色器,有需要的小伙伴可以参考一下... 目录一、项目概述二、核心功能解析2.1 实时颜色追踪2.2 智能颜色显示三、效果展示四、实现步骤详解4.1 环境配置4.