如何為 Java 8 並行流自訂執行緒池？

為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中文網其他相關文章！