Stream APIまたはCompletableFutureを使用した並列dbクエリ？

Question

複数のデータベースクエリ（またはWebサービスリクエスト）を並行して送信し、後でそれらを集約したいとします。 stream APIまたはCompletableFutureを使用することをおすすめしますか？

STREAM：

List<Result> result = requests.parallelStream() 
           .map(req -> query(req.getFirstname, req.getLastname)) 
           .collect(toList()); 

//a database, or a webservice 
private Result query(firstname, lastname); 

FUTURES：

List<CompletableFuture> futures; 
for (QueryReq req: requests) { //given input 
    futures.add(CompletableFuture 
         .supplyAsync(() -> query(req.getFirstname, req.getLastname)); 
} 

//wait for all futures to complete and collect the results 
List<Result> results = new ArrayList<>(); 
for (CompleteableFuture f : futures) { 
    results.add(f.get()); 
} 

流れは確かに少ない冗長ですが、どちらがどのような理由のために好まれる必要がありますが？

Sidenote：この例をSQL = :firstname IN (..) and ... :lastname IN(..)で簡単にクエリできます。しかし、ストリームや先物を使うのは単なる例です。

タスクは、dbクエリではなく、複数のWebサービス要求を並列に送信することもできます。

Answer 1

あなたがすでに言ったように：「ストリームは確かにあまり冗長ではありません」、Streamを好んで使うのは十分ではありませんか？公平になるためには、Java 8ストリームAPIを使用して2番目のサンプルコードをCompletableFutureに書き直す必要があります。

List<Result> result = requests.stream() 
     .map(req -> CompletableFuture.supplyAsync(() -> query(req.getFirstname, req.getLastname))) 
     .collect(toList()).stream() 
     .map(f -> f.get()).collect(toList()); 

それはそれはまだより長い/かなり冗長ですになります。しかし、私は重要なポイントは、同時スレッド数を設定する方法ですここだと思う

List<Result> result = requests.parallelStream() 
     .map(req -> query(req.getFirstname, req.getLastname)).collect(toList()); 

：並列ストリームにより、スレッド番号は固定ですForkJoinPool.commonPoolによって、CPUコア番号。通常、大量のWeb/dbリクエストを送信するには小さすぎます。たとえば、送信するウェブ/ dbリクエストが数十、数百になる場合、ほとんどの場合、ForkJoinPool.commonPoolで定義されたスレッド番号よりも20以上のスレッドでリクエストを送信する方がはるかに高速です。個人的には、並列ストリームでスレッド番号を指定する便利な方法がわかりません。あなたが参照できるいくつかの答えは次のとおりです：custom-thread-pool-in-java-8-parallel-stream