scala 系列 ---- 流 Stream、视图 View、线程安全的集合、并行集合的使用详解用法及代码示例

阳光穿透心脏的1/2处 2022-11-19 09:58 145阅读 0赞

### 流 Stream ###

stream是一个集合。这个集合，可以用于存放**无穷多个元素**，但是这无穷个元素并不会一次性生产出来，而是需要用到多大的区间，就会动态的生产，**末尾元素遵循lazy规则**(即：要使用结果才进行计算的) 。

**创建Stream对象**

def numsForm(n: BigInt) : Stream[BigInt] = n #:: numsForm(n + 1)
    val stream1 = numsForm(1)

说明

Stream 集合存放的数据类型是BigInt

numsForm 是自定义的一个函数，函数名是程序员指定的。

创建的集合的第一个元素是 n , 后续元素生成的规则是 n + 1

后续元素生成的规则是可以程序员指定的 ，比如 numsForm( n \* 4)...

**使用tail，会动态的向stream集合按规则生成新的元素**

//创Stream
    def numsForm(n: BigInt) : Stream[BigInt] = n #:: numsForm(n + 1)
    val stream1 = numsForm(1)
    println(stream1) //
    //取出第一个元素
    println("head=" + stream1.head) //
    println(stream1.tail) //
    println(stream1) //?

**使用map映射stream的元素并进行一些计算**

//创建Stream
    def numsForm(n: BigInt) : Stream[BigInt] = n #:: numsForm(n + 1)
    def multi(x:BigInt) : BigInt = {
    x * x
    }
    println(numsForm(5).map(multi)) //? (25,?)

### 2 视图 View ###

基本介绍

Stream的懒加载特性，也可以对其他集合应用view方法来得到类似的效果，具有如下特点：

1）view方法产出一个总是被懒执行的集合。

2）view不会缓存数据，每次都要重新计算，比如遍历View时。

def multiple(num: Int): Int = {
    num}
    def eq(i: Int): Boolean = {
    i.toString.equals(i.toString.reverse)
    }
    //说明: 没有使用view
    val viewSquares1 = (1 to 100)
    .map(multiple)
    .filter(eq)
    println(viewSquares1)
    //for (x <- viewSquares1) {}
    //使用view
    val viewSquares2 = (1 to 100)
    .view
    .map(multiple)
    .filter(eq)
    println(viewSquares2)
    for (item <- viewSquares2) {
        print(item + ",")
      }

### 3 线程安全的集合 ###

所有线程安全的集合都是以Synchronized开头的集合

SynchronizedBuffer
    SynchronizedMap
    SynchronizedPriorityQueue
    SynchronizedQueue
    SynchronizedSet
    SynchronizedStack

### 4 并行集合 ###

1）Scala为了充分使用多核CPU，提供了并行集合（有别于前面的串行集合），用于多核环境的并行计算。

2）主要用到的算法有： Divide and conquer : 分治算法，Scala通过splitters(分解器)，combiners（组合器）等抽象层来实现，主要原理是将计算工作分解很多任务，分发给一些处理器去完成，并将它们处理结果合并返回

应用案例

1）打印1~5

![5b27fba5fe2f002e5e3e205af7c3615e.png][]

2）查看并行集合中元素访问的线程

val result1 = (0 to 100).map{case _ => Thread.currentThread.getName}
    val result2 = (0 to 100).par.map{case _ => Thread.currentThread.getName}
    println(result1)
    println(result2)

[5b27fba5fe2f002e5e3e205af7c3615e.png]: /images/20221119/52b8653dbb77464ca617a376ef45b84c.png