可完成未来恢复，是否具有同等功能？即例外但返回CompletableFuture&lt；U&gt； [英] CompletableFuture recoverWith equivalent? i.e. exceptionally but return CompletableFuture<U>

问题描述

我看不到明显的方法来处理带有异步结果的异常。

例如，如果我要重试异步操作，则可能会出现如下情况：

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

askPong询问执行元的位置：

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是什么？

Scala

在试图找出在Java8中执行推荐答案恢复的正确方法时经历了很多挫折之后，我最终只编写了自己的代码。我仍然不知道这是不是最好的方法，但我创建了如下内容：

public RecoveryChainAsync<T> recoverWith(Function<Throwable,
                                         CompletableFuture<T>> fn);

通过重复调用Recovery With，我将恢复链中的函数排入队列，并使用"Handle"自己实现恢复流。然后，RecoveryChainAsync.getCompletableFuture()返回整个链的代表性CompletableFuture。希望这能有所帮助。

这篇关于可完成未来恢复，是否具有同等功能？即例外但返回CompletableFuture&lt；U&gt；的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！