我正在尝试掌握Java 8 CompletableFuture。我怎样才能将这些加入到人中并在“allOf”之后返回它们。下面的代码无法正常工作,但可以让您对我尝试过的内容有所了解。
在JavaScript ES6中,我会做
Promise.all([p1, p2]).then(function(persons) {
console.log(persons[0]); // p1 return value
console.log(persons[1]); // p2 return value
});
到目前为止,我在Java方面的工作
public class Person {
private final String name;
public Person(String name) {
this.name = name;
}
public String getName() {
return name;
}
}
@Test
public void combinePersons() throws ExecutionException, InterruptedException {
CompletableFuture<Person> p1 = CompletableFuture.supplyAsync(() -> {
return new Person("p1");
});
CompletableFuture<Person> p2 = CompletableFuture.supplyAsync(() -> {
return new Person("p1");
});
CompletableFuture.allOf(p1, p2).thenAccept(it -> System.out.println(it));
}
最佳答案
CompletableFuture#allOf
方法不会公开传递给它的已完成CompletableFuture
实例的集合。
请注意,allOf
还将异常完成的 future 视为已完成的 future 。因此,您将不会总是拥有一个Person
。您实际上可能有一个异常/可抛出。
如果知道您正在使用的CompletableFuture
的数量,请直接使用它们
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<Person>[] 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
)返回一个包含已完成的 future 中所有Person[]
对象的Person
,则可以执行@Test
public Person[] combinePersons() throws Exception {
CompletableFuture<Person> p1 = CompletableFuture.supplyAsync(() -> {
return new Person("p1");
});
CompletableFuture<Person> p2 = CompletableFuture.supplyAsync(() -> {
return new Person("p1");
});
// make sure not to change the contents of this array
CompletableFuture<Person>[] 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);
}