在Scala 2.10中为所有集合设置并行度级别？

发布时间：2020-12-16 09:25:49 所属栏目：安全来源：网络整理

导读：我了解如何通过可变的tasksupport字段(c.f. https://stackoverflow.com/a/5425354/82970)为单个并行集合设置并行度级别. How can I set the parallelism level for all new parallel collections in Scala 2.10? 一个辅助问题—是由并行集合“继承”并由它构

我了解如何通过可变的tasksupport字段(c.f. https://stackoverflow.com/a/5425354/82970)为单个并行集合设置并行度级别.

How can I set the parallelism level for all new parallel collections in Scala 2.10?

一个辅助问题—是由并行集合“继承”并由它构建的新并行集合关联的任务支持吗？ (例如拍摄,地图等)

解决方法

>我简要地查看了这些来源,如果我理解正确,有三个系统属性可用于配置默认执行上下文,它似乎用作默认任务支持.这些确定任务支持对象的并行度级别.

> scala.concurrent.context.minThreads：Int,最小并行度级别
> scala.concurrent.context.numThreads：要么指定要直接使用的并行级别的Int,要么是字符串：“x”后跟Double(例如“x1.5”),然后乘以Runtime. getRuntime.availableProcessors
> scala.concurrent.context.maxThreads：Int,最大并行度级别

相关的源文件(如果我正确地遵循了所有内容)似乎是ExecutionContextImpl.
>至于你问题的第二部分：
转换地图,过滤器等操作应该保留在原始集合上设置的任务支持.至少消息来源看起来那样.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!