为什么阿里巴巴禁止使用 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线程同步/互斥过程详解》文章讲解多线程并发访问导致竞态条件,需通过互斥锁、原子操作和条件变量实现线程安全与同步,分析死锁条件及避免方法,并介绍RAII封装技术提升资源管理效率... 目录01. 资源共享问题1.1 多线程并发访问1.2 临界区与临界资源1.3 锁的引入02. 多线程案例2.1 为

Java使用Thumbnailator库实现图片处理与压缩功能

《Java使用Thumbnailator库实现图片处理与压缩功能》Thumbnailator是高性能Java图像处理库,支持缩放、旋转、水印添加、裁剪及格式转换,提供易用API和性能优化,适合Web应... 目录1. 图片处理库Thumbnailator介绍2. 基本和指定大小图片缩放功能2.1 图片缩放的

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

MySQL中EXISTS与IN用法使用与对比分析

《MySQL中EXISTS与IN用法使用与对比分析》在MySQL中,EXISTS和IN都用于子查询中根据另一个查询的结果来过滤主查询的记录,本文将基于工作原理、效率和应用场景进行全面对比... 目录一、基本用法详解1. IN 运算符2. EXISTS 运算符二、EXISTS 与 IN 的选择策略三、性能对比

使用Python构建智能BAT文件生成器的完美解决方案

《使用Python构建智能BAT文件生成器的完美解决方案》这篇文章主要为大家详细介绍了如何使用wxPython构建一个智能的BAT文件生成器,它不仅能够为Python脚本生成启动脚本,还提供了完整的文... 目录引言运行效果图项目背景与需求分析核心需求技术选型核心功能实现1. 数据库设计2. 界面布局设计3

使用IDEA部署Docker应用指南分享

《使用IDEA部署Docker应用指南分享》本文介绍了使用IDEA部署Docker应用的四步流程:创建Dockerfile、配置IDEADocker连接、设置运行调试环境、构建运行镜像,并强调需准备本... 目录一、创建 dockerfile 配置文件二、配置 IDEA 的 Docker 连接三、配置 Do

Android Paging 分页加载库使用实践

《AndroidPaging分页加载库使用实践》AndroidPaging库是Jetpack组件的一部分,它提供了一套完整的解决方案来处理大型数据集的分页加载,本文将深入探讨Paging库... 目录前言一、Paging 库概述二、Paging 3 核心组件1. PagingSource2. Pager3.

python使用try函数详解

《python使用try函数详解》Pythontry语句用于异常处理,支持捕获特定/多种异常、else/final子句确保资源释放,结合with语句自动清理,可自定义异常及嵌套结构,灵活应对错误场景... 目录try 函数的基本语法捕获特定异常捕获多个异常使用 else 子句使用 finally 子句捕获所

C++11右值引用与Lambda表达式的使用

《C++11右值引用与Lambda表达式的使用》C++11引入右值引用,实现移动语义提升性能,支持资源转移与完美转发;同时引入Lambda表达式,简化匿名函数定义,通过捕获列表和参数列表灵活处理变量... 目录C++11新特性右值引用和移动语义左值 / 右值常见的左值和右值移动语义移动构造函数移动复制运算符

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali