如何使用CompletableFuture异步发送多个请求并返回成功？

Question

假设我有5个请求，我想并行发送所有5个。我可以使用CompletableFuture.allOf（）来做到这一点；但是，allOf（）只有在所有期货都成功时才返回，即使有一个失败也会失败。我如何从n个成功的期货中得到x，并且在并行发送请求的同时忽略失败的期货？

我正在尝试采取的步骤：

1. Send 5 messages in parallel
2. After 10 second timeout, return all successful messages even if any failed

.

Answer 1

您可以单独捕获异常，并为这些异常场景返回null：

private CompletableFuture<GreetHolder> getGreeting(String lang) {
    return CompletableFuture.supplyAsync( () -> {
        try {
            log.info("Task execution started.");
            Thread.sleep(2000);
            log.info("Task execution stopped.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return new GreetHolder(getGreet(lang));
    }, executor).exceptionally( ex -> {
        log.error("Something went wrong : ", ex);
        return null;
    });
}

CompletableFuture<Void> allFutures = CompletableFuture.allOf(getGreeting("en"), getGreeting("es"));

有关更多信息，请访问此页面：https://medium.com/@塞纳纳亚克。kalpa/fantastic-completablefuture-allof-and-how-to-handle-errors-27e8a97144a0