CompletablFutureおよびExecutorServiceと並行してメソッドを呼び出す

Question

getPriceメソッドをproductの中でproductsに並列呼び出ししようとしています。私はこのコードを持っていて、別のスレッドでgetPriceが実行されていることを確認しましたが、並列ではなく順次実行しています。誰も私がここに何が欠けていることを指摘してくれる？

ありがとうございました。

ExecutorService service = Executors.newFixedThreadPool(THREAD_POOL_SIZE); 
    Set<Product> decoratedProductSet = products.stream() 
    .map(product -> CompletableFuture 
          .supplyAsync(() -> getPrice(product.getId(), date, context), service)) 
    .map(t -> t.exceptionally(throwable -> null)) 
    .map(t -> t.join()) 
    .collect(Collectors.<Product>toSet()); 

Answer 1

あなたは、あなたのプロダクトをストリーミングCompletableFutureへのそれぞれを送信するが、それは参加してのためのストリームは、次のいずれかを処理する前に、その後、待機しています。

なぜ使用しない：

products.parallelStream() 
.map(p -> getPrice(p.getId(), date, context)) 
.collect(Collectors.<Product>toSet());