滨州网站建设公司电话,wordpress页面侧边栏消失,注册一个5000万空壳公司要多少钱,榆林市城乡建设规划局网站参考#xff1a;解剖SpringBoot异步线程池框架_哔哩哔哩_bilibili
1、 为什么要用异步框架#xff0c;它解决什么问题#xff1f;
在SpringBoot的日常开发中#xff0c;一般都是同步调用的。但经常有特殊业务需要做异步来处理#xff0c;例如#xff1a;注册新用户解剖SpringBoot异步线程池框架_哔哩哔哩_bilibili
1、 为什么要用异步框架它解决什么问题
在SpringBoot的日常开发中一般都是同步调用的。但经常有特殊业务需要做异步来处理例如注册新用户送100个积分或下单成功发送push消息等。
1容错性
如果送积分出现异常不能因为送积分而导致用户注册失败。
因为用户注册是主要功能送积分是次要功能即使送积分异常也要提示用户注册成功然后后面再针对积分异常做补偿处理。
2提升性能
例如注册用户花了20毫秒送积分花费50毫秒。如果同步的话总耗时70毫秒用异常的话无需等待积分故耗时20毫秒。
因此使用异步能解决2个问题容错性性能。
2、简单异步调用示例
1开启异步任务
采用EnableAsync来开启异步任务支持另外需要加入Configuration来把当前类加入springIOC容器中。
SyncConfiguration.java文件
Configuration
EnableAsync
public class SyncConfiguration {
}
2在方法上标记异步调用
增加一个service类用来做积分处理
Async添加在方法上代表该方法为异步处理
ScoreService.java文件
public interface ScoreService {public void addScore(); // 增加积分}ScoreServiceImpl.java文件
Service
Slf4j
public class ScoreServiceImpl implements ScoreService {AsyncOverridepublic void addScore() {// 模拟睡5秒用于赠送积分处理try {Thread.sleep(5000);log.info(--------------------处理积分----------------);} catch (InterruptedException e) {e.printStackTrace();}}}
调用测试
GetMapping(/sync1)public String getAsyncScore(){log.info(--------注册用户----------);scoreService.addScore();return OK;}
连续发送4次请求的日志信息如下 3、为什么要给Async自定义线程池
Async注解在默认情况下用的是SimpleAsyncTaskExecutor线程池因为它不是真正的线程池这个类不重用线程每次调用都会新建一个新的线程。
可以通过如上日志查看每次打印的线程名都是[task-1][task-2], [task-3]……递增的。
我们采用ThreadPoolTaskExecutor其实质是对java.util.concurrent.ThreadPoolExecutor的包装。
4、为Async实现一个自定义线程池
1配置自定义线程池
SyncConfiguration.java文件
Configuration
EnableAsync
public class SyncConfiguration {Bean(namescorePoolTaskExecutor)public ThreadPoolTaskExecutor getScorePoolTaskExecutor(){ThreadPoolTaskExecutor taskExecutor new ThreadPoolTaskExecutor();// 核心线程数taskExecutor.setCorePoolSize(2);// 线程池维护线程的最大数量只有在缓冲队列满了之后才会申请超过核心线程数的线程taskExecutor.setMaxPoolSize(4);// 缓存队列taskExecutor.setQueueCapacity(2);// 空闲时间当超过了核心线程数之外的线程在空闲时间到达之后会被销毁taskExecutor.setKeepAliveSeconds(10);// 异步方法内部线程名称taskExecutor.setThreadNamePrefix(score-);// 当线程池的任务缓存队列已满并且线程池中的线程数目达到maximumPoolSize如果还有任务到达就会采取的拒绝策略taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());taskExecutor.initialize();return taskExecutor;}
}2为Async指定线程池的名称
ScoreService.java文件
public interface ScoreService {public void addScore(); // 增加积分public void addScore2(); // 增加积分测试2
}
ScoreServiceImpl.java文件
Service
Slf4j
public class ScoreServiceImpl implements ScoreService {AsyncOverridepublic void addScore() {// 模拟睡5秒用于赠送积分处理try {Thread.sleep(5000);log.info(--------------------处理积分----------------);} catch (InterruptedException e) {e.printStackTrace();}}Async(scorePoolTaskExecutor)Overridepublic void addScore2() {// 模拟睡5秒用于赠送积分处理try {Thread.sleep(5000);log.info(--------------------处理积分----------------);} catch (InterruptedException e) {e.printStackTrace();}}
}
测试类
GetMapping(/sync2)public String getAsyncScore2(){log.info(--------注册用户----------);scoreService.addScore2();return OK;} 连续调用8次的效果 可以发现只有两个线程一直在重用。
6、总结
1异步的好处 容错性性能提升 2自定义线程池的方法 首先配置类中开启异步任务支持同时配置线程池策略 其次异步方法的Async中指定线程池的名称
