标签：username 异步 多表 get endCreateTime indexTodoInfoVO CompletableFuture return

    @Override
    public IndexTodoInfoVO getTodoInfo(String beginCreateTime, String endCreateTime) {
        //实例化vo对象
        IndexTodoInfoVO indexTodoInfoVO = new IndexTodoInfoVO();
        //获取当前用户
        String username = SecurityUtils.getUsername();

        //使用CompletableFuture异步线程，向公共线程池提交一些任务.
        /**
         * 1、使用supplyAsync（）从某些数据库中获取数据
         * 2、使用thenAccept（），将此数据写入CSV文件
         */
        CompletableFuture<Integer> aFuture = CompletableFuture.supplyAsync(() -> {
            return clueMapper.getTofollowedCluesNum(username, beginCreateTime, endCreateTime);
        });

        CompletableFuture<Integer> bFuture = CompletableFuture.supplyAsync(() -> {
            return businessMapper.getTofollowedCluesNum(username, beginCreateTime, endCreateTime);
        });

        CompletableFuture<Integer> cFuture = CompletableFuture.supplyAsync(() -> {
            return clueMapper.getToallocatedCluesNum(username, beginCreateTime, endCreateTime);
        });

        CompletableFuture<Integer> dFuture = CompletableFuture.supplyAsync(() -> {
            return businessMapper.getToallocatedBusinessNum(username, beginCreateTime, endCreateTime);
        });

        //　join()和get()方法都是用来获取CompletableFuture异步之后的返回值
        CompletableFuture.allOf(aFuture,bFuture,cFuture,dFuture).join();

        //封装给指定VO对象
        try {
            indexTodoInfoVO.setTofollowedCluesNum(aFuture.get());
            indexTodoInfoVO.setTofollowedCluesNum(bFuture.get());
            indexTodoInfoVO.setToallocatedCluesNum(cFuture.get());
            indexTodoInfoVO.setToallocatedBusinessNum(dFuture.get());
        } catch (Exception e) {
            throw new CustomException(e.getMessage());
        }
        //返回数据
        return indexTodoInfoVO;
    }

标签：username,异步,多表,get,endCreateTime,indexTodoInfoVO,CompletableFuture,return
来源： https://www.cnblogs.com/luoxiao1104/p/16389107.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。