spring中的@Async注解详解

动态代理机制 Spring通过AOP（面向切面编程）为被@Async标记的方法生成代理对象。当调用异步方法时，代理对象将任务提交给TaskExecutor线程池执行。

• 代理类型：根据目标类是否实现接口，选择JDK动态代理或CGLIB代理。

• 拦截逻辑：AsyncExecutionInterceptor拦截方法调用，将任务提交至线程池。

线程池管理

• 默认线程池：使用SimpleAsyncTaskExecutor（每次调用创建新线程，不推荐生产环境使用）。

• 自定义线程池：通过ThreadPoolTaskExecutor配置核心线程数、队列容量等参数，避免资源耗尽问题。

条件触发 需在配置类添加@EnableAsync启用异步支持，否则注解无效。

典型场景

• 后台任务：邮件发送、日志记录、报表生成等耗时操作。

• 并行处理：批量数据处理、多服务并发调用。

基础用法

@Service
public class OrderService {
@Async // 无返回值异步方法
public void processOrderAsync(Order order) {
// 处理订单逻辑
}

@Async // 带返回值的异步方法
public Future<Report> generateReportAsync() {
return new AsyncResult<>(report);
}
}

返回值处理：

• 返回void：适用于无需获取结果的场景。

• 返回Future<T>或CompletableFuture<T>：用于异步获取执行结果或异常。

自定义线程池配置

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(50);
executor.setQueueCapacity(100);
executor.setThreadNamePrefix("CustomAsync-");
executor.initialize();
return executor;
}
}

• 推荐参数：根据业务负载设置corePoolSize（核心线程数）和queueCapacity（队列容量），避免任务堆积导致OOM。

注解失效场景

• 同类调用：在同一个类中通过this调用@Async方法，代理无法拦截（需通过依赖注入调用）。

• 非public方法：仅支持public或protected方法。

• 未启用异步支持：主配置类未添加@EnableAsync。

异常处理

• 未捕获异常：默认情况下异步方法抛出的异常不会传播到调用方。

• 解决方案：

  • 使用try-catch包裹异步方法体。

  • 实现AsyncUncaughtExceptionHandler接口全局处理异常。

事务失效 异步方法默认不继承调用方的事务上下文。若需事务支持：

• 在异步方法上添加@Transactional。

• 使用Propagation.REQUIRES_NEW传播级别。

上下文传递 异步线程默认不继承主线程的上下文（如SecurityContext）。可通过TaskDecorator复制上下文信息：

executor.setTaskDecorator(new ContextCopyingTaskDecorator());

组合注解优化 自定义注解（如@AsyncWithLogging）结合@Async与日志切面，实现异步任务的统一监控。

动态线程池选择 在@Async注解中指定线程池名称：

@Async("reportExecutor")
public void generateReport() { ... }