Springboot中@Async异步,实现异步结果合并统一返回方式

 更新时间:2023年09月27日 08:55:36   作者:Yang疯狂打码中  
这篇文章主要介绍了Springboot中@Async异步,实现异步结果合并统一返回方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

@Async异步,实现异步结果合并统一返回

本文是为了实现在SpringBoot中使用@Async异步时,将所有异步返回的结果合并。

举例

如果我们想拉取三个数据,每个数据拉取时间是2秒钟,想将结果统一返回给前端,以往我们都是这么做

    @Override
    public SysUser getUserA() throws InterruptedException {
        System.out.println("A线程:"+Thread.currentThread().getId());
        SysUser sysUser = new SysUser();
        sysUser.setUserName("A用户");
        Thread.sleep(2000L);
        System.out.println("A 拉取成功");
        return sysUser;
    }
    @Override
    public SysUser getUserB() throws InterruptedException {
        System.out.println("B线程:"+Thread.currentThread().getId());
        SysUser sysUser = new SysUser();
        sysUser.setUserName("B用户");
        Thread.sleep(2000L);
        System.out.println("B 拉取成功");
        return sysUser;
    }
    @Override
    public SysUser getUserC() throws InterruptedException {
        System.out.println("C线程:"+Thread.currentThread().getId());
        SysUser sysUser = new SysUser();
        sysUser.setUserName("C用户");
        Thread.sleep(2000L);
        System.out.println("C 拉取成功");
        return sysUser;
    }

执行拉取测试

    @Test
    public void testAsync() throws Exception{
        System.out.println(new Date());
        SysUser a = sysUserService.getUserA();
        SysUser b = sysUserService.getUserB();
        SysUser c = sysUserService.getUserC();
        List<SysUser> list = new ArrayList<>(Arrays.asList(a,b,c));
        list.forEach(user->{
            System.out.println(user.getUserName());
        });
        System.out.println(new Date());
    }

结果:共耗时6秒(一个结果2秒)

如果我们有个需求 ,这三个数据一起返回给前端不能超过5秒,这种情形我们就会使用到异步,

问题

但是如果使用异步,主线程不会等待异步线程返回,会直接执行之后代码返回前端(如下图),前端接收到的就是null

解决

如果我们想达到异步的结果统一返回,就需要使用到CompletableFuture

注:使用@Async时,需要@EnableAsync开启异步,调用@Async的方法不能与@Async所在同一个类中

执行测试:等待异步返回,并收集结果,使用.get获取返回值

结果:可以看出每个方法都是异步并行,2秒就即可返回三个合并后的结果

当前执行流程

为什么耗时是2秒:

CompletableFuture.allOf(a,b,c).join();

我们这里 allOf 传递了 三个 异步线程的返回值, 所以看到上图,也就出现了三个等待返回值的坑位 A B C。

可以把这个想象成一辆车,三个位, 必须人满才发车。

那么要等多久呢?

这三个人几乎是同时走向这辆车的,但是无论其他人走多快,因为得整整齐齐,所以耗时取决于这三个坑位,最慢上车的那个人。

如果我把其中一个B线程改为10秒

结果:可以看出B线程拉取的最慢,并且总耗时为10秒

 

注意:

其实,只要你使用到了  返回接收值CompletableFuture ,其实就已经开始触发,并不是一定要用allOf。 

例如:如果我们在使用CompletableFuture时,在异步中途使用到返回值,那么主线程会等待这个异步线程返回

结果:可以看出主线程一直在等待B线程的返回结果,等待10秒后才继续直接线程C

心得:只要调用了get(),主线程就会等待异步线程结果的返回

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • SpringBoot实现PPT格式文件上传并在线预览功能

    SpringBoot实现PPT格式文件上传并在线预览功能

    本文介绍SpringBoot实现PPT格式文件上传并在线预览功能,通过上传接口,可在C盘的tempfile目录下找到上传的文件,预览时会在同级目录下创建一个相同文件名后缀为pdf的文件,每次预览会先查找文件是否存在,存在则直接预览,不存在则会走上面的处理,需要的朋友可以参考下
    2022-02-02
  • Spring MVC各种参数进行封装的方法实例

    Spring MVC各种参数进行封装的方法实例

    这篇文章主要给大家介绍了关于Spring MVC各种参数进行封装的相关资料,SpringMVC内置多种数据类型转换器,可以根据请求中的参数与后端控制器方法的参数的关系为我们实现简单的数据封装,需要的朋友可以参考下
    2023-06-06
  • 一文看懂RabbitMQ消息丢失如何防止

    一文看懂RabbitMQ消息丢失如何防止

    这篇文章主要介绍了RabbitMQ消息丢失的场景,以及如何保证信息不丢失,看完这篇文章一定可以帮助你RabbitMQ有更深的理解,需要的朋友可以参考下
    2023-03-03
  • Java利用Redis实现高并发计数器的示例代码

    Java利用Redis实现高并发计数器的示例代码

    这篇文章主要介绍了Java利用Redis实现高并发计数器的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-02-02
  • Java Servlet上传图片到指定文件夹并显示图片

    Java Servlet上传图片到指定文件夹并显示图片

    在学习Servlet过程中,针对图片上传做了一个Demo,如果大家对Java Servlet上传图片到指定文件夹并显示图片功能感兴趣的朋友大家通过本文一起学习吧
    2017-08-08
  • Mybatis中的游标查询Cursor(滚动查询)

    Mybatis中的游标查询Cursor(滚动查询)

    这篇文章主要介绍了Mybatis中的游标查询Cursor(滚动查询),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-01-01
  • 解决maven maven.compiler.source和maven.compiler.target的坑

    解决maven maven.compiler.source和maven.compiler.target的坑

    这篇文章主要介绍了解决maven maven.compiler.source和maven.compiler.target的坑,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • Log4j_配置方法(全面讲解)

    Log4j_配置方法(全面讲解)

    下面小编就为大家带来一篇Log4j_配置方法(全面讲解)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • Java实现顺序表的操作详解

    Java实现顺序表的操作详解

    顺序表是用一段物理地址连续的存储单元依次存储数据元素的线性结构,一般情况下采用数组存储。本文主要介绍了顺序表的实现与常用操作,需要的可以参考一下
    2022-09-09
  • Java获取线程ID的实例

    Java获取线程ID的实例

    以下实例演示了如何使用 getThreadId() 方法获取线程id,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-10-10

最新评论