如何解决在未来的失败中传播信息
我正在使用可完成的期货来做一堆ngOnInit(): void {
this._dataService.currentUserId.subscribe(userId => this.userId = userId);
if(this.userId.length === 0){
this.userService.getUserProfile().subscribe(
res => {
this.userDetails = res['user'];
this.userId = this.userDetails._id;
this.getProducts();
},err => {
console.log(err);
}
);
} else {
this.getProducts();
}
}。 X与互联网对话，可能失败也可能失败。当我调用X时，我给它传递了一个值，我们称它为X。 value。
X(value)以上是我正在玩的内容的摘要。归结为分析结果集，我可以看到测试中所有失败/未失败的值（即，对或错）。
private void X(String value) {
CompletableFuture<Boolean> future = CompletableFuture.supplyAsync(()-> {
try {
Object response = talkToExternalThing(value);
} catch (InterruptedException e) {
throw new CompletionException(e.getCause());
}
return true;
}).exceptionally(ex -> false);
futures.add(future);
}
我的问题是，我不仅想知道它是否失败，还想要其他元数据，例如导致失败的Map<Boolean,List<CompletableFuture<Boolean>>> result = futures.stream()
.collect(Collectors.partitioningBy(CompletableFuture::isCompletedExceptionally));
。我希望可能有一个异常对象，因此我可以对其进行分析。值得注意的是，异常是是value。
解决方法
这是我的建议：
ExecutorService executorService = Executors.newCachedThreadPool();
private void X(String value) {
CompletableFuture<Pair<Boolean,String>> future = new CompletableFuture<>();
executorService.execute(() -> {
try {
Object response = talkToExternalThing(value);
} catch (InterruptedException e) {
// un-successfully,with the value
future.complete(new Pair<>(false,value));
return;
}
// successfully,with the value
future.complete(new Pair<>(true,value));
});
futures.add(future);
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。