许昌企业网站建设公司,长沙微信公众号,苏州百度快照优化排名,建筑设计师接私活平台了解Java中Future演进历史的同学应该知道#xff0c;Dubbo 2.6.x及之前版本中使用的Future是在java 5中引入的#xff0c;所以存在以上一些功能设计上的问题#xff0c;而在java 8中引入的CompletableFuture进一步丰富了Future接口#xff0c;很好的解决了这些问题。
Dubb…了解Java中Future演进历史的同学应该知道Dubbo 2.6.x及之前版本中使用的Future是在java 5中引入的所以存在以上一些功能设计上的问题而在java 8中引入的CompletableFuture进一步丰富了Future接口很好的解决了这些问题。
Dubbo在2.7.0版本已经升级了对Java 8的支持同时基于CompletableFuture对当前的异步功能进行了增强。 CompletableFuture 实例
创建一个CompletableFuture列表每个CompletableFuture对象代表一个异步调用的结果CompletableFuture对象定义了执行完成后的操作及异常处理使用CompletableFuture.allOf()方法将这个CompletableFuture列表组合成一个新的CompletableFuture对象join()方法会阻塞当前线程直到对应的异步调用完成并返回结果
ListPoint 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;非Dubbo接口的异步化 CompletableFuture.supplyAsync(() - pointClient.batchGetPoint(new BatchPointReq(subUidList)), threadPool) 参考资料
Dubbo异步化实践如何基于Dubbo实现全异步调用链Java 并发编程 Future及CompletionService20个使用 Java CompletableFuture的例子
