【CompletableFuture实战】

前言

过去的一年，匆匆忙忙，换了一次工作，写博客的习惯就落下了，总之，有点懈怠。希望今年能重拾信心，步入正规！

CompletableFuture的用法网上资料颇多，我这里就简单记录下自己项目中的真实场景（代码模拟思路），算是抛砖引玉~

    public void handleUserList(List<Users> userList) {
        // 增加自定义线程池
        ExecutorService executorService = new ThreadPoolExecutor(2, 2, 0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(12));
        List<Users> itDeptList = userList.stream().filter(name -> name.getDeptName().equals("IT")).collect(Collectors.toList());
        if (CollectionUtils.isEmpty(itDeptList)) {
            return;
        }
        CompletableFuture<Void> createFuture = CompletableFuture.runAsync(() -> {
            // 模拟某线程执行业务，比如创建用户
            usersMapper.insert(itDeptList.get(0));
        }, executorService);

        CompletableFuture<Void> updateFuture = CompletableFuture.runAsync(() -> {
            List<Integer> userIds = itDeptList.stream().map(Users::getUserId).collect(Collectors.toList());
            // 模拟某线程执行业务，比如根据ID列表查询用户
            usersMapper.selectBatchIds(userIds);
        }, executorService);

        // 等待两个线程执行完毕，最后执行主线程
        CompletableFuture.allOf(createFuture, updateFuture).join();
    }