11

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));

}
4

1 に答える 1

24

このメソッドは、渡されたCompletableFuture#allOf完了したインスタンスのコレクションを公開しません。CompletableFuture

CompletableFuture指定されたすべての が完了すると完了するnew を返しますCompletableFuture。指定された のいずれかが CompletableFuture例外的に完了した場合、返さ CompletableFutureれた も同様に完了し、CompletionExceptionこの例外が原因として保持されます。それ以外の場合、指定された の結果CompletableFutureは返された に反映されませんが CompletableFuture、それらを個別に検査することで取得できます。が指定されていない場合は、値を含む完了をCompletableFuture返し ます。CompletableFuturenull

allOf例外的に完了した先物も完了済みとみなすことに注意してください。Personそのため、常に一緒に仕事をする必要はありません。実際には例外/スロー可能なものがあるかもしれません。

使用している sの量がわかっている場合は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を返すようにしたい場合は、次のようにすることができます。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);
}
于 2015-12-10T20:44:58.830 に答える