我正在寻找如何在Java中给出一个Async CompletableFutures的列表,用于成功完成或失败的前N个中的任何一个。除非没有N成功,否则忽略任何失败。
这有什么例子吗?
谢谢
也许,这样的事情?
public static <T> CompletableFuture<List<T>> firstSuccessful(
List<CompletableFuture<T>> list, int n) {
int maxFail = list.size() - n;
if(maxFail < 0) throw new IllegalArgumentException();
AtomicInteger fails = new AtomicInteger(0);
List<T> rList = new ArrayList<>(n);
CompletableFuture<List<T>> result = new CompletableFuture<>();
BiConsumer<T,Throwable> c = (value,failure) -> {
if(failure != null) {
if(fails.incrementAndGet() > maxFail) result.completeExceptionally(failure);
}
else {
if(!result.isDone()) {
boolean commit;
synchronized(rList) {
commit = rList.size() < n && rList.add(value) && rList.size() == n;
}
if(commit) result.complete(Collections.unmodifiableList(rList));
}
}
};
for(CompletableFuture<T> f: list) f.whenComplete(c);
return result;
}
它返回N个结果作为List
,虽然顺序未确定。只是返回一个Set
会改变语义,即当多个期货被评估为相同的结果时。
如果有足够的成功完成,列表将始终具有长度N.它也将在第N个结果可用时完成,而不是等待其他期货。只要有很多失败的期货,就不可能再成功完成N值,所以将产生特殊的未来。实际上,它将是失败期货中的任意抛出。