基本介绍

  1. Scala为了充分使用多核CPU,提供了并行集合(有别于前面的串行集合,用于多核环境的并行计算
  2. 主要用到的算法有:
    1. Divide and conquer:分治算法,Scala通过splitters,combiners等抽象层来实现,主要原理是将计算工作分解很多任务,分发给一些处理器去完成,并将它们处理结果合并返回
    2. Work stealin算法,主要用于任务调度负载均衡(load-balancing),通俗点完成自己的所有任务之后,发现其他人还有活没千完,主动(或被安排)帮他人一起千,这样达到尽早干完的目的

1.使用并行集合首先导入maven依赖

2.其次导入命名空间 import scala.collection.parallel.CollectionConverters._

1
2
3
4
5
<dependency>
<groupId>org.scala-lang.modules</groupId>
<artifactId>scala-parallel-collections_2.13</artifactId>
<version>0.2.0</version>
</dependency>