springboot使用线程池(ThreadPoolTaskExecutor)示例
代码仓库：gitee
线程池创建
@Configuration
@EnableAsync
public class TaskPoolConfig {
@Bean("syncExecutorPool")
public Executor taskExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
// 核心池大小
taskExecutor.setCorePoolSize(5);
// 最大线程数
taskExecutor.setMaxPoolSize(10);
// 队列程度
taskExecutor.setQueueCapacity(100);
// 线程空闲时间
taskExecutor.setKeepAliveSeconds(60);
// 线程前缀名称
taskExecutor.setThreadNamePrefix("syncExecutor--");
// 该方法用来设置 线程池关闭 的时候 等待 所有任务都完成后，再继续 销毁 其他的 Bean，
// 这样这些 异步任务 的 销毁 就会先于 数据库连接池对象 的销毁。
taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
// 任务的等待时间 如果超过这个时间还没有销毁就 强制销毁，以确保应用最后能够被关闭，而不是阻塞住。
taskExecutor.setAwaitTerminationSeconds(60);
// 线程不够用时由调用的线程处理该任务
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
return taskExecutor;
}
}
线程池参数
核心线程数量：CorePoolSize
看业务场景设置（我通常设置为CPU核心*1）
最大线程数量：MaxPoolSize
当核心线程数量都在使用状态时，会调用最大线程数量里的线程，使用的总线程不会超过最大线程数量，其余则等待（我通常设置为CPU核心*2）
队列程度：QueueCapacity
线程队列的大小
线程空闲时间：KeepAliveSeconds
线程前缀名称：ThreadNamePrefix
停机策略：WaitForTasksToCompleteOnShutdown
该方法用来设置 线程池关闭 的时候 等待 所有任务都完成后，再继续 销毁 其他的 Bean，这样这些 异步任务 的 销毁 就会先于 数据库连接池对象 的销毁。
任务的等待时间：AwaitTerminationSeconds
任务的等待时间 如果超过这个时间还没有销毁就 强制销毁，以确保应用最后能够被关闭，而不是阻塞住
拒接策略：RejectedExecutionHandler
线程不够用时由调用的线程处理该任务
线程池测试1（核心线程数量）
结果：线程池的核心线程数量轮训执行
线程池测试2（当核心线程数量和最大线程数量不够时）
随机睡眠0-10000毫秒
new Random().nextInt(10000)
结果：
当5个核心线程数量不够用时，使用最大线程数量里的线程
当最大线程数量不够用时，使用主线程执行该任务
// 线程不够用时由调用的线程处理该任务
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
总结
到此这篇关于springboot使用线程池（ThreadPoolTaskExecutor）示例的文章就介绍到这了,更多相关springboot线程池内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文详细给大家介绍了Java中Random简介相关知识，非常不错，具有参考借鉴价值，需要的朋友参考下吧2017-06-06
springBoot 打war包 程序包com.sun.istack.internal不存在的问题及解决方案
这篇文章主要介绍了springBoot 打war包 程序包com.sun.istack.internal不存在的问题及解决方案,亲测试过可以，需要的朋友可以参考下2018-07-07
springboot工程，是没有webapp文件夹的，静态文件放在src/main/resources/static文件夹下即可，模板文件放在src/main/resources/templates下，本文给大家介绍springBoot快速访问工程目录下的静态资源的相关知识，一起看看吧2021-06-06
这篇文章主要介绍了Mybatis注解sql时出现的一个错误及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-02-02
这篇文章主要介绍了Java基础之Bean的创建、定位和使用,文中有非常详细的图文示例及代码，对正在学习java基础的小伙伴们有很好地帮助,需要的朋友可以参考下2021-05-05
SpringBoot继承LogStash实现日志收集的方法示例
这篇文章主要介绍了SpringBoot继承LogStash实现日志收集的方法示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-05-05
Java DataBase Connectivity是将Java与SQL结合且独立于特定的数据库系统的应用程序编程接口，一种可用于执行SQL语句的JavaAPI。本文主要介绍了JDBC的概念及获取数据库连接的5种方式，需要的可以参考一下2022-09-09
线上项目涉及大量查询接口中，存在电话号明文展示不合规的问题。如果对每个接口返回结果中电话号相关字段修改相关代码逻辑，则工作量较大花费时间多。因此设计电话号加密注解，减少工作量。2021-06-06
为了方便组织各种信息，计算机常将信息以表的形式进行组织，然后再以行和列的形式呈现出来。二维数组的结构决定了其能非常方便地表示计算机中的表，以第一个下标表示元素所在的行，第二个下标表示元素所在的列。下面简单了解一下二维数组，包括数组的声明和初始化2022-04-04
这篇文章主要介绍了理解JDK动态代理为什么必须要基于接口，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-10-10
最新评论