Spring Boot中的@Async注解用于创建异步行为，允许方法在不阻塞调用线程的情况下执行。
@Async的使用
- 在Spring Boot主类或配置类中启用异步支持：
@EnableAsync
@SpringBootApplication
public class MyApp {
public static void main(String[] args) {
SpringApplication.run(MyApp.class, args);
}
}
- 在服务类中使用@Async注解：
@Service
public class AsyncService {
@Async
public Future<String> executeAsyncTask() {
// 模拟长时间运行的任务
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return new AsyncResult<>("任务完成");
}
}
- 调用异步方法：
@RestController
public class AsyncController {
@Autowired
private AsyncService asyncService;
@GetMapping("/async")
public String asyncMethod() throws ExecutionException, InterruptedException {
Future<String> future = asyncService.executeAsyncTask();
return future.get(); // 异步方法将在这里被调用，而不会阻塞主线程
}
}
@Async的原理
Spring通过使用Java的Executor框架为@Async注解提供支持。Spring自动配置一个线程池来处理异步方法的执行。
自定义线程池
可以通过创建配置类并定义一个Executor的Bean来自定义线程池：
@Configuration
public class AsyncConfig implements AsyncConfigurer {
@Override
@Bean
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5); // 核心线程数
executor.setMaxPoolSize(10); // 最大线程数
executor.setQueueCapacity(25); // 队列大小
executor.initialize();
return executor;
}
}
在这个配置类中，我们定义了一个ThreadPoolTaskExecutor，并设置了线程池的参数，如核心线程数、最大线程数和队列大小。然后通过executor.initialize()初始化线程池。
在服务类中使用自定义线程池：
@Service
public class AsyncServiceWithCustomThreadPool {
private final Executor executor;
@Autowired
public AsyncServiceWithCustomThreadPool(Executor executor) {
this.executor = executor;
}
@Async
public void executeAsyncTaskWithCustomThreadPool() {
// 异步任务的逻辑
}
}
在这个例子中，我们注入了Executor Bean，并在异步方法中使用它。
注意事项
- 确保在启动类上使用@EnableAsync注解来启用异步支持。
- 异步方法应该返回Future或其子类型，如Future<T>，