CompletableFuture recoverWith equivalent? i.e. exceptionally but return CompletableFuturelt;Ugt;(可完成未来恢复,是否具有同等功能?即例外但返回CompletableFuturelt;Ugt;)
问题描述
我看不到明显的方法来处理带有异步结果的异常。
例如,如果我要重试异步操作,则可能会出现如下情况:
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<;U>;的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本文标题为:可完成未来恢复,是否具有同等功能?即例外但返回CompletableFuture<;U>;
基础教程推荐
- 在螺旋中写一个字符串 2022-01-01
- Spring Boot Freemarker从2.2.0升级失败 2022-01-01
- Java 中保存最后 N 个元素的大小受限队列 2022-01-01
- 如何强制对超级方法进行多态调用? 2022-01-01
- 如何对 HashSet 进行排序? 2022-01-01
- 首次使用 Hadoop,MapReduce Job 不运行 Reduce Phase 2022-01-01
- 由于对所需库 rt.jar 的限制,对类的访问限制? 2022-01-01
- 如何使用 Stream 在集合中拆分奇数和偶数以及两者的总和 2022-01-01
- 如何使用 Eclipse 检查调试符号状态? 2022-01-01
- 如何在不安装整个 WTP 包的情况下将 Tomcat 8 添加到 Eclipse Kepler 2022-01-01