在LINQ的scala并行集合中是否有任何等价物来withDegreeOfParallelism设置将运行查询的线程数？我想并行运行一个需要运行一定数量线程的操作.
我正在使用该par.map表达式在 Scala (SBT) 中并行执行进程。
考虑一下list.par.map(function(_))（我正在准备一份 MWE）。这意味着应该以并行方式function(_)应用于 的所有元素。list在我的示例中，list有 3 个元素。但 Scala 仅并行执行function(list(1))，function(list(2))并且仅在之后执行function(list(3))。
这种行为有原因吗？与程序在两核处理器上执行有关系吗？或者你如何强制并行执行这三件事？