如何使用Compltable Future进行外部API调用？

Question

我假设有很多情况需要调用基于值列表的外部RESTful服务。

    List<Integer> products = Arrays.asList(1, 2, 3);

现在对于这些productId中的每一个，我想并行调用一个外部endpoint。大致如下：

    List<CompletableFuture<Products>> futureProducts = new ArrayList<>();

    for(Integer id : products){
    futureProducts.add(CompletableFuture.supplyAsync(() -> getExternalApiResponse(id)));
    }

你会如何转换这个

    List<CompletableFuture<Product>> futureProducts;

到

    List<Product> completedProductInformation;

当所有通话成功完成时。

    List<Product> productInformation;

一个人如何使用可完成的未来来实现这一点？

我想我要问的是，如何等待所有调用完成，然后以集合的形式获得结果。

Answer 1

试试这个，你可以在加入后处理流中的其他业务。

futureProducts.stream().map(CompletableFuture::join).collect(Collectors.toList())