Java 8並行流可以使用自訂執行緒池進行任務隔離嗎？

Java 8 並行流的自訂執行緒池

在Java 8 並行流領域，出現了一個問題：是否可以使用針對特定任務的自訂執行緒池？儘管進行了廣泛的搜索，但許多開發人員仍無法實現此功能。

考慮需要並行流的多執行緒伺服器應用程式。然而，為了保持分隔並防止一個模組的任務阻塞其他模組，每個模組都需要不同的執行緒池。

為了說明該問題，請考慮以下範例：

ExecutorService es = Executors.newCachedThreadPool();

es.execute(() -> runTask(1000)); // incorrect task
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));
es.execute(() -> runTask(0));

在此人為的範例，CPU 密集型任務是使用 Executors.newCachedThreadPool() 並行執行的。第一個任務是透過模擬線程睡眠故意減慢的。結果，其他任務陷入困境，等待完成。這演示了一個模組中的緩慢任務如何阻礙其他模組中的任務。

但是，有一個巧妙的解決方案可以解決這一困境：在特定的 fork-join 池中將並行操作作為任務執行。透過這樣做，它們與其他並行流操作使用的公共 fork-join 池保持隔離。

final int parallelism = 4;
ForkJoinPool forkJoinPool = null;
try {
    forkJoinPool = new ForkJoinPool(parallelism);
    final List<Integer> primes = forkJoinPool.submit(() ->
        // Parallel task here, for example
        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();
    }
}

此技術利用 ForkJoinTask.fork()，它指定當前任務是否在fork-join 池，非同步執行應該發生在該池中。否則，將使用 ForkJoinPool.commonPool()。

透過利用這種方法，您可以在多執行緒應用程式中的各個模組中安全地使用並行流，而不會影響效能或任務劃分。

以上是Java 8並行流可以使用自訂執行緒池進行任務隔離嗎？的詳細內容。更多資訊請關注PHP中文網其他相關文章！