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线程池内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
基于SpringBoot与Mybatis实现SpringMVC Web项目
这篇文章主要介绍了基于SpringBoot与Mybatis实现SpringMVC Web项目的相关资料，需要的朋友可以参考下2017-04-04
进入到@SpringBootApplication的源码，可以看到里面组合了三个我们感兴趣的注解@ComponentScan、@EnableAutoConfiguration、@SpringBootConfiguration，我们一一分析这三个注解2022-10-10
这篇文章主要介绍了Java中的日期时间处理及格式化处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-08-08
Spring事务传播机制是指，包含多个事务的方法在相互调用时，事务是如何在这些方法间传播的。本文通过示例详细介绍了Spring的事务传播机制，需要的可以参考一下2023-01-01
springcloud-gateway整合jwt+jcasbin实现权限控制的详细过程
这篇文章主要介绍了springcloud-gateway整合jwt+jcasbin实现权限控制,基于springboot+springcloud+nacos的简单分布式项目，项目交互采用openFeign框架，单独提取出来成为一个独立的model，需要的朋友可以参考下2023-02-02
我们在做项目的时候通常需要通过请求日志来排查定位线上问题,如果日志比较多而我们又需要查找整个请求的全部日志的时候会比较困难,下面我们就来看看如何用java aop实现请求id的日志记录吧2024-12-12
Springboot2 集成 druid 加密数据库密码的配置方法
这篇文章给大家介绍Springboot2 集成 druid 加密数据库密码的配置方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧2021-07-07
我们经常会遇到父子线程数据传递(非调用参数)的场景,本文主要介绍了Java线程之间数据传递的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-08-08
SpringBoot3.x接入Security6.x实现JWT认证的完整步骤
这篇文章主要介绍了Spring Boot 3.x中Spring Security 6.x的安全配置变化,特别是JWT过滤器的工作原理和配置方法,文中通过代码介绍的非常详细,需要的朋友可以参考下2025-02-02
本文主要是给大家介绍 OIDC 的核心概念以及如何通过对 Spring Security 的授权码模式进行扩展来实现 OIDC 的单点登录。对Security实现OIDC单点登录的详细过程感兴趣的朋友，一起看看吧2021-09-09
最新评论