Dubbo 2.7.0 CompletableFuture 异步-编程知识

Dubbo 2.7.0 CompletableFuture 异步

了解Java中Future演进历史的同学应该知道，Dubbo 2.6.x及之前版本中使用的Future是在java 5中引入的，所以存在以上一些功能设计上的问题，而在java 8中引入的CompletableFuture进一步丰富了Future接口，很好的解决了这些问题。

Dubbo在2.7.0版本已经升级了对Java 8的支持，同时基于CompletableFuture对当前的异步功能进行了增强。

Dubbo 异步调用链路

CompletableFuture 实例

创建一个CompletableFuture列表，每个CompletableFuture对象代表一个异步调用的结果
CompletableFuture对象定义了执行完成后的操作及异常处理
使用CompletableFuture.allOf()方法将这个CompletableFuture列表组合成一个新的CompletableFuture对象
join()方法会阻塞当前线程，直到对应的异步调用完成并返回结果

List<Point> resultList = Lists.newCopyOnWriteArrayList();
CompletableFuture.allOf(Lists.partition(uidList, limit).stream().map(subUidList -> {return pointClient.batchGetPoint(new BatchPointReq(subUidList)).whenComplete((res, thr) -> {if (thr != null) {logger.warn("batchGetPoint fail, req: {}", req, thr);} else if (res.isSuccess()) {resultList.addAll(res.getPointList());}});
}).toArray(CompletableFuture[]::new)).join();
// 亦可在总CompletableFuture使用`thenApply()`合并结果
return resultList;