Vil*_*tas 12 scala parallel-collections
假设我有一个有点大(几百万个项目,或者说)字符串列表.运行这样的东西是个好主意:
val updatedList = myList.par.map(someAction).toList
Run Code Online (Sandbox Code Playgroud)
或者在运行之前将列表分组是一个更好的主意...par.map(,如下所示:
val numberOfCores = Runtime.getRuntime.availableProcessors
val updatedList =
myList.grouped(numberOfCores).toList.par.map(_.map(someAction)).toList.flatten
Run Code Online (Sandbox Code Playgroud)
更新:由于someAction是相当昂贵的(比较grouped,toList等等)
| 归档时间: |
|
| 查看次数: |
1516 次 |
| 最近记录: |