0
0

Spring 框架——@Async 注解

目录

1.同步调用与异步调用

在 Java 中，同步调用和异步调用是两种不同的操作方式，用于处理方法调用和任务执行。

1.1.同步调用

（1）定义：同步调用指的是调用方法时，调用者会等待被调用的方法执行完成后才继续执行后续的代码。也就是说，方法调用是阻塞的，当前线程会被阻塞直到方法执行结束并返回结果。

（2）示例：

publicclassSyncExample{publicstaticvoidmain(String[] args){System.out.println("Start");//同步调用String result =longRunningTask();System.out.println("Result: "+ result);System.out.println("End");}publicstaticStringlongRunningTask(){try{//模拟长时间运行的任务Thread.sleep(3000);}catch(InterruptedException e){
            e.printStackTrace();}return"Task Completed";}}

（3）解释：
在上述代码中，

longRunningTask()

方法会暂停当前线程 3 秒钟，然后返回结果。在 

main

方法中，

longRunningTask()

的调用是同步的，

System.out.println("Result: " + result);

会等待 

longRunningTask()

完成后才执行。

1.2.异步调用

（1）定义：异步调用指的是调用方法时，调用者不会等待方法执行完成，而是立即继续执行后续的代码。被调用的方法在后台线程中执行，调用者可以通过回调、Future 模式或其他机制获取结果。

（2）示例：

importjava.util.concurrent.CompletableFuture;publicclassAsyncExample{publicstaticvoidmain(String[] args){System.out.println("Start");//异步调用CompletableFuture<String> future =CompletableFuture.supplyAsync(()->longRunningTask());//继续执行其他操作System.out.println("Doing other work while waiting for result...");//获取异步任务的结果（会阻塞，直到任务完成）
        future.thenAccept(result ->System.out.println("Result: "+ result));System.out.println("End");}publicstaticStringlongRunningTask(){try{//模拟长时间运行的任务Thread.sleep(3000);}catch(InterruptedException e){
            e.printStackTrace();}return"Task Completed";}}

（3）解释：在上述代码中，

longRunningTask()

被异步执行，通过 

CompletableFuture.supplyAsync

方法。在异步执行期间，

System.out.println("Doing other work while waiting for result...");

会继续执行，不会被阻塞。

future.thenAccept(result -> System.out.println("Result: " + result));

会在任务完成后处理结果。

1.3.总结

  • 同步调用： - 特点：调用方在发起方法调用后，必须等待被调用的方法完成并返回结果之后，才能继续执行后续的操作（即会阻塞）。在同步调用中，调用方和被调用方的执行顺序是严格按照调用顺序进行的。- 适用场景： - 依赖顺序：当某个操作必须在另一个操作完成后才能进行时。- 简单任务：当任务执行时间短且没有并发问题时。- 确保执行顺序：需要确保多个步骤按顺序完成，比如数据库事务处理。
  • 异步调用： - 特点：调用方发起方法调用后，不必等待被调用的方法完成，而是可以继续执行后续的操作。被调用的方法将在后台线程中运行，完成后会通知调用方结果或执行回调。- 适用场景： - 任务需要较长时间完成，阻塞主线程会影响程序的响应性。- 需要处理多个任务时，通过异步调用可以提高并发处理能力。- 用户界面应用中，异步操作可以防止界面冻结，提升用户体验。

2.注解 @Async 介绍

@Async

注解中的 Async 是单词 

Asynchronous

的缩写。Asynchronous 指的是“异步的”，即操作或方法的执行不会阻塞当前线程，允许在后台执行任务的同时继续进行其他操作。使用 @Async 注解可以让 Spring 在后台线程池中异步执行被注解的方法，从而提升应用的性能和响应能力。

@Async

注解的代码如下所示：

