Scala中ForkJoinPool实际线程数低于设置值的问题咨询

核心问题1：并行集合实例未复用 #

你的代码中两次调用list.par，每次调用都会生成一个新的并行集合实例。第一次设置taskSupport的实例和后续map操作的实例不是同一个，导致自定义的ForkJoinPool并未生效，map依然使用默认的并行池（默认池的线程数上限为64，对应8核机器的8*8）。

修复代码 #

将并行集合赋值给变量，复用同一个实例并设置taskSupport：

val threadIds = new ConcurrentSkipListSet[Long]()
val pool = new ForkJoinPool(250)
val forkJoinSupport = new ForkJoinTaskSupport(pool)
// 复用同一个并行集合实例
val parList = list.par
parList.taskSupport = forkJoinSupport
parList.map{ element =>
  threadIds.add(Thread.currentThread().getId)
  // 你的业务逻辑
}
println(s"""No of actual threads in pool: ${threadIds.size()}: Threads = ${threadIds.asScala.mkString(",")}""")

核心问题2：任务类型影响线程实际使用数 #

即使正确配置了自定义池，实际使用的线程数还取决于任务性质：

• CPU密集型任务：ForkJoinPool基于工作窃取模式，会尽量避免过多线程导致的上下文切换开销。8核机器上，即使设置并行度为250，实际活跃线程数也会接近CPU核心数，不会达到250。
• IO密集型任务：如果任务包含阻塞操作（如IO等待、sleep等），ForkJoinPool会创建更多线程来利用空闲CPU资源，此时才会接近你设置的250线程数。

额外验证点 #

可以通过打印自定义池的参数确认配置生效：

println(s"Custom pool parallelism: ${pool.getParallelism}")
println(s"Custom pool active threads: ${pool.getActiveThreadCount}")

内容的提问来源于stack exchange，提问作者Raj