> 文章列表 > CompletableFuture学习及实践应用

CompletableFuture学习及实践应用

CompletableFuture学习及实践应用

技术使用背景

CompletableFuture并发任务多线程进行管理,CompletableFuture是一种非常灵活和高效的异步编程工具,它的内部实现是基于链表、锁、线程池和异步调用的概念。它可以用来处理复杂的异步任务和多个任务之间的依赖关系,让程序的并发执行更加高效和简单
当时客户端启动时刻调我们后端的接口比较多,后来客户端想把多个接口合成一个,根据入参的urlList,来进行多个接口调用,这样客户端就可以一次只调一个合并接口,对于客户端来说方便了,但是对于服务端来说,并发的任务交给服务端,服务端去并发组装接口,当时我第一时间想的是,能不能在网关层面做接口并发,但是因为对网关不熟悉,我直接在其中的一个微服务进行调用。

并发请求代码

@Resource(name = \"p2pPool\")
private ThreadPoolExecutor p2pPool;
CompletableFuture<Void> completableFuture = allOf(request, map);
completableFuture.join();//进行组装completableFuture
public CompletableFuture<Void> allOf(List<interface> requestDtoList, Map<String, Object> map) {CompletableFuture<Void>[] completableFutures = new CompletableFuture[requestDtoList.size()];for (int i = 0; i < requestDtoList.size(); i+