Làm thế nào để thiết lập số lượng bài để sử dụng cho mệnh

Question

tôi know mà bạn có thể thiết lập số lượng các chủ đề để sử dụng cho tất cả các hoạt động .par như vậy: collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel: Int)

Nhưng là nó có thể thiết lập số lượng bài để chỉ sử dụng cho một cuộc gọi .par?

Answer 1

Bạn có thể tạo một khối lập mức độ xử lý song song và sau đó thực hiện các phương pháp cụ thể trong khối rằng:

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

Và sau đó gọi nó như vậy:

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

Answer 2

Trong Scala 2.11 bạn nên sử dụng hỗ trợ tác vụ song song, như sau:

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

parallelCollection.map(...) 

Xem công việc hỗ trợ documentation