Springboot之@Async不执行原因及分析
作者:成明宁杰
背景
项目中有一个异步方法允许一段时间后就不再执行了。该异步方法是使用@Async注解的。
分析原因
1.业务场景用了@Async注解的方法,且没有使用自定义线程池。
2.ThreadPoolTaskExecutor是springboot提供的默认线程池 。
也就是说如果没有自定义线程池,那么会自动装配这个默认的。
In the absence of an Executor bean in the context, Spring Boot auto-configures a ThreadPoolTaskExecutor with sensible defaults that can be automatically associated to asynchronous task execution (@EnableAsync) and Spring MVC asynchronous request processing.
3.ThreadPoolTaskExecutor的默认参数是由TaskExecutionProperties控制的。
默认核心线程是8,线程prefix是 “task-”。
搜索线程dump,有8个异步任务已经耗尽了线程池,且执行没有停止的迹象。
构造默认线程池方法
org.springframework.boot.task.TaskExecutorBuilder#configure
4.如果该线程池被耗尽,则所有任务将会在线程池的队列中等待,而默认队列大小是Integer.MAX_VALUE
5.一方面要调整业务代码,使用默认线程池;另一方面也可以暂时增加默认线程池大小缓解
@Async使用总结
1、 非必须不使用异步。如果是核心业务包含事务处理,先同步记录数据,再异步发起。防止直接发起后异步没被调度到服务关闭,造成数据丢失
2、 核心业务必须使用自定义线程池,防止默认异步线程池阻塞,也方便通过线程池监控核心执行情况
3、 简单业务场景使用默认线程池时,避免操作长时间过长占用默认线程池,影响Spring以及别的框架组件异步任务执行
4、 @Async可能失效的原因
- a) @SpringBootApplication启动类当中没有添加@EnableAsync注解。
- b) 异步方法使用注解@Async的返回值只能为void或者Future。
- c) 没有走Spring的代理类。因为@Transactional和@Async注解的实现都是基于Spring的AOP,而AOP的实现是基于动态代理模式实现的。那么注解失效的原因就很明显了,有可能因为调用方法的是对象本身而不是代理对象,因为没有经过Spring容器管理。
@Async失效解决方法
- a) 注解的方法必须是public方法。
- b) 注解的方法不要定义为static
- c) 方法一定要从另一个类中调用,也就是从类的外部调用,类的内部调用是无效的。
- d) 如果需要从类的内部调用,需要先获取其代理类。
如果该线程池被耗尽,则所有任务将会在线程池的队列中等待,而默认队列大小是Integer.MAX_VALUE
一方面要调整业务代码,使用默认线程池;另一方面也可以暂时增加默认线程池大小缓解
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。