packageorg.springframework.scheduling.annotation;importjava.lang.annotation.Documented;importjava.lang.annotation.ElementType;importjava.lang.annotation.Retention;importjava.lang.annotation.RetentionPolicy;importjava.lang.annotation.Target;importorg.springframework.aot.hint.annotation.Reflective;@Target({ElementType.TYPE,ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)@Documented@Reflectivepublic@interfaceAsync{Stringvalue()default"";}

@Async

注解用在方法和类上的作用分别如下：

2.1.用在方法上

（1）功能：标记方法为异步执行，这意味着方法将在一个新的线程中执行，不会阻塞调用该方法的线程。并且方法所在的类必须要被 Spring 作为 Bean 管理。
（2）限制：只对 

public

方法有效，且方法返回类型为 

void

或者 

Future

。
（3）例子：

@AsyncpublicCompletableFuture<String>asyncMethod(){// 执行异步任务}

2.2.用在类上

（1）功能：标记类中的所有 

public

方法都为异步执行。这个类必须要被 Spring 作为 Bean 管理，并且所有被 

@Async

注解的方法都会异步执行。
（2）限制：类上使用 @Async 不一定能保证类中所有方法都异步执行，特别是如果方法被类内部直接调用时，例如方法 

asyncMethod2

在同一类内直接调用方法 

asyncMethod1

，

asyncMethod1

会在当前线程中同步执行，而不是异步执行。
（3）例子：

@Async@ServicepublicclassMyService{publicCompletableFuture<String>asyncMethod1(){// 执行异步任务}publicCompletableFuture<String>asyncMethod2(){// 执行异步任务}}

3.使用演示

一般来说，

@Async

注解用在方法上来指定特定方法异步执行，标记整个类的方式较少使用。

3.1.在启动类或者配置类上增加 @EnableAsync 注解

例如，在 Spring Boot 项目的启动类上增加 @EnableAsync 注解：

@EnableAsync//开启异步调用@SpringBootApplicationpublicclassMyExampleApplication{publicstaticvoidmain(String[] args){SpringApplication.run(MyExampleApplication.class, args);}}

@EnableAsync 注解用于启用 Spring 框架的异步方法执行功能。它使得应用程序能够处理被 @Async 注解标记的方法，确保这些方法在独立的线程中异步执行。将 @EnableAsync 注解添加到配置类或者启动类上后，Spring 将自动配置所需的支持，并允许 @Async 注解在应用程序中生效。

3.2.在异步方法上增加 @Async 注解

packagecom.example.myexample.service.async;importlombok.extern.slf4j.Slf4j;importorg.springframework.scheduling.annotation.Async;importorg.springframework.stereotype.Service;@Slf4j@ServicepublicclassMyAsyncTask{@AsyncpublicvoidnotifyUser(){
        log.info("asyncTask 方法所处的线程：{}",Thread.currentThread().getName());//模拟处理异步任务try{Thread.sleep(3000);
            log.info("通知用户保存订单成功");}catch(InterruptedException e){thrownewRuntimeException(e);}}}

3.3.调用异步方法

packagecom.example.myexample.controller;importcom.example.myexample.service.OrderService;importorg.springframework.web.bind.annotation.PostMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;importjavax.annotation.Resource;@RestController@RequestMapping("asyncTest")publicclassAsyncTestController{@ResourceprivateOrderService orderService;@PostMappingpublicStringsaveOrder(){
        orderService.saveOrder();return"success";}}

packagecom.example.myexample.service;publicinterfaceOrderService{voidsaveOrder();}

packagecom.example.myexample.service.impl;importcom.example.myexample.service.OrderService;importcom.example.myexample.service.async.MyAsyncTask;importlombok.extern.slf4j.Slf4j;importorg.springframework.stereotype.Service;importjavax.annotation.Resource;@Slf4j@ServicepublicclassOrderServiceImplimplementsOrderService{@ResourceprivateMyAsyncTask myAsyncTask;@OverridepublicvoidsaveOrder(){
        log.info("saveOrder 方法所处的线程：{}",Thread.currentThread().getName());
        log.info("保存订单");//调用异步方法
        myAsyncTask.notifyUser();postProcess();}publicvoidpostProcess(){
        log.info("postProcess 方法所处的线程：{}",Thread.currentThread().getName());}}

上述代码只包括了调用异步方法的核心部分，其它部分代码（例如 Controller 层）并未给出。

3.4.测试

使用 Postman 进行测试：

http://localhost:8080/asyncTest/

在这里插入图片描述

日志打印结果如下，从中可以发现：方法 

saveOrder

和 

notifyUser

在不同的线程中执行了，即 

notifyUser

确实被异步调用了。

在这里插入图片描述

3.5.其它说明

如果要将异步方法改为有返回值，可以将返回类型从 

void

改为 

Future<T>

或 

CompletableFuture<T>

。这里我们使用 CompletableFuture 作为返回类型：

@AsyncpublicCompletableFuture<String>notifyUser2(){
    log.info("asyncTask 方法所处的线程：{}",Thread.currentThread().getName());// 模拟处理异步任务try{Thread.sleep(3000);
        log.info("通知用户保存订单成功");}catch(InterruptedException e){thrownewRuntimeException(e);}returnCompletableFuture.completedFuture("通知用户保存订单成功");}

publicvoidsaveOrder2(){
    log.info("saveOrder 方法所处的线程：{}",Thread.currentThread().getName());
    log.info("保存订单");CompletableFuture<String> future = myAsyncTask.notifyUser2();//在需要时可以调用 get() 来阻塞当前线程直到异步任务完成try{String result = future.get();// 这将阻塞直到异步任务完成System.out.println("任务结果: "+ result);}catch(Exception e){
        e.printStackTrace();}}

有关 Future 模式的相关知识可以参考 Java 并发编程面试题——Future 模式这篇文章。

4.注意事项

4.1.@Async 注解失效的常见情况

@Async

注解在某些情况下可能会失效，包括：

  • 方法定义不符合要求：@Async 方法必须是 public，并且不能是 final、static 或 private。
  • 类未被 Spring 扫描：确保含有 @Async 注解的类被 Spring 扫描到。通常需要将类放在 @Component、@Service 或其他 Spring 管理的组件中。
  • 缺少 @EnableAsync 注解：在配置类上未添加 @EnableAsync 注解，Spring 不会启用异步处理。
  • 方法调用在同一类内部：@Async 方法被同一类的其他方法调用时不会生效，因为 Spring 的代理机制无法处理同一类内的调用。
  • 返回值处理不当：异步方法通常返回 Future 或 void，确保返回值类型正确处理。

4.2.使用 @Async 注解可能会导致循环依赖

4.2.1.示例

需要注意的是，如果代码编写不当，在使用 

@Async

注解可能会导致循环依赖，例如：

@ServicepublicclassCDTestsService1ImplimplementsCDTestsService1{@AutowiredprivateCDTestsService2 cdTestsService2;@Async@OverridepublicvoidperformAsyncTask(){System.out.println("performAsyncTask...");}}

@ServicepublicclassCDTestsService2ImplimplementsCDTestsService2{@AutowiredprivateCDTestsService1 cdTestsService1;@OverridepublicvoidperformTask(){
        cdTestsService1.performAsyncTask();}}

@RestController@RequestMapping("asyncTest")publicclassAsyncTestController{@ResourceprivateCDTestsService2 cdTestsService2;@PostMapping("/cdTest")publicStringcdTest(){
        cdTestsService2.performTask();return"success";}}

当启动项目时，会出现循环依赖的异常提示：
在这里插入图片描述

4.2.2.原因分析

  • 循环依赖：- CDTestsService1Impl 依赖于 CDTestsService2Impl，并且 CDTestsService2Impl 依赖于 CDTestsService1Impl。这种相互依赖会导致 Spring 容器在创建这些 bean 时发生问题。- 当 Spring 容器创建 CDTestsService1Impl 时，它需要注入 CDTestsService2Impl。接着，创建 CDTestsService2Impl 时，它需要注入 CDTestsService1Impl。这样，就会形成一个死循环，因为两个 bean 互相等待对方被完全创建和注入。
  • @Async 注解的影响：- @Async 注解用于异步执行方法。这意味着 performAsyncTask 方法会在不同的线程中运行，因此不会阻塞当前线程。但是，Spring 在执行异步方法时，仍然需要确保异步方法的 bean 实例在调用之前已完全创建和注入。- 由于 performAsyncTask 是异步的，Spring 在调用这个方法时可能会遇到由于循环依赖未完全解决而引发的异常。

4.2.3.解决方案

（1）使用构造函数注入
使用构造函数注入可以避免循环依赖问题。构造函数注入在 bean 创建时确保所有依赖项都已解决，因此更可靠。

@ServicepublicclassCDTestsService1ImplimplementsCDTestsService1{privatefinalCDTestsService2 cdTestsService2;@AutowiredpublicCDTestsService1Impl(CDTestsService2 cdTestsService2){this.cdTestsService2 = cdTestsService2;}@Async@OverridepublicvoidperformAsyncTask(){System.out.println("performAsyncTask...");}}@ServicepublicclassCDTestsService2ImplimplementsCDTestsService2{privatefinalCDTestsService1 cdTestsService1;@AutowiredpublicCDTestsService2Impl(CDTestsService1 cdTestsService1){this.cdTestsService1 = cdTestsService1;}@OverridepublicvoidperformTask(){
        cdTestsService1.performAsyncTask();}}

（2）使用 @Lazy 注解

@Lazy

注解可以推迟 bean 的初始化，解决循环依赖问题。你可以将 

@Lazy

注解添加到字段注入中，以便在需要时才加载依赖。

@ServicepublicclassCDTestsService1ImplimplementsCDTestsService1{@Autowired@LazyprivateCDTestsService2 cdTestsService2;@Async@OverridepublicvoidperformAsyncTask(){System.out.println("performAsyncTask...");}}@ServicepublicclassCDTestsService2ImplimplementsCDTestsService2{@Autowired@LazyprivateCDTestsService1 cdTestsService1;@OverridepublicvoidperformTask(){
        cdTestsService1.performAsyncTask();}}

（3）分离异步调用
如果 

performAsyncTask

不需要立即执行，考虑将它移到另一个服务中，或通过其他机制避免直接的循环依赖。

@ServicepublicclassCDTestsService1ImplimplementsCDTestsService1{@AutowiredprivateTaskExecutor taskExecutor;// Spring 提供的 TaskExecutor@OverridepublicvoidperformAsyncTask(){
        taskExecutor.execute(()->{System.out.println("performAsyncTask...");});}}@ServicepublicclassCDTestsService2ImplimplementsCDTestsService2{@AutowiredprivateCDTestsService1 cdTestsService1;@OverridepublicvoidperformTask(){
        cdTestsService1.performAsyncTask();}}

使用 

TaskExecutor

来执行异步任务可以将异步执行的逻辑与服务依赖解耦，避免直接在服务之间形成循环依赖。

标签： spring java Async
本文转载自: https://blog.csdn.net/weixin_43004044/article/details/141754812
版权归原作者 代码星辰 所有， 如有侵权，请联系我们删除。
登录后发布评论

“Spring 框架——@Async 注解”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

Prometheus安装部署

[开源]27.8K star！这款 Postman 替代工具太火了！

推荐几个 VSCode 流程图工具

【Git使用】一篇文章教会你在idea中上传代码到Github仓库

毕业设计项目 大数据共享单车数据分析与可视化(源码分享)

大数据技术之SparkCore

使用PHPExcel库实现PHP读写Excel文件

文章导航