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