基于Nacos的简单动态化线程池实现
在后台开发中，会经常用到线程池技术，对于线程池核心参数的配置很大程度上依靠经验。然而，由于系统运行过程中存在的不确定性，我们很难一劳永逸地规划一个合理的线程池参数。在对线程池配置参数进行调整时，一般需要对服务进行重启，这样修改的成本就会偏高。一种解决办法就是，将线程池的配置放到平台侧，运行开发同学根据系统运行情况对核心参数进行动态配置。
本文以nacos作为服务配置中心，以修改线程池核心线程数、最大线程数为例，实现一个简单的动态化线程池。
代码实现
1.依赖
com.alibaba.cloud spring-cloud-starter-alibaba-nacos-discovery 2021.1 com.alibaba.cloud spring-cloud-starter-alibaba-nacos-config 2021.1 org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter 2.配置yml文件
bootstrap.yml：
server: port: 8010 # 应用名称（nacos会将该名称当做服务名称）spring: application: name: order-service cloud: nacos: discovery: namespace: public server-addr: 192.168.174.129:8848 config: server-addr: 192.168.174.129:8848 file-extension: yml application.yml：
spring: profiles: active: dev 为什么要配置两个yml文件？
springboot中配置文件的加载是存在优先级顺序的，bootstrap优先级高于application。
nacos在项目初始化时，要保证先从配置中心进行配置拉取，拉取配置之后才能保证项目的正常启动。
3.nacos配置
登录到nacos管理页面，新建配置，如下图所示：
注意data id的命名格式为，${spring.application.name}-${spring.profile.active}.${spring.cloud.nacos.config.file-extension} ，在本文中，data id的名字就是order-service-dev.yml。
这里我们只配置了两个参数，核心线程数量和最大线程数。
4.线程池配置和nacos配置变更监听
@refreshscope@configurationpublic class dynamicthreadpool implements initializingbean { @value(${core.size}) private string coresize; @value(${max.size}) private string maxsize; private static threadpoolexecutor threadpoolexecutor; @autowired private nacosconfigmanager nacosconfigmanager; @autowired private nacosconfigproperties nacosconfigproperties; @override public void afterpropertiesset() throws exception { //按照nacos配置初始化线程池 threadpoolexecutor = new threadpoolexecutor(integer.parseint(coresize), integer.parseint(maxsize), 10l, timeunit.seconds, new linkedblockingqueue(10), new threadfactorybuilder().setnameformat(c_t_%d).build(), new rejectedexecutionhandler() { @override public void rejectedexecution(runnable r, threadpoolexecutor executor) { system.out.println(rejected!); } }); //nacos配置变更监听 nacosconfigmanager.getconfigservice().addlistener(order-service-dev.yml, nacosconfigproperties.getgroup(), new listener() { @override public executor getexecutor() { return null; } @override public void receiveconfiginfo(string configinfo) { //配置变更，修改线程池配置 system.out.println(configinfo); changethreadpoolconfig(integer.parseint(coresize), integer.parseint(maxsize)); } }); } /** * 打印当前线程池的状态 */ public string printthreadpoolstatus() { return string.format(core_size:%s,thread_current_size:%s; + thread_max_size:%s;queue_current_size:%s,total_task_count:%s, threadpoolexecutor.getcorepoolsize(), threadpoolexecutor.getactivecount(), threadpoolexecutor.getmaximumpoolsize(), threadpoolexecutor.getqueue().size(), threadpoolexecutor.gettaskcount()); } /** * 给线程池增加任务 * * @param count */ public void dynamicthreadpooladdtask(int count) { for (int i = 0; i < count; i++) { int finali = i; threadpoolexecutor.execute(new runnable() { @override public void run() { try { system.out.println(finali); thread.sleep(10000); } catch (interruptedexception e) { e.printstacktrace(); } } }); } } /** * 修改线程池核心参数 * * @param coresize * @param maxsize */ private void changethreadpoolconfig(int coresize, int maxsize) { threadpoolexecutor.setcorepoolsize(coresize); threadpoolexecutor.setmaximumpoolsize(maxsize); }} 这个代码就是实现动态线程池和核心了，需要说明的是：
@refreshscope：这个注解用来支持nacos的动态刷新功能；
@value(${max.size})，@value(${core.size})：这两个注解用来读取我们上一步在nacos配置的具体信息；同时，nacos配置变更时，能够实时读取到变更后的内容
nacosconfigmanager.getconfigservice().addlistener：配置监听，nacos配置变更时实时修改线程池的配置。
5.controller
为了观察线程池动态变更的效果，增加controller类。
@restcontroller@requestmapping(/threadpool)public class threadpoolcontroller { @autowired private dynamicthreadpool dynamicthreadpool; /** * 打印当前线程池的状态 */ @getmapping(/print) public string printthreadpoolstatus() { return dynamicthreadpool.printthreadpoolstatus(); } /** * 给线程池增加任务 * * @param count */ @getmapping(/add) public string dynamicthreadpooladdtask(int count) { dynamicthreadpool.dynamicthreadpooladdtask(count); return string.valueof(count); }} 6.测试
启动项目，访问http://localhost:8010/threadpool/print打印当前线程池的配置。
可以看到，这个就是我们之前在nacos配置的线程数。
访问http://localhost:8010/threadpool/add?count=20增加20个任务，重新打印线程池配置
可以看到已经有线程在排队了。
为了能够看到效果，我们多访问几次/add接口，增加任务数，在控制台出现拒绝信息时调整nacos配置。
此时，执行/add命令时，所有的线程都会提示rejected。
调整nacos配置，将核心线程数调整为50，最大线程数调整为100.
重新多次访问/add接口增加任务，发现没有拒绝信息了。这时，打印具体的线程状态，发现线程池参数修改成功。
基于 spring boot + mybatis plus + vue & element 实现的后台管理系统 + 用户小程序，支持 rbac 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
项目地址：https://github.com/yunaiv/ruoyi-vue-pro
视频教程：https://doc.iocoder.cn/video/
总结
这里，只是简单实现了一个可以调整核心线程数和最大线程数的动态线程池。具体的线程池实现原理可以参考美团的这篇文章：https://tech.meituan.com/2020/04/02/java-pooling-pratice-in-meituan.html，结合监控告警等实现一个完善的动态线程池产品。
优秀的轮子还有好多，比如hippo4j ，使用起来和dynamic-tp差不多。hippo4j 有无依赖中间件实现动静线程池，也有默认实现nacos和apollo的版本，而dynamic-tp 默认实现依赖nacos或apollo。
浅谈纠缠量子传感器
美格智能助力YoloLiv让直播“小白”秒变“专家”，共同开启电商的“大航海”时代
iOS 15来了！苹果也打算走多系统互通的路子？
挪威人形机器人公司1X完成1亿美元B轮融资
戴尔即将推出多款Android产品，包括2款平板电脑
基于Nacos的简单动态化线程池实现
ch32和stm32参数对比
评估数字通信链路质量的方法--眼图测试
国内三大云服务运营商谁更强
TeamViewer——一个值得信赖的远程办公“工作利器“
在新形冠状肺炎疫情下智能家居市场有什么样的新机会
GPS中智能天线的设计与实现
华为与奇瑞将在智能汽车/5G/大数据三大领域展开合作
FIILT1无线蓝牙耳机评测 人声表现力令人满意便携性极佳
彭于晏助阵Vivo X9 Plus发布会：12月30日3498元正式开卖！
阻容元件对音响设备的影响及如何进行合理的选用
2019年我国将建超8万个5G基站
【飞创直线模组】激光焊接六轴三坐标平台应用方案
星空灰魅蓝Note5图赏 大气精致手感棒 不愧千元之王
首航4G主动安全智能终端SH-GM荣幸入选
本文以nacos作为服务配置中心，以修改线程池核心线程数、最大线程数为例，实现一个简单的动态化线程池。
代码实现
1.依赖
com.alibaba.cloud spring-cloud-starter-alibaba-nacos-discovery 2021.1 com.alibaba.cloud spring-cloud-starter-alibaba-nacos-config 2021.1 org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter 2.配置yml文件
bootstrap.yml：
server: port: 8010 # 应用名称（nacos会将该名称当做服务名称）spring: application: name: order-service cloud: nacos: discovery: namespace: public server-addr: 192.168.174.129:8848 config: server-addr: 192.168.174.129:8848 file-extension: yml application.yml：
spring: profiles: active: dev 为什么要配置两个yml文件？
springboot中配置文件的加载是存在优先级顺序的，bootstrap优先级高于application。
nacos在项目初始化时，要保证先从配置中心进行配置拉取，拉取配置之后才能保证项目的正常启动。
3.nacos配置
登录到nacos管理页面，新建配置，如下图所示：
注意data id的命名格式为，${spring.application.name}-${spring.profile.active}.${spring.cloud.nacos.config.file-extension} ，在本文中，data id的名字就是order-service-dev.yml。
这里我们只配置了两个参数，核心线程数量和最大线程数。
4.线程池配置和nacos配置变更监听
@refreshscope@configurationpublic class dynamicthreadpool implements initializingbean { @value(${core.size}) private string coresize; @value(${max.size}) private string maxsize; private static threadpoolexecutor threadpoolexecutor; @autowired private nacosconfigmanager nacosconfigmanager; @autowired private nacosconfigproperties nacosconfigproperties; @override public void afterpropertiesset() throws exception { //按照nacos配置初始化线程池 threadpoolexecutor = new threadpoolexecutor(integer.parseint(coresize), integer.parseint(maxsize), 10l, timeunit.seconds, new linkedblockingqueue(10), new threadfactorybuilder().setnameformat(c_t_%d).build(), new rejectedexecutionhandler() { @override public void rejectedexecution(runnable r, threadpoolexecutor executor) { system.out.println(rejected!); } }); //nacos配置变更监听 nacosconfigmanager.getconfigservice().addlistener(order-service-dev.yml, nacosconfigproperties.getgroup(), new listener() { @override public executor getexecutor() { return null; } @override public void receiveconfiginfo(string configinfo) { //配置变更，修改线程池配置 system.out.println(configinfo); changethreadpoolconfig(integer.parseint(coresize), integer.parseint(maxsize)); } }); } /** * 打印当前线程池的状态 */ public string printthreadpoolstatus() { return string.format(core_size:%s,thread_current_size:%s; + thread_max_size:%s;queue_current_size:%s,total_task_count:%s, threadpoolexecutor.getcorepoolsize(), threadpoolexecutor.getactivecount(), threadpoolexecutor.getmaximumpoolsize(), threadpoolexecutor.getqueue().size(), threadpoolexecutor.gettaskcount()); } /** * 给线程池增加任务 * * @param count */ public void dynamicthreadpooladdtask(int count) { for (int i = 0; i < count; i++) { int finali = i; threadpoolexecutor.execute(new runnable() { @override public void run() { try { system.out.println(finali); thread.sleep(10000); } catch (interruptedexception e) { e.printstacktrace(); } } }); } } /** * 修改线程池核心参数 * * @param coresize * @param maxsize */ private void changethreadpoolconfig(int coresize, int maxsize) { threadpoolexecutor.setcorepoolsize(coresize); threadpoolexecutor.setmaximumpoolsize(maxsize); }} 这个代码就是实现动态线程池和核心了，需要说明的是：
@refreshscope：这个注解用来支持nacos的动态刷新功能；
@value(${max.size})，@value(${core.size})：这两个注解用来读取我们上一步在nacos配置的具体信息；同时，nacos配置变更时，能够实时读取到变更后的内容
nacosconfigmanager.getconfigservice().addlistener：配置监听，nacos配置变更时实时修改线程池的配置。
5.controller
为了观察线程池动态变更的效果，增加controller类。
@restcontroller@requestmapping(/threadpool)public class threadpoolcontroller { @autowired private dynamicthreadpool dynamicthreadpool; /** * 打印当前线程池的状态 */ @getmapping(/print) public string printthreadpoolstatus() { return dynamicthreadpool.printthreadpoolstatus(); } /** * 给线程池增加任务 * * @param count */ @getmapping(/add) public string dynamicthreadpooladdtask(int count) { dynamicthreadpool.dynamicthreadpooladdtask(count); return string.valueof(count); }} 6.测试
启动项目，访问http://localhost:8010/threadpool/print打印当前线程池的配置。
可以看到，这个就是我们之前在nacos配置的线程数。
访问http://localhost:8010/threadpool/add?count=20增加20个任务，重新打印线程池配置
可以看到已经有线程在排队了。
为了能够看到效果，我们多访问几次/add接口，增加任务数，在控制台出现拒绝信息时调整nacos配置。
此时，执行/add命令时，所有的线程都会提示rejected。
调整nacos配置，将核心线程数调整为50，最大线程数调整为100.
重新多次访问/add接口增加任务，发现没有拒绝信息了。这时，打印具体的线程状态，发现线程池参数修改成功。
基于 spring boot + mybatis plus + vue & element 实现的后台管理系统 + 用户小程序，支持 rbac 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
项目地址：https://github.com/yunaiv/ruoyi-vue-pro
视频教程：https://doc.iocoder.cn/video/
总结
这里，只是简单实现了一个可以调整核心线程数和最大线程数的动态线程池。具体的线程池实现原理可以参考美团的这篇文章：https://tech.meituan.com/2020/04/02/java-pooling-pratice-in-meituan.html，结合监控告警等实现一个完善的动态线程池产品。
优秀的轮子还有好多，比如hippo4j ，使用起来和dynamic-tp差不多。hippo4j 有无依赖中间件实现动静线程池，也有默认实现nacos和apollo的版本，而dynamic-tp 默认实现依赖nacos或apollo。
浅谈纠缠量子传感器
美格智能助力YoloLiv让直播“小白”秒变“专家”，共同开启电商的“大航海”时代
iOS 15来了！苹果也打算走多系统互通的路子？
挪威人形机器人公司1X完成1亿美元B轮融资
戴尔即将推出多款Android产品，包括2款平板电脑
基于Nacos的简单动态化线程池实现
ch32和stm32参数对比
评估数字通信链路质量的方法--眼图测试
国内三大云服务运营商谁更强
TeamViewer——一个值得信赖的远程办公“工作利器“
在新形冠状肺炎疫情下智能家居市场有什么样的新机会
GPS中智能天线的设计与实现
华为与奇瑞将在智能汽车/5G/大数据三大领域展开合作
FIILT1无线蓝牙耳机评测 人声表现力令人满意便携性极佳
彭于晏助阵Vivo X9 Plus发布会：12月30日3498元正式开卖！
阻容元件对音响设备的影响及如何进行合理的选用
2019年我国将建超8万个5G基站
【飞创直线模组】激光焊接六轴三坐标平台应用方案
星空灰魅蓝Note5图赏 大气精致手感棒 不愧千元之王
首航4G主动安全智能终端SH-GM荣幸入选