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