一、什么是@Async注解？
@Async注解是Spring框架提供的一种用于声明异步方法的工具。它可以将标注的方法从调用者的线程中分离出来，另起一个新线程执行，从而避免阻塞调用者的线程，提高系统的并发能力和响应速度。
基本使用方法如下：
@Service
public class AsyncService {
@Async
public void asyncMethod() {
// 异步任务逻辑
}
}
在上述例子中，asyncMethod方法将在一个独立的线程中执行，不会阻塞调用它的主线程。
二、为什么会产生“坑”？
尽管@Async注解使用起来十分简单，但其背后的机制却涉及Spring的AOP（面向切面编程）和代理模式。这些机制在实际应用中容易导致一些意想不到的问题，即所谓的“坑”。这些“坑”通常源于对@Async注解的使用限制和Spring代理机制的不完全理解。
三、常见的“坑”及其规避方法
1. @Async只能作用于public方法
问题：@Async注解只对public方法有效，如果注解在private、protected或包级私有的方法上，将不会生效。
原因：这是因为Spring使用代理对象来处理异步调用，而代理对象只能代理public方法。
规避方法：确保所有标注@Async注解的方法是public的。
2. 自调用问题
问题：如果一个类中调用自身的异步方法，@Async注解将不会生效。
原因：这是因为Spring的代理机制，只有通过代理对象调用时注解才生效，而类内部的自调用不会经过代理对象。
规避方法：通过注入自身的代理对象来调用异步方法。
@Service
public class AsyncService {
@Autowired
private AsyncService selfProxy;
public void callerMethod() {
selfProxy.asyncMethod();
}
@Async
public void asyncMethod() {
// 异步任务逻辑
}
}
3. 配置线程池
问题：默认情况下，SpringBoot会使用一个简单的SimpleAsyncTaskExecutor，这个执行器不是真正的线程池，可能会导致性能问题。
原因：SimpleAsyncTaskExecutor每次调用时都会创建一个新线程，没有线程重用机制，可能导致大量线程创建和销毁的开销。
规避方法：自定义线程池并在@EnableAsync注解中指定。
@Configuration
@EnableAsync
public class AsyncConfig {
@Bean(name = "taskExecutor")
public Executor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(5);
executor.setQueueCapacity(500);
executor.setThreadNamePrefix("AsyncThread-");
executor.initialize();
return executor;
}
}
然后在使用@Async注解时指定这个线程池：
@Service
public class AsyncService {
@Async("taskExecutor")
public void asyncMethod() {
// 异步任务逻辑
}
}
4. 异步方法中的异常处理
问题：异步方法抛出的异常不会被直接捕获到，需要额外处理。
原因：异步方法在独立线程中执行，异常不会自动传递到调用线程。
规避方法：使用AsyncUncaughtExceptionHandler处理未捕获的异常。
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor.setMaxPoolSize(5);
executor.setQueueCapacity(500);
executor.setThreadNamePrefix("AsyncThread-");
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new CustomAsyncExceptionHandler();
}
}
public class CustomAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
@Override
public void handleUncaughtException(Throwable throwable, Method method, Object... obj) {
System.out.println("Exception message - " + throwable.getMessage());
System.out.println("Method name - " + method.getName());
for (Object param : obj) {
System.out.println("Parameter value - " + param);
}
}
}
5. 返回类型为Future
问题：如果异步方法的返回类型是Future或其子类，需要正确处理其结果。
原因：异步方法返回的Future对象需要调用get()方法获取结果，同时需要处理可能的异常。
规避方法：正确使用Future接口，处理异常并获取结果。
@Async
public Future<String> asyncMethodWithReturn() {
// 异步任务逻辑
return new AsyncResult<>("Result");
}
public void callerMethod() {
Future<String> future = asyncMethodWithReturn();
try {
String result = future.get();
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
四、总结
SpringBoot的@Async注解为异步编程提供了极大的便利，但在使用时必须注意其背后的代理机制和具体实现细节。通过了解和规避上述常见的“坑”，开发者可以更高效地利用@Async注解，提高应用的并发性能和响应速度。在实际项目中，结合具体需求和环境，合理配置和使用异步任务，才能真正发挥其优势。
欢迎大家积极留言交流学习心得，点赞的人最美丽！
