java - Set<Future<Object>> 中满足谓词的第一个对象

Question

抽象思想

我想从一组 Futures 中获取满足给定谓词的第一个值。

如果找到令人满意的值，则应取消所有其他 future 。如果在所有 Future 返回后仍未找到任何值，则应终止执行(通过返回默认值或抛出异常)。

具体例子

public boolean isThereVacantHotelRooms(Set<URL> hotelApiUrls) {
    // returns true if any provided server responds with a number larger than 0
}

我正在寻找一种在 Java 8 中实现上述内容的漂亮方法(外部库很好)。我已经尝试用 CompletableFuture 和 RxJava 来实现它，但我都觉得这个问题很不合常理，我最终得到了很多难看的代码。

Answer 1

我认为，您的情况可以通过合并、过滤和获取的组合来完成:

List<Observable<HotelInfo>> hotels = new ArrayList<>();
for (URL u : urls) {
    Observable<HotelInfo> hotelInfo = networkAPI.askHotel(u);
    hotels.add(hotelInfo);
}
Observable.merge(hotels)
.filter(h -> h.vacancy > 0)
.take(1)
.subscribe(h -> System.out.println("Winner: " + h), Throwable::printStackTrace);