scala – 如何设置用于参数的线程数

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

导读：我 know你可以设置所有.par操作使用的线程数,如： collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel：Int) 但是可以设置仅使用一个.par调用的线程数吗？解决方法您可以创建一个设置并行级别的块,然后在该块内执行特定方法

我 know你可以设置所有.par操作使用的线程数,如：
collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel：Int)

但是可以设置仅使用一个.par调用的线程数吗？

解决方法

您可以创建一个设置并行级别的块,然后在该块内执行特定方法：

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

然后称之为：

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

（编辑：李大同）

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