您如何访问已传递给CompletableFuture allOf的已完成期货？

1> Sotirios Del..：

---

该CompletableFuture#allOf方法不公开CompletableFuture传递给它的已完成实例的集合.

返回CompletableFuture在所有给定CompletableFutures完成时完成的新内容.如果任何给定的 CompletableFutures完全异常,则返回 CompletableFuture也会这样做,并将CompletionException此异常作为其原因.否则,给定CompletableFutures 的结果(如果有的话)不会反映在返回的结果中 CompletableFuture,但可以通过单独检查它们来获得.如果未CompletableFuture提供s,则返回CompletableFuture带有值的 完成null.

请注意,allOf还会考虑已完成的异常完成的期货.所以你不会总是有一个Person合作.你可能实际上有一个异常/ throwable.

如果您知道CompletableFuture正在使用的s 数量,请直接使用它们

CompletableFuture.allOf(p1, p2).thenAccept(it -> {
    Person person1 = p1.join();
    Person person2 = p2.join();
});

如果您不知道自己有多少(使用数组或列表),只需捕获传递给的数组 allOf

// make sure not to change the contents of this array
CompletableFuture[] persons = new CompletableFuture[] { p1, p2 };
CompletableFuture.allOf(persons).thenAccept(ignore -> {
   for (int i = 0; i < persons.length; i++ ) {
       Person current = persons[i].join();
   }
});

---

如果你想要你的combinePersons方法(@Test现在忽略它是a )来返回Person[]包含Person已完成的期货中的所有对象,你可以做

@Test
public Person[] combinePersons() throws Exception {
    CompletableFuture p1 = CompletableFuture.supplyAsync(() -> {
        return new Person("p1");
    });

    CompletableFuture p2 = CompletableFuture.supplyAsync(() -> {
        return new Person("p1");
    });

    // make sure not to change the contents of this array
    CompletableFuture[] persons = new CompletableFuture[] { p1, p2 };
    // this will throw an exception if any of the futures complete exceptionally
    CompletableFuture.allOf(persons).join();

    return Arrays.stream(persons).map(CompletableFuture::join).toArray(Person[]::new);
}

---

@ user874774哪种方法*？你的`combinePersons`方法？你需要在返回的`CompletableFuture`(或`get`)上'join`,尽管这些都是阻塞的.

---

@user你必须使用提到的方法之一来阻止并重新处理你传入的数组.

---

@user你没有.您可以使用这些方法来阻止,以确保计算完成.然后使用该数组从每个未来中提取`Person`对象.