メインスレッドを使用しないフォークと結合

Question

スレッドプールを使用してアイテムのリストを処理し、それらが完了するのを待っています。また、すべてが完了していない場合は、処理の4分後にそれをタイムアウトする必要があります。

これは問題は時々このアプローチはawaitQuiescenceは、そのいずれかが完了するまで開始されないことを意味し、リスト項目のいずれかを処理するためにメインスレッドを使用することで、現時点で私が持っている

ForkJoinPool threadPool = new ForkJoinPool(Runtime.getRuntime().availableProcessors() * 2); 

list.forEach(entry -> threadPool.execute(() -> { 
    // processing 
})); 

if (!threadPool.awaitQuiescence(4, TimeUnit.MINUTES)) { 
    // send alert about delay 
} 

です。同じようなことができますが、メインスレッドを使用しないことを保証する他のスレッドプールがありますか、またはForkJoinPoolを構成しない方法がありますか？

Answer 1

私は問題はあなたがまだメインスレッド内で（list.forEach）を反復していると思います。並列ストリームを使用して、プールに全体の計算を委任：

ForkJoinPool pool = new ForkJoinPool(Runtime.getRuntime().availableProcessors() * 2); 

pool.execute(() -> { 
    list.parallelStream().forEach(item -> { 
     // processing 
    }); 
}); 

if (!pool.awaitQuiescence(4L, TimeUnit.MINUTES)) { 
    // send alert about delay 
} 

私はForkJoinPoolと並列ストリームを使用する方法を参照してくださいthis question（および与えられた答えを）読んでお勧めします。