Springboot中@Async異步,實(shí)現(xiàn)異步結(jié)果合并統(tǒng)一返回方式

更新時(shí)間：2023年09月27日 08:55:36 作者：Yang瘋狂打碼中

這篇文章主要介紹了Springboot中@Async異步,實(shí)現(xiàn)異步結(jié)果合并統(tǒng)一返回方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

@Async異步,實(shí)現(xiàn)異步結(jié)果合并統(tǒng)一返回

本文是為了實(shí)現(xiàn)在SpringBoot中使用@Async異步時(shí)，將所有異步返回的結(jié)果合并。

舉例

如果我們想拉取三個(gè)數(shù)據(jù)，每個(gè)數(shù)據(jù)拉取時(shí)間是2秒鐘，想將結(jié)果統(tǒng)一返回給前端，以往我們都是這么做

    @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;
    }

執(zhí)行拉取測試

    @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());
    }

結(jié)果：共耗時(shí)6秒（一個(gè)結(jié)果2秒）