【CompletableFuture实战】

媒介

过去的一年，急忙忙忙，换了一次工作，写博客的习惯就落下了，总之，有点怠惰。希望今年能重拾信心，步入正规！
CompletableFuture的用法网上资料颇多，我这里就简单纪录下自己项目中的真实场景（代码模拟思绪），算是抛砖引玉~

1.     public void handleUserList(List<Users> userList) {
2.         // 增加自定义线程池
3.         ExecutorService executorService = new ThreadPoolExecutor(2, 2, 0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(12));
4.         List<Users> itDeptList = userList.stream().filter(name -> name.getDeptName().equals("IT")).collect(Collectors.toList());
5.         if (CollectionUtils.isEmpty(itDeptList)) {
6.             return;
7.         }
8.         CompletableFuture<Void> createFuture = CompletableFuture.runAsync(() -> {
9.             // 模拟某线程执行业务，比如创建用户
10.             usersMapper.insert(itDeptList.get(0));
11.         }, executorService);
13.         CompletableFuture<Void> updateFuture = CompletableFuture.runAsync(() -> {
14.             List<Integer> userIds = itDeptList.stream().map(Users::getUserId).collect(Collectors.toList());
15.             // 模拟某线程执行业务，比如根据ID列表查询用户
16.             usersMapper.selectBatchIds(userIds);
17.         }, executorService);
19.         // 等待两个线程执行完毕，最后执行主线程
20.         CompletableFuture.allOf(createFuture, updateFuture).join();
21.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。