不是吧？线程池这样搞？

其他系列文章目录

设计模式合集

多线程合集

分布式合集

ES合集

文章目录

系列文章目录

前言

一、为什么需要线程池？

二、举个背景例子

三、怎么创建线程池？

四、线程池指定线程数

前言

学习线程池能够帮助我们更好地处理多线程编程，并提高程序的性能和稳定性。

一、为什么需要线程池？

JVM在HotSpot的线程模型下，Java线程会一对一映射为内核线程。
这意味着，在Java中每次创建以及回收线程都会去内核创建以及回收。
这就有可能导致: 创建和销毁线程所花费的时间和资源可能比处理的任务花费的时间和资源要更多。
线程池的出现是为了提高线程的复用性以及固定线程的数量！！！

二、举个背景例子

一个消息管理平台，提供其中一个功能就是: 运营会圈定人群然后群发消息。
主要流程大致就是:创建模板---->定时---->群发消息---->用户收到消息。

先说一个概念：HDFS (Hadoop Distributed File System) 是分布式文件系统的一种，用于存储和处理大数据集。它是Hadoop框架的核心组件之一。HDFS可以让用户将大数据集分散在多台计算机上，以提高数据处理能力和可靠性。它将数据拆分为小块并存储在多台计算机上，提供了读写分离、容错机制、数据备份和高可用等特性。HDFS的基本单位是数据块，通常为128MB或256MB。数据块的复制数量和位置由系统自动管理。HDFS对于大数据的存储和管理提供了高度的可靠性和可扩展性，因此被广泛应用于大数据处理和分析领域。

然后运营圈定的人群实际上在模板上只是一个ID、这边要通过ID去获取到HDFS文件，
对HDFS文件进行遍历，然后继续往下发，（接收到定时任务，再对HDFS进行遍历）这里的处理，用的就是线程池处理。

HDFS遍历其实就是IO的操作，把这个过程给异步化，为了提高系统的吞吐量，于是这里用的线程池。即便遍历HDFS出现问题，我们可以建设完备的监控和告警可以及时发现。

三、怎么创建线程池？

阿里巴巴开发手册就有提到，不要使用Executors去创建线程。建议使用ThreadPoolExecutor去创建线程池。

最主要的目的就是:使用ThreadPoolExecutor创建的线程你是更能了解线程池运行的规则，避免资源耗尽的风险。

七个核心参数：

corePoolSize：核心线程数，线程池维护的最少线程数。
maximumPoolSize：最大线程数，线程池维护的最大线程数。
keepAliveTime：线程空闲时间，当线程池中的线程数大于核心线程数时，这些多余的线程会被销毁，这个参数定义了这些线程的空闲时间。
TimeUnit：时间单位，keepAliveTime的时间单位。
workQueue：任务队列，当提交的任务数量大于线程池当前可用的线程数时，任务会被存放在这个队列中。
threadFactory：线程工厂，用于创建线程池中的线程。
handler：拒绝策略，当任务队列已满且线程池中的线程数量已达到最大值时，新提交的任务如何被拒绝执行。常用的拒绝策略有AbortPolicy、CallerRunsPolicy、DiscardOldestPolicy和DiscardPolicy。