Wie, um die Anzahl der zu verwendenden threads für par

Ich kennen, dass Sie können die Anzahl der zu verwendenden threads für alle .par-Operationen wie so:
collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel: Int)

Aber ist es möglich, die Anzahl der zu verwendenden threads für nur eine .par nennen?

InformationsquelleAutor dave | 2012-02-06
  1. 16

    Könnten Sie einen block erstellen, der legt die Parallelität der Ebene und führen Sie dann spezielle Methoden, die innerhalb dieses block:

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

    Und dann rufen Sie es wie folgt:

    withParallelism(2) {
  (1 to 100).par.map(_ * 2)
}
    • Ich weiß nicht, wie die Tatsache, dass es ändert die globalen Zustand
    InformationsquelleAutor Submonoid
  2. 15

    In Scala 2.11, sollten Sie die parallele Sammlung-Aufgabe-Unterstützung, wie diese:

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

parallelCollection.map( ... )

    Finden Sie unter Aufgabe-Unterstützung Dokumentation

    InformationsquelleAutor caiiiycuk
Schreibe einen Kommentar