java - 为什么并行流不使用ForkJoinPool的所有线程？ [复制]

This question already has an answer here:

Parallel stream from a HashSet doesn't run in parallel

(1个答案)

4年前关闭。

因此，我知道，如果您在不使用自定义ForkJoinPool的情况下使用parallelStream，它将使用默认的ForkJoinPool，因为您拥有处理器，因此默认情况下该线程的线程数减少了一个。

因此，作为stated here(以及该问题的其他答案)，为了具有更多的并行性，您必须:

submit the parallel stream execution to your own ForkJoinPool: yourFJP.submit(() -> stream.parallel().forEach(doSomething));

因此，我这样做:

import java.util.Set;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.stream.IntStream;
import com.google.common.collect.Sets;

public class Main {

    public static void main(String[] args) throws InterruptedException, ExecutionException {

        ForkJoinPool forkJoinPool = new ForkJoinPool(1000);

        IntStream stream = IntStream.range(0, 999999);

        final Set<String> thNames = Collections.synchronizedSet(new HashSet<String>());

        forkJoinPool.submit(() -> {
            stream.parallel().forEach(n -> {

                System.out.println("Processing n: " + n);
                try {
                    Thread.sleep(500);
                    thNames.add(Thread.currentThread().getName());
                    System.out.println("Size: " + thNames.size() + " activeCount: " + forkJoinPool.getActiveThreadCount());
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            });
        }).get();
    }
}

我创建了一组线程名称，以查看正在创建多少个线程，并且还记录了池中有 Activity 线程的数量，并且两个数量的增长都不超过16，因此这意味着此处的并行度为不超过16(为什么还要16？)。如果不使用forkJoinPool，则将获得4作为并行度，这取决于我拥有的处理器数量。

为什么给我16个而不是1000个？

最佳答案

更新

最初，这个答案是一个详尽的解释，声称ForkJoinPool施加了反压，甚至没有达到规定的并行度，因为总是有闲置的 worker 可以处理该流。

那是不对的。

原始问题提供了实际答案，该问题被标记为重复-官方不支持使用自定义ForkJoinPool进行流处理，并且当使用forEach时，将使用默认的池并行性来确定流分离器的行为。

这是一个示例，说明如何在手动将任务提交给自定义ForkJoinPool时，池的 Activity 线程数轻松达到其并行性级别:

for (int i = 0; i < 1_000_000; ++i) {
   forkJoinPool.submit(() -> {
      try {
         Thread.sleep(1);
         thNames.add(Thread.currentThread().getName());
         System.out.println("Size: " + thNames.size() + " activeCount: " + forkJoinPool.getActiveThreadCount() + " parallelism: " + forkJoinPool.getParallelism());
      } catch (Exception e) {
         throw new RuntimeException(e);
      }
   });
}

感谢，Stuart Marks 指出了这一点，并感谢 Sotirios Delimanolis 认为我的原始答案是错误的:)

关于java - 为什么并行流不使用ForkJoinPool的所有线程？ [复制]，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41841829/

上一篇：python - Qt Designer实时显示python脚本的输出

下一篇：java - Java Robot单击的速度为每秒70次单击，无法弄清楚数学/出了什么问题

相关文章：

java - libGDX - 缩放时纹理区域绘制怪异

java - 平衡 Java J2EE 服务器上 CPU/内存资源的线程使用

java - 在 Java 中进行多线程时，常规队列不适合使用吗？

multithreading - 如何限制 kotlin 协程的最大并发性

go - golang 好用在多线程应用程序中吗？

java - setter方法在Spring中不起作用？

java - 创建一个简单的 Hello world Android 客户端-服务器程序

java - Windows 服务器上的简单 Java 应用程序......我应该使用 Java EE

使用 Process() 和多线程的 Swift 命令行工具在一定数量的执行轮次(~3148)后崩溃

c++ - asio::strand 的拷贝是否会创建一个新的执行程序？