Я знаю, что вы можете установить количество потоков, используемых для всех операций .par, например так: collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel: Int)
Но можно ли установить количество потоков, которые будут использоваться только для одного вызова .par?
Вы можете создать блок, который устанавливает уровень параллелизма, а затем выполнять определенные методы в этом блоке:
def withParallelism[A](n : Int)(block : => A) : A = {
import collection.parallel.ForkJoinTasks.defaultForkJoinPool._
val defaultParLevel = getParallelism
setParallelism(n)
val ret = block
setParallelism(defaultParLevel)
ret
}
И затем назовите это так:
withParallelism(2) {
(1 to 100).par.map(_ * 2)
}
В Scala 2.11 вы должны использовать поддержку задач параллельного сбора, например:
parallelCollection.tasksupport = new ForkJoinTaskSupport(
new java.util.concurrent.ForkJoinPool(parlevel))
parallelCollection.map( ... )
См. документацию по поддержке задач.
not found: value setParallelism22.04.2021