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中文网其他相关文章！