首页 > 软件编程 > java > Springboot中@Async异步,异步结果合并统一返回

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秒）