使用Java 8流最大化并行性[重复]

Question

请考虑下面的代码。我希望这10个任务中的每一个同时运行100毫秒。

long runUntil = System.currentTimeMillis() + 100;
IntStream.range(0, 10).parallel().forEach(i ->
{
    int cnt = 0;
    while(System.currentTimeMillis() < runUntil)
        cnt++;
    System.out.println(i + ": " + cnt);
});

然而，我得到的结果是：

2: 56443
1: 67506
4: 74693
6: 70549
0: 0
3: 0
5: 0
7: 0
8: 0
9: 0

所以只有4个任务并行执行，第五个任务只有在前4个任务中的一个完成时才开始。我希望所有的任务都差不多同时开始，而不是彼此等待。

我不同意它是Java8Parallel stream中自定义线程池的重复，因为问题是运行缓慢的任务阻塞了其他任务，而在我的例子中，我只是想知道在使用stream API时如何（如果可以的话）最大化并行性。

Answer 1

当您执行并行流时,您正在调用ForkJoinPool,该池的工作线程数等于以下结果：

 Runtime.getRuntime().availableProcessors(); // 4 in your case

因此并行任务由4个线程并发执行。

在您开始第5个任务时（100毫秒已过），因此此条件：

  while(System.currentTimeMillis() < runUntil)

long runUntil = System.currentTimeMillis() + 1000;
ForkJoinPool forkJoinPool = new ForkJoinPool(10); // 10 Threads
forkJoinPool.submit(() ->
IntStream.range(0, 10).parallel().forEach(i -> {
    int cnt = 0;
    while (System.currentTimeMillis() < runUntil)
        cnt++;
    System.out.println(i + ": " + cnt);
})).get();