Spring Boot-异步@Async

在Spring Boot中，@Async注解可以用来创建异步任务。这种方式可以帮助我们在处理一些耗时任务时，避免阻塞主线程，提高系统的处理效率。

解决方案1：

在Spring Boot中，我们可以通过在启动类上添加@EnableAsync注解来启用异步支持。然后在需要异步执行的方法上添加@Async注解。

@SpringBootApplication
@EnableAsync
public class DemoApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}
 
@Service
public class AsyncService {
 
    @Async
    public void asyncMethod() {
        System.out.println("执行异步任务：" + Thread.currentThread().getName());
    }
}

解决方案2：

在@Async注解的方法中，我们可以通过返回Future类型的对象来获取异步执行的结果。

@Service
public class AsyncService {
 
    @Async
    public Future<String> asyncMethod() {
        System.out.println("执行异步任务：" + Thread.currentThread().getName());
        return new AsyncResult<>("异步任务执行完毕");
    }
}
 
@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @GetMapping("/async")
    public String asyncMethod() throws ExecutionException, InterruptedException {
        Future<String> future = asyncService.asyncMethod();
        return future.get();
    }
}

解决方案3：

在@Async注解的方法中，我们可以通过抛出异常来处理异步执行中可能出现的错误。

@Service
public class AsyncService {
 
    @Async
    public void asyncMethod() {
        System.out.println("执行异步任务：" + Thread.currentThread().getName());
        int i = 10 / 0;
    }
}
 
@Service
public class AsyncService {
 
    @Async
    public void asyncMethod() {
        System.out.println("执行异步任务：" + Thread.currentThread().getName());
        int i = 10 / 0;
    }
 
    @Async
    public void asyncMethodWithException() {
        System.out.println("执行异步任务：" + Thread.currentThread().getName());
        throw new RuntimeException("异步任务执行失败");
    }
}

注意：在使用@Async注解时，如果异步方法中发生了异常，异常并不会被直接抛出到主线程中，因为异步方法返回的是Future类型的对象。我们可以通过Future对象的get方法来获取异常。

解决方案4：

在@Async注解的方法中，我们可以通过自定义线程池来执行异步任务。

@Configuration
public class AsyncConfig implements AsyncConfigurer {
 
    @Override
    @Bean
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(100);
        executor.setKeepAl