Spring 框架——@Async 注解

server/2024/9/24 13:22:53/

目录

  • 1.同步调用与异步调用
    • 1.1.同步调用
    • 1.2.异步调用
    • 1.3.总结
  • 2.注解 @Async 介绍
    • 2.1.用在方法上
    • 2.2.用在类上
  • 3.使用演示
    • 3.1.在启动类或者配置类上增加 @EnableAsync 注解
    • 3.2.在异步方法上增加 @Async 注解
    • 3.3.调用异步方法
    • 3.4.测试
    • 3.5.其它说明
  • 4.注意事项
    • 4.1.@Async 注解失效的常见情况
    • 4.2.使用 @Async 注解可能会导致循环依赖
      • 4.2.1.示例
      • 4.2.2.原因分析
      • 4.2.3.解决方案

1.同步调用与异步调用

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

1.1.同步调用

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

（2）示例：

java">public class SyncExample {public static void main(String[] args) {System.out.println("Start");//同步调用String result = longRunningTask();System.out.println("Result: " + result);System.out.println("End");}public static String longRunningTask() {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）示例：

java">import java.util.concurrent.CompletableFuture;public class AsyncExample {public static void main(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");}public static String longRunningTask() {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.总结

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

Async__80">2.注解 @Async 介绍

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

java">package org.springframework.scheduling.annotation;import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.aot.hint.annotation.Reflective;@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Reflective
public @interface Async {String value() default "";
}

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

2.1.用在方法上

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

java">@Async
public CompletableFuture<String> asyncMethod() {// 执行异步任务
}

2.2.用在类上

（1）功能：标记类中的所有 public 方法都为异步执行。这个类必须要被 Spring 作为 Bean 管理，并且所有被 @Async 注解的方法都会异步执行。
（2）限制：类上使用 @Async 不一定能保证类中所有方法都异步执行，特别是如果方法被类内部直接调用时，例如方法 asyncMethod2 在同一类内直接调用方法 asyncMethod1，asyncMethod1 会在当前线程中同步执行，而不是异步执行。
（3）例子：

java">@Async
@Service
public class MyService {public CompletableFuture<String> asyncMethod1() {// 执行异步任务}public CompletableFuture<String> asyncMethod2() {// 执行异步任务}
}

3.使用演示

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

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

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

java">@EnableAsync	//开启异步调用
@SpringBootApplication
public class MyExampleApplication {public static void main(String[] args) {SpringApplication.run(MyExampleApplication.class, args);}}

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

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

java">package com.example.myexample.service.async;import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;@Slf4j
@Service
public class MyAsyncTask {@Asyncpublic void notifyUser() {log.info("asyncTask 方法所处的线程：{}", Thread.currentThread().getName());//模拟处理异步任务try {Thread.sleep(3000);log.info("通知用户保存订单成功");} catch (InterruptedException e) {throw new RuntimeException(e);}}
}

3.3.调用异步方法

java">package com.example.myexample.controller;import com.example.myexample.service.OrderService;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;@RestController
@RequestMapping("asyncTest")
public class AsyncTestController {@Resourceprivate OrderService orderService;@PostMappingpublic String saveOrder() {orderService.saveOrder();return "success";}
}

java">package com.example.myexample.service;public interface OrderService {void saveOrder();
}

java">package com.example.myexample.service.impl;import com.example.myexample.service.OrderService;
import com.example.myexample.service.async.MyAsyncTask;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;import javax.annotation.Resource;@Slf4j
@Service
public class OrderServiceImpl implements OrderService {@Resourceprivate MyAsyncTask myAsyncTask;@Overridepublic void saveOrder() {log.info("saveOrder 方法所处的线程：{}", Thread.currentThread().getName());log.info("保存订单");//调用异步方法myAsyncTask.notifyUser();postProcess();}public void postProcess() {log.info("postProcess 方法所处的线程：{}", Thread.currentThread().getName());}
}

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

3.4.测试

使用 Postman 进行测试：

java">http://localhost:8080/asyncTest/

在这里插入图片描述

日志打印结果如下，从中可以发现：方法 saveOrder 和 notifyUser 在不同的线程中执行了，即 notifyUser 确实被异步调用了。

在这里插入图片描述

3.5.其它说明

如果要将异步方法改为有返回值，可以将返回类型从 void 改为 Future<T> 或 CompletableFuture<T>。这里我们使用 CompletableFuture 作为返回类型：

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

java">public void saveOrder2() {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.注意事项

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

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

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

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

4.2.1.示例

需要注意的是，如果代码编写不当，在使用 @Async 注解可能会导致循环依赖，例如：

java">@Service
public class CDTestsService1Impl implements CDTestsService1 {@Autowiredprivate CDTestsService2 cdTestsService2;@Async@Overridepublic void performAsyncTask() {System.out.println("performAsyncTask...");}
}

java">@Service
public class CDTestsService2Impl implements CDTestsService2 {@Autowiredprivate CDTestsService1 cdTestsService1;@Overridepublic void performTask() {cdTestsService1.performAsyncTask();}
}

java">@RestController
@RequestMapping("asyncTest")
public class AsyncTestController {@Resourceprivate CDTestsService2 cdTestsService2;@PostMapping("/cdTest")public String cdTest() {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 创建时确保所有依赖项都已解决，因此更可靠。

java">@Service
public class CDTestsService1Impl implements CDTestsService1 {private final CDTestsService2 cdTestsService2;@Autowiredpublic CDTestsService1Impl(CDTestsService2 cdTestsService2) {this.cdTestsService2 = cdTestsService2;}@Async@Overridepublic void performAsyncTask() {System.out.println("performAsyncTask...");}
}@Service
public class CDTestsService2Impl implements CDTestsService2 {private final CDTestsService1 cdTestsService1;@Autowiredpublic CDTestsService2Impl(CDTestsService1 cdTestsService1) {this.cdTestsService1 = cdTestsService1;}@Overridepublic void performTask() {cdTestsService1.performAsyncTask();}
}

（2）使用 @Lazy 注解
@Lazy 注解可以推迟 bean 的初始化，解决循环依赖问题。你可以将 @Lazy 注解添加到字段注入中，以便在需要时才加载依赖。

java">@Service
public class CDTestsService1Impl implements CDTestsService1 {@Autowired@Lazyprivate CDTestsService2 cdTestsService2;@Async@Overridepublic void performAsyncTask() {System.out.println("performAsyncTask...");}
}@Service
public class CDTestsService2Impl implements CDTestsService2 {@Autowired@Lazyprivate CDTestsService1 cdTestsService1;@Overridepublic void performTask() {cdTestsService1.performAsyncTask();}
}

（3）分离异步调用
如果 performAsyncTask 不需要立即执行，考虑将它移到另一个服务中，或通过其他机制避免直接的循环依赖。

java">@Service
public class CDTestsService1Impl implements CDTestsService1 {@Autowiredprivate TaskExecutor taskExecutor;  // Spring 提供的 TaskExecutor@Overridepublic void performAsyncTask() {taskExecutor.execute(() -> {System.out.println("performAsyncTask...");});}
}@Service
public class CDTestsService2Impl implements CDTestsService2 {@Autowiredprivate CDTestsService1 cdTestsService1;@Overridepublic void performTask() {cdTestsService1.performAsyncTask();}
}

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


http://www.ppmy.cn/server/119119.html

相关文章

linux设置常见开机自启动命令

linux设置常见开机自启动命令

本文介绍了三种开机自启的方式&#xff0c;重点介绍使用systemctl的方式自启动的 方式一、修改 /etc/rc.d/rc.local 文件 /etc/rc.d/rc.local 文件会在 Linux 系统各项服务都启动完毕之后再被运行。所以你想要自己的脚本在开机后被运行的话&#xff0c;可以将自己脚本路径加到…
阅读更多...
滚雪球学SpringCloud[5.2讲]： 配置的动态刷新与安全管理

滚雪球学SpringCloud[5.2讲]： 配置的动态刷新与安全管理

全文目录&#xff1a; 前言5.2 配置的动态刷新与安全管理使用Spring Cloud Bus实现动态刷新动态刷新在多种场景中的应用Spring Cloud Bus的工作机制与架构分析核心架构&#xff1a; 示例&#xff1a;Spring Cloud Bus动态刷新配置1. 引入依赖2. 配置RabbitMQ3. 启用Bus功能4. 触…
阅读更多...
2023年全国研究生数学建模竞赛华为杯C题大规模创新类竞赛评审方案研究求解全过程文档及程序

2023年全国研究生数学建模竞赛华为杯C题大规模创新类竞赛评审方案研究求解全过程文档及程序

2023年全国研究生数学建模竞赛华为杯 C题 大规模创新类竞赛评审方案研究 原题再现&#xff1a; 现在创新类竞赛很多&#xff0c;其中规模较大的竞赛&#xff0c;一般采用两阶段&#xff08;网评、现场评审&#xff09;或三阶段&#xff08;网评、现场评审和答辩&#xff09;评…
阅读更多...
2020ICPC上海 D - Walker M - Gitignore

2020ICPC上海 D - Walker M - Gitignore

D: 首先显然要二分,判断当前二分的mid时间下是否能满足走满0~n 枚举所有情况,这里按照左,右起点p1,p2分别讨论 p1向左 p2向左(以下向左和向右都代表向左或者向右到墙,而不代表初速度方向)&#xff0c;只需要计算p1或者p2反弹之后还能走距离n就是合法 p1向左 p2向右&#xff…
阅读更多...
深度学习常见面试题及答案（1~5）

深度学习常见面试题及答案（1~5）

文章目录 1. 请简述深度学习中的反向传播算法的基本原理和作用。一、基本原理二、作用 2. 解释一下循环神经网络&#xff08;RNN&#xff09;的工作原理&#xff0c;以及它在处理序列数据时的优势和局限性是什么&#xff1f;一、循环神经网络&#xff08;RNN&#xff09;的工作…
阅读更多...
【Linux下的cpp】编译调试（gcc、g++、gdb）

【Linux下的cpp】编译调试（gcc、g++、gdb）

【Linux下的cpp】编译调试&#xff08;gcc、g、gdb&#xff09; 文章目录 【Linux下的cpp】编译调试&#xff08;gcc、g、gdb&#xff09;简述gcc、g、gdb编译过程g 编译参数命令行编译演练1、直接编译2、生成库文件并编译链接静态库并生成可执行文件链接动态库生成可执行文件 …
阅读更多...
【sgCreateCallAPIFunction】自定义小工具：敏捷开发→调用接口方法代码生成工具

【sgCreateCallAPIFunction】自定义小工具：敏捷开发→调用接口方法代码生成工具

<template><div :class"$options.name" class"sgDevTool"><sgHead /><div class"sg-container"><div class"sg-start"><div style"margin-bottom: 10px">调用接口方法定义列表</div…
阅读更多...
基于深度学习的零售柜商品识别系统实战思路

基于深度学习的零售柜商品识别系统实战思路

1. 了解我们要构建的系统 在开始编码之前&#xff0c;我们先了解一下我们要构建的系统&#xff1a; 目标&#xff1a;创建一个能够识别零售商品的计算机视觉系统核心技术&#xff1a;深度学习&#xff0c;特别是YOLOv5物体检测算法功能&#xff1a; 上传图片并识别其中的商品…
阅读更多...
最新文章

Copyright @ 2022~2023