不要使用Executors直接创建线程池,非常不安全的,阿里代码规范明确规定不能这么创建线程池的,该如何正确创建安全可靠的线程池,线程池辅助创建工具类

本文主要是介绍不要使用Executors直接创建线程池,非常不安全的,阿里代码规范明确规定不能这么创建线程池的,该如何正确创建安全可靠的线程池,线程池辅助创建工具类,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本人新人,技术小白一个,如果接下来的描述有什么不对的地方,欢迎批评。如果觉得可取,转发时记得点赞哟~


目录

问题

解决方案:

重点1:线程池大小

重点2:适当的阻塞队列

无界队列

有界队列

重点3:明确拒绝策略


问题

首先,在《阿里巴巴Java开发手册》中明确指出:

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

这里说一下原理先,为什么不能这么创建

先说说newFixedThreadPool和newSingleThreadExecutor这两个

这两个用来存储线程的队列是无界的,这个影响的话,如果极端情况下,线程被占满,请求一直进来,就会造成队列中一直堆积。这种情况很容易就造成oom了,所以这种非常不安全,pass掉!

再说说newCachedThreadPool和newScheduledThreadPool这两个

这两个线程池的数量是Integer.MAX_VALUE,每次来一个任务,通过底层你可以看到,是new了一个线程进行执行,不复用,非常的浪费资源,这和自己每次去new线程没什么区别。创建的线程太多的话,就会造成OOM,所以这两种也pass掉


解决方案:

这里不长篇大论的讲理论了,直接说关键点:

重点1:线程池大小

线程池有两个线程数的设置,一个为核心池线程数,一个为最大线程数。

当创建的线程数等于 corePoolSize 时,会加入设置的阻塞队列。当队列满时,会创建线程执行任务直到线程池中的数量等于maximumPoolSize。

所以线程池的大小很重要,这个取决于你的阻塞队列是否可用,最大线程池是否可用,是否可以自动扩容线程池,动态调节等功能是否生效,是否安全等。。。

重点2:适当的阻塞队列

阻塞队列共有7个,

3个为有界的阻塞队列,ArrayBlockingQueue,LinkedBlockingQueue ,LinkedBlockingDeque

3个为无界的阻塞队列,LinkedTransferQueue,DelayQueue,PriorityBlockingQueue

1个比较特殊的不存储元素的队列,SynchronousQueue

无界队列

队列大小无限制,常用的为无界的LinkedBlockingQueue,使用该队列做为阻塞队列时要尤其当心,当任务耗时较长时可能会导致大量新任务在队列中堆积最终导致OOM。阅读代码发现,Executors.newFixedThreadPool 采用就是 LinkedBlockingQueue,而楼主踩到的就是这个坑,当QPS很高,发送数据很大,大量的任务被添加到这个无界LinkedBlockingQueue 中,导致cpu和内存飙升服务器挂掉。

有界队列

常用的有两类,一类是遵循FIFO原则的队列如ArrayBlockingQueue,另一类是优先级队列如PriorityBlockingQueue。PriorityBlockingQueue中的优先级由任务的Comparator决定。 

使用有界队列时队列大小需和线程池大小互相配合,线程池较小有界队列较大时可减少内存消耗,降低cpu使用率和上下文切换,但是可能会限制系统吞吐量。

所以如果不考虑特殊因素的话,正常情况下,我们应该去选择有界队列,才可以让线程池变得安全。同时有界队列才能使下一个重点生效!

重点3:明确拒绝策略

共有五中拒绝策略,

ThreadPoolExecutor.AbortPolicy :丢弃任务并抛出RejectedExecutionException异常。 (默认)

 

ThreadPoolExecutor.DiscardPolicy  :也是丢弃任务,但是不抛出异常。

 

 

ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)

 

 

ThreadPoolExecutor.CallerRunsPolicy:由调用线程处理该任务

最后一种就是你去实现接口,然后实现一种自定义的拒绝策略,这种方法不细说了,可以看一下上面几种怎么实现的,模仿一下就可以了。

默认的会抛出异常,如果自己没打算去处理那些要抛弃的任务的话,就可以选择第二种,丢弃任务不抛出异常。如果说任务比较重要,可以选择默认的,然后进行捕捉异常,在异常中,将任务自己保存起来或者预警什么的都可以。如果都要丢弃,还可以选择第三种丢弃方式,将最开始进来的给丢弃掉,这种用的就比较少了。还有第四种,由创建任务的这个线程去处理这件事,这种的话会大大降低系统吞吐量,如果不是特殊情况,一般选择第一二种就ok了。


安全快速便捷创建线程池的辅助工具类,如果有不完善的地方,欢迎评论指出,我会努力完善的!
该工具类里面有三种默认的创建方式,只需要传入核心线程池大小即可,三种默认的分别为满了之后丢弃抛异常,满了之后丢弃不抛异常,满了之后丢弃最前面的重试插入
还有一种自定义的创建方式,高度自定义化,完全自己设计,不过所需要的参数已经全部准备好,只需要选择即可。傻瓜式创建,安全且方便
而且所有的参数是调用时才会创建放入,不会提前创建浪费资源
具体的内容请阅读源码,注释很全面,根据注释和命名可以明白是什么意思的,如果有乱码,请用UTF-8重新编码

下方免费下载辅助类的链接哦

 

 

 

 

 

这篇关于不要使用Executors直接创建线程池,非常不安全的,阿里代码规范明确规定不能这么创建线程池的,该如何正确创建安全可靠的线程池,线程池辅助创建工具类的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Rust中的注释使用解读

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

MobaXterm远程登录工具功能与应用小结

《MobaXterm远程登录工具功能与应用小结》MobaXterm是一款功能强大的远程终端软件,主要支持SSH登录,拥有多种远程协议,实现跨平台访问,它包括多会话管理、本地命令行执行、图形化界面集成和... 目录1. 远程终端软件概述1.1 远程终端软件的定义与用途1.2 远程终端软件的关键特性2. 支持的

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

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

使用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 库我是将整个头文件/源文件都添加到了工程中进行编译,这样 跨平台

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中,括号匹配是一个常见问题,尤其是在