问偷工作的并行工作似乎不会占用太多的工作。

EN

这个想法是在一台96核的机器上运行一个并行作业，通过窃取ForkJoinPool的工作。

下面是我目前正在使用的代码：

import scala.collection.parallel.ForkJoinTaskSupport
import scala.concurrent.forkjoin.ForkJoinPool

val sequence: ParSeq[Item] = getItems().par
sequence.tasksupport = new ForkJoinTaskSupport(new ForkJoinPool())
val results = for {
  item <- sequence
  res   = doSomethingWith(item)
} yield res

在这里，sequence大约有20,000件商品。大多数项目需要2-8秒的时间来处理，其中只有200件需要更长的时间，大约40秒。

问题：

一切运行良好，然而，偷工作方面似乎不太好。下面是与实际负载(蓝色)相比较的预期总CPU负载(黑色)：

​

​

在查看CPU活动时，非常清楚的是，随着工作的完成，越来越少的核心被使用。在过去的10分钟里，只有2到3个核心仍在忙着依次处理几十个项目。

为什么仍然在队列中的项目不会被其他免费内核窃取，即使使用ForkJoinPool，这应该是偷工作的吗？

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ForkJoinPool.html