java - CompletableFuture recoverWith 等效？即异常但返回 CompletableFuture

Question

我没有看到处理具有异步结果的异常的明显方法。

例如，如果我想重试一个异步操作，我会期待这样的事情:

CompletionStage<String> cf = askPong("cause error").handleAsync((x, t) -> {
    if (t != null) {
        return askPong("Ping");
    } else {
        return x;
    }
});

askPong 询问 Actor 的地方:

public CompletionStage<String> askPong(String message){
    Future sFuture = ask(actorRef, message, 1000);
    final CompletionStage<String> cs = toJava(sFuture);
    return cs;
} 

但是 handleAsync 并没有像您想象的那样做 - 它在另一个线程上异步运行回调。此处返回 CompletionStage 是不正确的。

今日危险问题:thenApply 是thenCompose，exceptionally 是什么？

Answer 1

这是您要找的吗？

askPong("cause error")
        .handle( (pong, ex) -> ex == null 
                ? CompletableFuture.completedFuture(pong) 
                : askPong("Ping")
        ).thenCompose(x -> x);

此外，不要使用 ...Async 方法，除非您打算异步执行所提供函数的主体。所以当你做类似的事情时

.handleAsync((x, t) -> {
    if (t != null) {
        return askPong("Ping");
    } else {
        return x;
    })

您要求在单独的线程中运行 if-then-else。由于 askPong 返回一个 CompletableFuture，因此可能没有理由异步运行它。