如何将自定义线程池与 Java 8 并行流结合使用？

Java 8 并行流中的可自定义线程池

控制并行流中的线程资源分配可增强应用程序性能和模块化。然而，目前尚不清楚如何为 Java 8 中的特定流操作指定自定义线程池。

本文探讨了该问题并提供了解决方案，克服了并行流中共享线程池的限制。

问题陈述

考虑使用并行流的服务器应用程序。为了防止一个模块中的缓慢任务影响其他模块，需要对线程池进行划分。然而，标准并行流实现对所有操作都使用共享线程池。

如以下代码片段所示，受损任务会无限期延迟其他线程：

// CPU-intensive tasks in separate threads leveraging parallel streams
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));

解决方案

要在指定的 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:
        return IntStream.range(1, 1_000_000).parallel()
                .filter(PrimesPrint::isPrime)
                .boxed()
                .collect(Collectors.toList());
    }).get();
    System.out.println(primes);
} catch (Exception e) {
    throw new RuntimeException(e);
} finally {
    if (forkJoinPool != null) {
        forkJoinPool.shutdown();
    }
}

此技术利用 ForkJoinTask.fork() 的行为：“在当前任务正在运行的池中异步执行此任务（如果适用），或者使用如果不在 ForkJoinPool() 中，则为 ForkJoinPool.commonPool()。"

以上是如何将自定义线程池与 Java 8 并行流结合使用？的详细内容。更多信息请关注PHP中文网其他相关文章！