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

一方面要调整业务代码，使用默认线程池；另一方面也可以暂时增加默认线程池大小缓解

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

最新评论