快速入门

启用异步支持

在 Spring Boot 应用中，首先需要在配置类上添加 @EnableAsync 注解来开启异步功能：

@Configuration

@EnableAsync

public class AsyncConfig {

// 可在此自定义线程池

}

标记异步方法

在需要异步执行的方法上添加 @Async 注解：

@Service

public class NotificationService {

// 无返回值的异步方法

@Async

public void sendEmail(String email) {

// 模拟耗时操作

try {

Thread.sleep(3000);

System.out.println("邮件已发送至: " + email);

} catch (InterruptedException e) {

Thread.currentThread().interrupt();

}

}

// 有返回值的异步方法

@Async

public Future processData(String input) {

try {

Thread.sleep(2000);

String result = "处理结果: " + input.toUpperCase();

return new AsyncResult<>(result);

} catch (InterruptedException e) {

return new AsyncResult<>("处理失败");

}

}

}

调用异步方法

@RestController

public class DemoController {

@Autowired

private NotificationService notificationService;

@GetMapping("/send")

public String sendEmail() {

notificationService.sendEmail("user@example.com");

return "请求已接受，处理中...";

}

@GetMapping("/process")

public String processData() throws Exception {

Future future = notificationService.processData("hello");

// 执行其他任务...

String result = future.get(); // 阻塞获取结果

return result;

}

}

实现原理

核心机制：AOP 与代理模式

Spring 的 @Async 功能基于 AOP（面向切面编程）和代理模式实现：

启用阶段：@EnableAsync 导入配置，注册 AsyncAnnotationBeanPostProcessor

处理阶段：后处理器检查 Bean 方法上的 @Async 注解，并创建代理对象

执行阶段：代理对象拦截方法调用，将执行提交给 TaskExecutor

源码解析

核心拦截器 AnnotationAsyncExecutionInterceptor 的 invoke 方法：

public Object invoke(final MethodInvocation invocation) throws Throwable {

// 确定使用的执行器

Executor executor = getExecutor(this.beanFactory, invocation.getMethod());

// 将方法调用封装为 Callable 任务

Callable