java 8並列ストリーム、ブロックコードが可能ですか？

Question

私の状況はとても簡単です。

私はリストを持っています。各項目に対して非同期にロジックを実行したいと思います。

すべてのスレッドが完了すると、私はクローズ接続を呼び出したいと思います。そのような

：

bucketsList.parallelStream().forEach(t -> { 
//some logic 
}); 
try { 
RestApi.getInstance().closeClientConnection(); 
} catch (IOException e) { 
    e.printStackTrace(); 
} 

は、そのオブジェクトのすべてを通過終了する並列ストリームのためcloseConnectionの一部を待機させる方法はありますか？

EDIT：私はまだブロックされてParallelStreamにbucketsList

Answer 1

操作になりますし、それがフィニッシュに生み出されたすべてのスレッドをお待ちしていますどのように多くのアイテムを知らないよう 私はCountDownLatchを使用することはできません。これらのスレッドは非同期に実行されます（前のスレッドが終了するのを待つことはありません）が、コード全体が非同期で動作するようになるわけではありません。

あなたが実際に非同期呼び出しを行うと、あなたのforEachその結果CompletableFuture<T>で作業している場合は、代わりにあなたの端末操作単一CompletableFuture<T>を生成reduce行う必要があります。中間処理は、副作用を伴うpeekまたはID map（どちらも悩まされていますが、ベストプラクティスの解決策はわかりません）の可能性があります。あなたは単一の解決の結果、CompletableFuture<T>の結果として接続を閉じるでしょう。

closeClientConnection()は、ParallelStreamが処理された後にのみ実行されるため、十分ではありません。