news 2026/3/10 20:12:15

Async 注解原理分析

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Async 注解原理分析

核心作用:Spring 提供的注解,标注在类或方法上,使方法在异步线程中执行,调用者无需等待方法完成即可继续执行后续逻辑。

使用两步走

  1. 启动类添加@EnableAsync,开启异步任务支持;
  2. 需异步执行的方法 / 类上添加@Async注解(示例中常用CompletableFuture处理异步结果)。

@Async 原理分析

@Async可以异步执行任务,本质上是使用动态代理来实现的。通过 Spring 中的后置处理器BeanPostProcessor为使用@Async注解的类创建动态代理,之后@Async注解方法的调用会被动态代理拦截,在拦截器中将方法的执行封装为异步任务提交给线程池处理。

开启异步:@EnableAsync 的作用

  • @EnableAsync通过@Import(AsyncConfigurationSelector.class)加载配置类;
  • AsyncConfigurationSelector根据AdviceMode(默认PROXY)选择加载ProxyAsyncConfiguration
  • ProxyAsyncConfiguration注册关键后置处理器AsyncAnnotationBeanPostProcessor

后置处理器:动态代理的核心

  • AsyncAnnotationBeanPostProcessor@Async生效的关键,会为标注@Async的类创建动态代理;
  • 该处理器通过setBeanFactory()方法创建AsyncAnnotationAdvisor(Spring AOP 的Advisor组件)。

创建Advisor:定义拦截规则与逻辑

dvisor包含Advice(通知逻辑)和Pointcut(切入点):

  • Advice:创建AnnotationAsyncExecutionInterceptor拦截器,负责异步执行逻辑;
  • Pointcut:通过AnnotationMatchingPointcut匹配类 / 方法上的@Async注解(类级别 + 方法级别)。

后置处理器逻辑:生成代理对象

  • Bean 初始化后,postProcessAfterInitialization()方法判断 Bean 是否符合Advisor规则;
  • 符合规则则通过ProxyFactory创建代理对象,后续@Async方法调用会被代理拦截。

@Async 注解方法的拦截

1. 确定异步执行器(线程池)

  • 优先从缓存获取,或通过@Asyncvalue限定符查找自定义线程池;
  • 无自定义线程池时,默认使用SimpleAsyncTaskExecutor风险提示:每次创建新线程,无复用,高并发下易导致资源耗尽)。

2. 封装异步任务

  • 将目标方法执行逻辑(invocation.proceed())封装为Callable任务;
  • 若方法返回Future类型,会阻塞等待结果(处理异步嵌套调用),其他类型执行后返回null

3. 提交异步任务

根据方法返回值类型选择提交方式:

  • CompletableFuture:用supplyAsync()提交;
  • ListenableFuture:用submitListenable()提交;
  • Future:直接submit()提交;
  • void或其他类型:submit()提交后返回null

总结

理解@Async原理的核心在于理解@EnableAsync注解,该注解开启了异步任务的功能。

主要流程如下图:

@Async 使用建议

必须自定义线程池

  • 避免使用默认的SimpleAsyncTaskExecutor,推荐ThreadPoolTaskExecutor
  • 可配置核心线程数、最大线程数、队列容量等(示例:创建executor1executor2等不同线程池,通过@Async("executor1")指定)。

避免 @Async 注解实效

失效场景

原因

解决方案

同一类内调用异步方法

绕过 Spring 代理,未触发拦截

将异步方法移至另一个 Spring Bean

异步方法用static修饰

代理无法拦截静态方法(不属于实例)

用非静态包装方法调用静态逻辑

未加@EnableAsync

未开启异步支持

启动类添加@EnableAsync

方法所在类非 Spring Bean

Spring 无法创建代理

确保类被@Service等注解管理

规范返回值类型

  • 无需结果:返回void
  • 需要结果:返回Future子类(如CompletableFutureListenableFuture);
  • 其他类型(如StringObject):无法获取方法执行结果。

处理异步方法异常

  • 全局处理:实现AsyncConfigurer重写getAsyncUncaughtExceptionHandler(),自定义异常处理器;
  • 局部处理:用CompletableFutureexceptionally()等方法捕获异常。

事务管理注意

  • 异步方法需事务时,需添加@Transactional(propagation = Propagation.REQUIRES_NEW),开启独立新事务(避免与调用方事务关联)。

控制执行顺序

  • 异步方法默认无序,需按顺序执行时,用CompletableFuturethenCompose()thenAccept()等方法串联任务(如先执行fetchDataAsync,再执行processDataAsync)。
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/3/10 3:34:22

别再手写过滤器!SpringCloud Gateway 内置30 个,少写 80% 重复代码

发现公司的网关项目里有很多的轮子,几乎每个人接手这个项目开发,都会自定义过滤器,导致有非常非常多的过滤器,修改其中一个,指不定就会影响其他的人功能,非常的恼火。其实在 Spring Cloud Gateway 本身内置…

作者头像 李华
网站建设 2026/3/3 9:13:26

开源 + 国产芯片:具身智能的 DeepSeek 时刻来了?

为什么大语言模型已经能写作、编程、拿数学奥赛金牌,但机器人连叠个衣服都费劲?一个反常识的事实: 机器人全行业的训练数据加起来,也不够特斯拉的自动驾驶系统训练一天的。 这一点不夸张。 特斯拉 FSD(Full Self-Drivi…

作者头像 李华
网站建设 2026/3/10 18:07:42

PHP 8.5 新特性 闭包可以作为常量表达式了

默认值以前,我会写这样的代码:function someFunction(mixed $someValue, ?callable $callback null): bool{$callback ?? fn () > true;return $callback($someValue);}或者这样:final class SomeClass{private Closure $someCallable;public function __construct(){$t…

作者头像 李华
网站建设 2026/3/7 23:03:12

分布式抢券系统限流器降级与CAP权衡全攻略

分布式抢券系统限流器降级与CAP权衡全攻略 1. 背景与挑战 在电商抢券、秒杀等场景中,限流器是核心组件,用于避免系统过载和优惠券超发。通常我们依赖 Redis 作为全局分布式限流器的计数中心。 然而,一旦 Redis 集群出现故障或网络分区,系统必须具备 多层次的降级与兜底能…

作者头像 李华
网站建设 2026/3/8 21:16:37

通达信周KDJ副图

{}{周C:("CCI.CCI#WEEK"(14)/10),COLORGREEN,LINETHICK2; IF(周C>周C AND 周C>REF(周C,5),周C,DRAWNULL),COLORRED,LINETHICK3;}; 周DIF:100*"MACD.DIF#WEEK"COLORGREEN; 周DEA:100*"MACD.DEA#WEEK",COLORCYAN,LINETHICK2; 别冲动反弹:周D…

作者头像 李华