Cómo establecer el número de hilos de usar para el par

Question

I know que se puede establecer el número de hilos de usar para todas las operaciones .par así: collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel: Int)

Pero, ¿es posible establecer el número de hilos para utilizar para una sola llamada .par?

Answer 1

Se puede crear un bloque que define el nivel de paralelismo y luego ejecutar métodos específicos dentro de ese bloque:

def withParallelism[A](n : Int)(block : => A) : A = { 
    import collection.parallel.ForkJoinTasks.defaultForkJoinPool._ 
    val defaultParLevel = getParallelism 
    setParallelism(n) 
    val ret = block 
    setParallelism(defaultParLevel) 
    ret 
} 

Y luego llamarlo como tal:

withParallelism(2) { 
    (1 to 100).par.map(_ * 2) 
} 

Answer 2

En Scala 2.11 se debe utilizar compatibilidad con tareas de recopilación paralelas, como esta:

parallelCollection.tasksupport = new ForkJoinTaskSupport(
    new scala.concurrent.forkjoin.ForkJoinPool(parlevel)) 

parallelCollection.map(...) 

Ver la compatibilidad de tareas documentation