Async 注解原理分析
核心作用：Spring 提供的注解，标注在类或方法上，使方法在异步线程中执行，调用者无需等待方法完成即可继续执行后续逻辑。
使用两步走：
- 启动类添加
@EnableAsync，开启异步任务支持； - 需异步执行的方法 / 类上添加
@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. 确定异步执行器（线程池）
- 优先从缓存获取，或通过
@Async的value限定符查找自定义线程池； - 无自定义线程池时，默认使用
SimpleAsyncTaskExecutor（风险提示：每次创建新线程，无复用，高并发下易导致资源耗尽）。
2. 封装异步任务
- 将目标方法执行逻辑（
invocation.proceed()）封装为Callable任务； - 若方法返回
Future类型，会阻塞等待结果（处理异步嵌套调用），其他类型执行后返回null。
3. 提交异步任务
根据方法返回值类型选择提交方式：
CompletableFuture：用supplyAsync()提交；ListenableFuture：用submitListenable()提交；Future：直接submit()提交；void或其他类型：submit()提交后返回null。
总结
理解@Async原理的核心在于理解@EnableAsync注解，该注解开启了异步任务的功能。
主要流程如下图：
@Async 使用建议
必须自定义线程池
- 避免使用默认的
SimpleAsyncTaskExecutor，推荐ThreadPoolTaskExecutor； - 可配置核心线程数、最大线程数、队列容量等（示例：创建
executor1、executor2等不同线程池，通过@Async("executor1")指定）。
避免 @Async 注解实效
失效场景 | 原因 | 解决方案 |
同一类内调用异步方法 | 绕过 Spring 代理，未触发拦截 | 将异步方法移至另一个 Spring Bean |
异步方法用 | 代理无法拦截静态方法（不属于实例） | 用非静态包装方法调用静态逻辑 |
未加 | 未开启异步支持 | 启动类添加 |
方法所在类非 Spring Bean | Spring 无法创建代理 | 确保类被 |
规范返回值类型
- 无需结果：返回
void； - 需要结果：返回
Future子类（如CompletableFuture、ListenableFuture）； - 其他类型（如
String、Object）：无法获取方法执行结果。
处理异步方法异常
- 全局处理：实现
AsyncConfigurer重写getAsyncUncaughtExceptionHandler()，自定义异常处理器； - 局部处理：用
CompletableFuture的exceptionally()等方法捕获异常。
事务管理注意
- 异步方法需事务时，需添加
@Transactional(propagation = Propagation.REQUIRES_NEW)，开启独立新事务（避免与调用方事务关联）。
控制执行顺序
- 异步方法默认无序，需按顺序执行时，用
CompletableFuture的thenCompose()、thenAccept()等方法串联任务（如先执行fetchDataAsync，再执行processDataAsync）。