首页 > 资讯 > 后端开发 > Python >详解springboot使用异步注解@Async获取执行结果的坑

863

分享到

详解springboot使用异步注解@Async获取执行结果的坑

2024-04-02 19:04:59 863人浏览薄情痞子

Python 官方文档：入门教程 => 点击学习

摘要

目录一、引言二、获取异步执行结果 1、环境介绍 2、错误的方式 3、正确方式三、异步执行@Async注解四、总结一、引言在java后端开发中经常会碰到处理多个任务的情况，

一、引言

在java后端开发中经常会碰到处理多个任务的情况，比如一个方法中要调用多个请求，然后把多个请求的结果合并后统一返回，一般情况下调用其他的请求一般都是同步的，也就是每个请求都是阻塞的，那么这个处理时间必定是很长的，有没有一种方法可以让多个请求异步处理那，答案是有的。

SpringBoot中提供了很便利的方式可以解决上面的问题，那就是异步注解@Async。正确的使用该注解可以使你的程序飞起，相反如果使用不当那么并不会取到理想的效果。

二、获取异步执行结果

1、环境介绍

下面是我的controller，SyncController.java


package com.atssg.controller;

import com.atssg.service.MySyncService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.WEB.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;


@Slf4j
@RestController
@RequestMapping("/sync")
public class SyncController {
    @Autowired
    private MySyncService syncService;

    @GetMapping(value = "/test")

    public String test() {
        String str=null;
        try {

            log.info("start");
            str = syncService.asyncMethod();
            log.info("str:{}", str);
            return str;
        } catch (Exception e) {
            e.printStackTrace();
        }

        return str;
    }
}

在controller中就是调用下层的方法并返回，再看service层的类MySyncService.java


package com.atssg.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

@Service
public class MySyncService {
    @Autowired
    private SyncService syncService;

    
    public String asyncMethod() throws InterruptedException, ExecutionException {

        Future<String> result1 = syncService.method1("I");
        Future<String> result2 = syncService.method2("love");
        Future<String> result3 = syncService.method3("async");

        String str = result1.get();
        String str2 = result2.get();
        String str3 = result3.get();

        String result = str + str2 + str3;

        return result;
    }

    
    public String syncMethod() throws InterruptedException, ExecutionException {
        
        String str = syncService.method1("I").get();
        String str2 = syncService.method2("love").get();
        String str3 = syncService.method3("async").get();
        return str + str2 + str3;
    }
}

上面便是service类，仅仅是调用下次异步层的方法，并取得返回值。上面类中有两个方法，其写法也类似但结果却大不相同，后面详说。

下面是异步层的方法，SyncService.java


package com.atssg.service;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Service;

import java.util.concurrent.Future;

@Service
@Async
public class SyncService {

    //@Async
    public Future<String> method1(String str) throws InterruptedException {
       Thread.sleep(1000*10);
        return new AsyncResult<>( str);
    }
    //@Async
    public Future<String> method2(String str) throws InterruptedException {
        Thread.sleep(1000*5);
        return new AsyncResult<>(str);
    }
   // @Async
    public Future<String> method3(String str) throws InterruptedException {
        Thread.sleep(1000*15);
        return new AsyncResult<>(str);
    }
}

该类使用@Async注解，表明该类中所有的方法都是异步执行的，其中@Async可修饰类也可以修饰方法。

这便是所有的环境。

2、错误的方式

在MySyncService中有两个方法，先看其中一个方法


public String syncMethod() throws InterruptedException, ExecutionException {
        
        String str = syncService.method1("I").get();
        String str2 = syncService.method2("love").get();
        String str3 = syncService.method3("async").get();
        return str + str2 + str3;
    }

这种写法是调用异步方法后立即调用get()方法，即获取结果，下面看测试结果，在controllor中调用该方法，下面看执行结果

2021-08-21 11:06:28.612 INFO 3584 --- [NIO-8080-exec-1] com.atssg.controller.SyncController : start
2021-08-21 11:06:58.651 INFO 3584 --- [nio-8080-exec-1] com.atssg.controller.SyncController : str:Iloveasync

可以看到共执行了30s，在异步层的方法中的三个方法如下，


//@Async
    public Future<String> method1(String str) throws InterruptedException {
       Thread.sleep(1000*10);
        return new AsyncResult<>( str);
    }
    //@Async
    public Future<String> method2(String str) throws InterruptedException {
        Thread.sleep(1000*5);
        return new AsyncResult<>(str);
    }
   // @Async
    public Future<String> method3(String str) throws InterruptedException {
        Thread.sleep(1000*15);
        return new AsyncResult<>(str);
    }

