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