為Java 8 並行流自訂執行緒池
Java 8 引入了並行流，為資料密集型操作提供了高效的並行性。然而，為平行流指定自訂執行緒池仍然是一個難以捉摸的功能。本文解決了這個問題，提出了使用 ForkJoinPool 的解決方法。
預設執行緒池的一個主要問題是潛在的阻塞行為。在一個流中運行緩慢的任務可能會阻礙其他並行流中的執行。這在隔離至關重要的多執行緒應用程式中尤其成問題。
要克服此限制，您可以為每個任務建立專用的 ForkJoinPool。在 ForkJoinPool 中將並行流作為單獨的任務執行時，該流保持隔離，利用指定的執行緒池而不是預設執行緒池。
考慮以下程式碼片段：
final int parallelism = 4;
ForkJoinPool forkJoinPool = null;
try {
forkJoinPool = new ForkJoinPool(parallelism);
final List<Integer> primes = forkJoinPool.submit(() ->
IntStream.range(1, 1_000_000).parallel()
.filter(PrimesPrint::isPrime)
.boxed().collect(Collectors.toList())
).get();
System.out.println(primes);
} catch (InterruptedException | ExecutionException e) {
throw new RuntimeException(e);
} finally {
if (forkJoinPool != null) {
forkJoinPool.shutdown();
}
}此程式碼建立一個具有指定並行度的新 ForkJoinPool 並在其中執行並行流。並行流在其隔離池中運行，防止其他執行緒的任何潛在幹擾。
這種方法可以更好地控制執行緒分配，允許開發人員劃分並行流並確保多執行緒應用程式中的資源效率。
以上是如何為 Java 8 並行流自訂執行緒池？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
