是否有可能以及如何讓Scala使用線程池中的線程？

Question

在斯卡拉2.11.8我使用par來並行化一個大而長的foreach。我還試圖優化代碼以避免每次都創建對象的新實例，因此我需要使用DynamicVariable。但是，我注意到仍然有很多這個類創建的實例，這導致我認爲par總是跨越新線程而不是重用它們。因此，OP如何使par從線程池中消耗有限的可重用線程？這可能嗎？

for (k <- 0 until 5) { 
    // avoid creating instances of PearsonsIncCorr 
    val inc = new DynamicVariable[PearsonsIncCorr](new PearsonsIncCorr) 
    elems.par foreach { pair => // <======= Here I'd like par to consume from a Thread pool 
     inc.withValue(new PearsonsIncCorr) { 
     inc.reset(...) 
     // compute incremental correlation 
     } 
    } 
} 

Answer 1

par具有默認線程池，這就是scala.concurrent.ExecutionContext.global，該線程池由processors依賴。

所以par不會永遠產卵環新的線程。

，如果你需要創建自定義TaskSupport，你可以不喜歡它：

val pc = mutable.ParArray(1, 2, 3) 
    pc.tasksupport = new ForkJoinTaskSupport(
     new java.util.concurrent.ForkJoinPool(2)) 
    }}} 
    pc.foreach(println)