可以看到这三个方法分别是睡眠10s、5s、15s，这就很好理解了syncMethod()方法中的写法是同步的，未达到异步的目的，切记调用完异步方法进接着调用get()方法不是异步的方式，而是同步的。

3、正确方式

上面看了错误的用法，下面看正确的方式，


 public String asyncMethod() throws InterruptedException, ExecutionException {

        Future<String> result1 = syncService.method1("I");
        Future<String> result2 = syncService.method2("love");
        Future<String> result3 = syncService.method3("async");

        String str = result1.get();
        String str2 = result2.get();
        String str3 = result3.get();

        String result = str + str2 + str3;

        return result;
    }

这种方式是首先调用异步方法，然后分别调用get()方法，取得执行结果。下面看测试结果

2021-08-21 11:17:23.516 INFO 3248 --- [nio-8080-exec-1] com.atssg.controller.SyncController : start
2021-08-21 11:17:38.535 INFO 3248 --- [nio-8080-exec-1] com.atssg.controller.SyncController : str:Iloveasync

执行时间未15s，这就很好解释了，异步层的三个方法，分别睡眠的时间是10s、5s、15s，既然是异步执行的，那么总的执行时间肯定是三个方法中最长的那个，符合测试结果。这才@Async正确的打开姿势。

三、异步执行@Async注解

@Async注解的定义如下，


@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Async {
    String value() default "";
}

可以看到该注解可以用在类及方法上，用在类上表示类中的所有方法都是异步的，用在方法上表示该方法是异步的。

四、总结

今天的文章分享到这里，主要分享了关于@Async注解在获取执行结果的时候的坑，一定要先调用异步方法，然后再调用get()方法，获取结果，其中get方法还有一个重载的，可以设置超时时间，即超过设置的超时时间便返回，不再等待，各位小伙伴可以自己试验。


 V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

下次继续分享有关@Async注解使用的一些小细节，欢迎持续关注。

到此这篇关于详解springboot使用异步注解@Async获取执行结果的坑的文章就介绍到这了,更多相关springboot使用异步注解@Async 内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:

--结束END--

本文标题: 详解springboot使用异步注解@Async获取执行结果的坑

本文链接: https://lsjlt.com/news/133228.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

回答

如何调试操作系统的错误？
操作系统

2023-11-15发布

回答

操作系统中的I/O系统是如何实现的？
操作系统

2023-11-15发布

回答

如何实现操作系统的内存管理？
操作系统

2023-11-15发布

回答

什么是虚拟内存，它对操作系统有什么影响？
操作系统

2023-11-15发布

回答

ASP中的MVC架构和WebForms架构有什么区别和使用场景？
ASP.NET

2023-11-15发布

回答

ASP中的数据验证和数据校验有什么不同？
ASP.NET

2023-11-15发布

回答

ASP中的ADO对象和DAO对象有什么区别和使用方法？
ASP.NET

2023-11-15发布

回答

Node.js中的包管理器NPM是什么？如何使用它进行依赖管理？
node.js

2023-11-15发布

回答

Vue.js中的动态组件是什么？如何使用它来动态渲染组件？
VUE

2023-11-15发布

回答

如何使用Vue.js实现懒加载和预加载？
VUE

2023-11-15发布

详解springboot使用异步注解@Async获取执行结果的坑

目录

一、引言

二、获取异步执行结果

1、环境介绍

2、错误的方式

3、正确方式

三、异步执行@Async注解

四、总结

详解springboot使用异步注解@Async获取执行结果的坑

使用多线程执行任务，并获取返回结果，附异步实现

spring的异步执行使用与源码详解

详解springboot通过Async注解实现异步任务及回调的方法

Springboot利用Aop捕捉注解实现业务异步执行

SpringBoot使用Async注解失效原因分析及解决(spring异步回调)

SpringBoot异步使用@Async的原理以及线程池配置详解

Springboot怎么用Aop捕捉注解实现业务异步执行

spring boot使用@Async异步注解的实现原理+源码

spring boot使用@Async注解解决异步多线程入库的问题

SpringMVC执行步骤、Model的使用详解

Springboot任务之异步任务的使用详解

使用python的subprocess执行命令、交互、等待、是否结束、解析JSON结果

使用 os/exec 和在命令行执行之间出现令人费解的不同结果

python分析数据的方法是什么

如何使用Python实现抽奖小程序

python copy函数的作用是什么

python ffmpeg模块怎么安装和使用

python进程池创建队列的方法是什么

python无法运行文件的原因有哪些

python can't open file报错怎么解决

python keyerror错误怎么解决

python字符串处理与应用的方法有哪些

python全局变量如何定义