Spring-boot 中@Async使用遇到的坑
Spring的@Async使用防坑
很多人会直接只用@Async来执行异步操作。但是这里面有一个问题，如果都是用spring的默认实现，是有坑的。
当我们开启EnableAsync注解 就可以使用@Async注解来执行异步操作了。
我们现在通过EnableAsync注解去打开spring异步世界的坑。
走JDK的动态代理：
最终走到这儿来了：AnnotationAsyncExecutionInterceptor#getDefaultExecutor(BeanFactory)
问题就在这里，如果我们自己没有定义Executor，也就是上面从容器beanFactory 中拿不到Executor 那么就会使用--SimpleAsyncTaskExecutor，这玩意儿实际上根本不是线程池！！！！！
请看它的doExecute 方法，直接new新的线程。
所以这玩意儿一直都是在创建新的 线程执行任务。。。。。
修改方式：
方案1.@Async 指定我们自己的线程池执行：@Async("自己线程池beanName")
方案2：回到AnnotationAsyncExecutionInterceptor#getDefaultExecutor(BeanFactory) 方法，看它如何获取线程池的：
要么我们自己配置一个TaskExecutor， 要么我们把我自己配置的线程池的名字叫做 taskExecutor 。这个常量的值：
DEFAULT_TASK_EXECUTOR_BEAN_NAME = "taskExecutor"，这样可以避免使用SimpleAsyncTaskExecutor。
方案3：实现AsyncConfigurer 接口作为一个配置类交给spring管理，通过getAsyncExecutor 方法配置异步线程池。
Spring-boot 中@Async使用的坑
1、首先使用@Async 需要在Spring启动类上添加注解@EnableAsyn或者在你们线程池配置类添加@EnableAsyn
一下两种选择一种即可
@SpringBootApplication
@EnableAsync
public class SpringBootApplicationStart {
public static void main(String[] args) {
SpringApplication.run(SpringBootApplicationStart.class);
}
}@EnableAsync
@Configuration
public class ThreadPoolConfig {
@Bean("simpleThreadPool")
public ThreadPoolTaskExecutor simpleThreadPool(){
ThreadPoolTaskExecutor simpleThreadPool = new ThreadPoolTaskExecutor();
simpleThreadPool.setCorePoolSize(5);
simpleThreadPool.setMaxPoolSize(10);
simpleThreadPool.setQueueCapacity(25);
simpleThreadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
simpleThreadPool.initialize();
return simpleThreadPool;
}
}注意如果自己配置了线程池那么在使用的时候需要保持一致
例如：@Async("simpleThreadPool")
2、在使用@Async的时候切记不要在一个类里面调用@Async声明的方法，会产生代理绕过问题。
@Async
public void asyncProcess() throws InterruptedException {
Thread.sleep(2000);
}3、注意写法
@Autowired
private AsyncTaskService asyncTaskService;
public String asyncMethod(String name,int age) {
OnelogStats.trace("msg_async", "进入service");
try {
// 初学者可能会有这种错误，AsyncTaskService没有注入到Spring导致Async不起作用,注释不规范
//new AsyncTaskService().asyncProcess();
asyncTaskService.asyncProcess();
} catch (InterruptedException e) {
return "async error";
}
return "I am " + name + ", I am " + age + " years old.";
}到此这篇关于Spring的@Async使用操遇到的坑的文章就介绍到这了,更多相关Spring @Async使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
本文的内容非常的简单，跟随世界潮流，第一个Java程序输出“Hell World!”。希望大家能够喜欢2016-05-05
Java 语言中的类、构造器、方法、成员变量、参数等都可以被注解进行标注，这篇文章主要介绍了Java注解的介绍和使用详细讲解,需要的朋友可以参考下2023-02-02
本篇文章给大家总计了Java数组的遍历与求和的知识点以及需要注意的地方，需要的朋友参考学习下。2018-02-02
本文通过实例代码给大家介绍SpringBoot整合aws的全过程，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧2021-12-12
这篇文章主要介绍了MyBatis直接执行SQL查询及数据批量插入的相关知识，需要的朋友一起学习吧2016-01-01
这篇文章主要介绍了mybatis xml如何使用not in 某个集合的格式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-01-01
SpringBoot使用自动配置xxxAutoConfiguration
这篇文章介绍了SpringBoot自动配置xxxAutoConfiguration的使用方法，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-12-12
顺序查找又称线性查找,主要用于在线性表中进行查找。顺序查找通常分为对一般的无序线性表的顺序查找和对按关键字有序的顺序表的顺序查找，下面我们来一探究竟2022-08-08
java实现图片转base64字符串 java实现base64字符串转图片
这篇文章主要为大家详细介绍了java实现图片转base64字符串，java实现base64字符串转图片，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-02-02
本文主要介绍了java8中的CompletableFuture,CompletableFuture实现了CompletionStage接口和Future接口,前者是对后者的一个扩展，增加了异步回调、流式处理、多个Future组合处理的能力，使Java在处理多任务的协同工作时更加顺畅便利,下文需要的朋友可以参考一下2022-05-05
最新评论