当任何给定的CompletableFutures用匹配某个谓词的结果完成时，如何使Futures完成？

Question

List<CompletableFuture<MyService>>

其中MyService是不可变的，如下所示：

public class MyService {
    public boolean isAvailable() {
         return true; // or false
    }
}

我现在想要一个未来，当其中一个未来：

• 完成；和
MyService实例的
• myService.isavailable()返回true

在继续操作时，我需要有可用的MyService实例。换句话说，我想要一个CompletableFuture ，它在满足这两个条件时完成。

我怎么能这么做？我知道可以使用completablefuture.anyof(...)在其中一个期货完成时继续执行，但我不确定如何集成第二个需求:myservice.isavailable()必须为true。

Answer 1

更新：我想我现在明白你的问题了。这样代理你的期货对你有帮助吗？

List<CompletableFuture<MyService>> givenFutures; // wherever they came from

CompletableFuture<MyService>[] myFutures = givenFutures.stream()
        .map(future -> {
            final CompletableFuture<MyService> futureWithCheck = new CompletableFuture<>();

            future.thenAccept(myService -> {
                if (myService.isAvailable()) {
                    futureWithCheck.complete(myService);
                }
            });

            return futureWithCheck;})
        .toArray(CompletableFuture[]::new);

// blocking
MyService availableService = (MyService) CompletableFuture.anyOf(myFutures).get();

// do what you want to do with the available service

更新2：我考虑了您关于thencompose的问题，也许我的解决方案的中间部分可以这样表达：

CompletableFuture<MyService>[] myFutures = givenFutures.stream()
        .map(future ->
                future.thenCompose(myService ->
                        myService.isAvailable() ? CompletableFuture.completedFuture(myService) : new CompletableFuture<>()))
        .toArray(CompletableFuture[]::new);

为了完整起见，旧的答案是：