标签：distinct 懒加载 原理 注意 多核 应用 while循环 函数 执行
要求：请将List(3,5,8)中所有的元素都*2，将其结果放到一个新的集合中返回，即返回一个新的List(6,10,16)，请编写程序实现
－案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
/*
请将List(3,5,8) 中的所有元素都 * 2 ，
将其结果放到一个新的集合中返回，即返回一个新的List(6,10,16), 请编写程序实现.
*/
val list1 = List(3, 5, 8) //集合
var list2 = List[Int]() //新的集合，准备放入新的内容
for (item <- list1) { //遍历
list2 = list2 :+ item * 2 // 对元素*2 ，然后加入list2集合
}
println("list2=" + list2) //List(6,10,16)
}
}
－上述案例演示的分析和小结
1) 优点
处理方法比较直接，好理解
2) 缺点
不够简洁高效
没有体现函数式编程特点 集合 => 函数 => 新的集合 => 函数 ...
不利于处理复杂的数据处理业务
－案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
//使用高阶函数
val res = test(sum2 _, 3.5)
println("res=" + res)
//在scala中，可以把一个函数直接赋给一个变量,但是不执行函数
val f1 = myPrint _
f1() //执行
}
def myPrint(): Unit = {
println("hello,world!")
}
//说明
//1. test就是一个高阶函数
//2. f: Double => Double 表示一个函数， 该函数可以接受一个Double,返回Double
//3. n1: Double 普通参数
//4. f(n1) 在test函数中，执行 你传入的函数
def test(f: Double => Double, n1: Double) = {
f(n1)
}
//普通的函数, 可以接受一个Double,返回Double
def sum2(d: Double): Double = {
println("sum2被调用")
d + d
}
}
－案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
test2(sayOK)
}
//说明test2是一个高阶函数，可以接受一个 没有输入，返回为Unit的函数
def test2(f: () => Unit) = {
f()
}
def sayOK() = {
println("sayOKKK...")
}
def sub(n1: Int): Unit = {
}
}
//请将 List(3,5,8) 中的所有元素都 * 2 , 将其结果放到一个新的集合中返回,即返回一个新的 List(6,10,16), 请编写程序实现.
val list = List(3, 5, 8)
//说明 list.map(multiple) 做了什么
//1. 将 list 这个集合的元素 依次遍历
//2. 将各个元素传递给 multiple 函数 => 新 Int
//3. 将得到新 Int ,放入到一个新的集合并返回
//4. 因此 multiple 函数调用 3
val list2 = list.map(multiple)
println("list2=" + list2) //List(6,10,16)
def multiple(n: Int): Int = {
println("multiple 被调用~~")
2 * n
}
//深刻理解 map 映射函数的机制-模拟实现
class MyList {
val list1 = List(3, 5, 8, 9) //新的集合
var list2 = List[Int]()
//写 map
def map(f: Int => Int): List[Int] = {
//遍历集合
for (item <- this.list1) {
//过滤,扁平化。。。
list2 = list2 :+ f(item)
}
list2
}
}
object MyList {
def apply(): MyList = new MyList()
}
－扁平化说明
flatmap：flat即压扁，压平，扁平化，效果就是将集合中的每个元素的子元素映射到某个函数并返回新的集合
－案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
val names = List("Alice", "Tom", "Nick")
//需求是将List集合中的所有元素，进行扁平化操作，即把所有元素打散
val names2 = names.flatMap(upper)
println("names2=" + names2)
}
def upper(s: String): String = {
s.toUpperCase
}
}
－基本说明
filter：将符合要求的数据(筛选)放置到新的集合中
－案例演示
应用案例：将 val names = List("Alice","Tom","Nick") 集合中首字母为‘A‘的筛选到新的集合
思考：如果这个使用传统的方法，如何完成？
object boke_demo01 {
def main(args: Array[String]): Unit = {
/*
选出首字母为A的元素
*/
val names = List("Alice", "Tom", "Nick")
val names2 = names.filter(startA)
println("names=" + names)
println("names2=" + names2)
}
def startA(str: String): Boolean = {
str.startsWith("A")
}
}
val list = List(1,20,30,4,5)，求出list的和
化简：将二元函数引用于集合中的函数
上面的问题当然可以使用遍历list方法来解决，这里使用scala的简化方式来完成
object boke_demo01 {
def main(args: Array[String]): Unit = {
/*
使用化简的方式来计算list集合的和
*/
val list = List(1, 20, 30, 4, 5)
val res = list.reduceLeft(sum) //接收一个函数时，也可以直接传入一个匿名函数
//执行的流程分析
//步骤 1 (1 + 20)
//步骤 2 (1 + 20) + 30
//步骤 3 ((1 + 20) + 30) + 4
//步骤 4 (((1 + 20) + 30) + 4) + 5 = 60
println("res=" + res) // 60
}
def sum(n1: Int, n2: Int): Int = {
println("sum被调用~~")
n1 + n2
}
}
1) def reduceLeft[B >: A](@deprecatedName(‘f) op: (B,A) => B): B
2) reduceLeft(f) 接收的函数需要的形式为 op: (B,A) => B): B
3) reduceLeft(f) 的运行规则是 从左边开始执行将得到的结果返回给第一个参数
4) 然后继续和下一个元素运行，将得到的结果继续返回给第一个参数，继续...
即: //((((1+2)+3)+4)+5) = 15
－fold函数将上一步返回的值作为函数的第一参数继续传递参与运算，直到list中的所有元素被遍历
－可以把reduceLeft看做简化版的foldLeft
如何理解：
def reduceLeft[B >: A](@deprecatedName(‘f) op: (B, A) => B): B =
if (isEmpty) throw new UnsupportedOperationException("empty.reduceLeft")
else tail.foldLeft[B](head)(op)
//可以看到. reduceLeft 就是调用的 foldLeft[B](head),并且是默认从集合的 head 元素开始操作的。
－相关函数：fold，foldLeft，foldRight，可以参考reduce的相关方法理解
看下面代码看看输出什么，并分析原因
案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
val list = List(1, 2, 3, 4)
def minus(num1: Int, num2: Int): Int = {
num1 - num2
}
//说明
//1. 折叠的理解和化简的运行机制几乎一样.
//理解 list.foldLeft(5)(minus) 理解成 list(5,1, 2, 3, 4) list.reduceLeft(minus)
//步骤 (5-1)
//步骤 ((5-1) - 2)
//步骤 (((5-1) - 2) - 3)
//步骤 ((((5-1) - 2) - 3)) - 4 = - 5
println(list.foldLeft(5)(minus)) // 函数的柯里化
////理解 list.foldRight(5)(minus) 理解成 list(1, 2, 3, 4, 5) list.reduceRight(minus)
// 步骤 (4 - 5)
// 步骤 (3- (4 - 5))
// 步骤 (2 -(3- (4 - 5)))
// 步骤 1- (2 -(3- (4 - 5))) = 3
println(list.foldRight(5)(minus)) //
}
}
－案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
val list4 = List(1, 9)
def minus(num1: Int, num2: Int): Int = {
num1 - num2
}
var i6 = (1 /: list4) (minus) // =等价=> list4.foldLeft(1)(minus)
println("i6=" + i6)
i6 = (100 /: list4) (minus) //=等价=> list4.foldLeft(100)(minus)
println(i6) // 输出?
i6 = (list4 :\ 10) (minus) // list4.foldRight(10)(minus)
println(i6) // 输出? 2
}
}
扫描，即对某个集合的所有元素做fold操作，但是会把产生的所有中间结果放置于一个集合中保存
object boke_demo01 {
def main(args: Array[String]): Unit = {
//普通函数
def minus( num1 : Int, num2 : Int ) : Int = {
num1 - num2
}
//5 (1,2,3,4,5) =>(5, 4, 2, -1, -5, -10) //Vector(5, 4, 2, -1, -5, -10)
val i8 = (1 to 5).scanLeft(5)(minus) //IndexedSeq[Int]
println("i8=" + i8)
//普通函数
def add( num1 : Int, num2 : Int ) : Int = {
num1 + num2
}
//(1,2,3,4,5) 5 => (20,19,17,14, 10,5)
val i9 = (1 to 5).scanRight(5)(add) //IndexedSeq[Int]
println("i9=" + i9)
}
}
在开发中，当我们需要将两个集合进行 对偶元组合并，可以使用拉链
object boke_demo01 {
def main(args: Array[String]): Unit = {
// 拉链
val list1 = List(1, 2, 3)
val list2 = List(4, 5, 6)
val list3 = list1.zip(list2) // (1,4),(2,5),(3,6)
println("list3=" + list3)
}
}
1) 拉链的本质就是两个集合的合并操作，合并后每个元素是一个 对偶元组
2) 操作的规则如下图
3) 如果两个集合个数不对应，会造成数据丢失
4) 集合不限于List，也可以是其它集合，比如：Array
5) 如果要取出合并后的各个对偶元组的数据，可以遍历
for(item<-list3) {
print(item._1 + " " + item._2) //取出时,按照元组的方式取出即可
}
通过iterator方法从集合获得一个迭代器，通过while循环和for表达式对集合进行遍历(学习使用迭代器来遍历)
object boke_demo01 {
def main(args: Array[String]): Unit = {
val iterator = List(1, 2, 3, 4, 5).iterator // 得到迭代器
/*
这里我们看看iterator 的继承关系
def iterator: Iterator[A] = new AbstractIterator[A] {
var these = self
def hasNext: Boolean = !these.isEmpty
def next(): A =
if (hasNext) {
val result = these.head; these = these.tail; result
} else Iterator.empty.next()
*/
println("--------遍历方式1 while -----------------")
while (iterator.hasNext) {
println(iterator.next())
}
println("--------遍历方式2 for -----------------")
for (enum <- iterator) {
println(enum) //
}
}
}
1) iterator的构建实际是AbstractIterator的一个匿名子类，该子类提供了
def iterator: Iterator[A] = new AbstractIterator[A] {
var these = self
def hasNext: Boolean = !these.isEmpty
def next(): A =
if (hasNext) {
val result = these.head;
these = these.tail;
result
} else Iterator.empty.next()
}
2) 该AbstractIterator子类提供了hasNext，next等方法
3) 因此，我们可以使用while的方式，使用hasNext，next方法变量
stream是一个集合。这个集合，可以用于存放无穷多个元素，但是这无穷个元素并不会一次性生产出来，而是需要用到多大的区间，就会动态的生产，末尾元素遵循lazy规则(即：要使用结果才进行计算)
－案例
def numsForm(n: BigInt): Stream[BigInt] = n #:: numsForm(n + 1) val stream1 = numsForm(1)
－说明
1) Stream集合存放的数据类型是BigInt
2) numsForm是自定义的一个函数，函数名是程序员指定的
3) 创建的集合的第一个元素是n，后续元素生成的规则是n+1
4) 后续元素生成的规则是可以程序员指定的
//创建 Stream
def numsForm(n: BigInt) : Stream[BigInt] = n #:: numsForm(n + 1)
val stream1 = numsForm(1)
println(stream1) //
//取出第一个元素
println("head=" + stream1.head) //
println(stream1.tail) // 当对流执行 tail 操作时,就会生成一个新的数据.
println(stream1) //
Stream的懒加载特性，也可以对其他集合应用view方法来得到类似的效果，具体有如下特点
1) view方法产出一个总是被懒执行的集合
2) view不会缓存数据，每次都要重新计算，比如遍历View时
请找到1-100中，数字倒叙排列和它本身相同的所有数
object boke_demo01 {
def main(args: Array[String]): Unit = {
def multiple(num: Int): Int = {
num
}
//如果这个数，逆序后和原来数相等，就返回true,否则返回false
def eq(i: Int): Boolean = {
println("eq 被调用..")
i.toString.equals(i.toString.reverse)
}
//说明: 没有使用view,常规方式
val viewSquares1 = (1 to 100).filter(eq)
println(viewSquares1)
//使用view，来完成这个问题,程序中，对集合进行map,filter,reduce,fold...
//你并不希望立即执行，而是在使用到结果才执行，则可以使用view来进行优化.
val viewSquares2 = (1 to 100).view.filter(eq)
println(viewSquares2)
//遍历
for (item <- viewSquares2) {
println("item=" + item)
}
}
}
1) Scala为了充分使用多核CPU，提供了并行集合(有别于前面的串行集合)，用于多核环境的并行计算
2) 主要用到的算法有：
Divide and conquer: 分治算法，Scala通过splitters(分解器)，combiners(组合器)等抽象层来实现，主要原理是将计算工作分解很多任务，分发给一些处理器去完成，并将它们处理结果合并返回
Work stealin算法，主要用于任务调度负载均衡(load-balancing)，通俗点完成自己的所有任务之后，发现其他人还有活没干完，主动(或被安排)帮他人一起干，这样达到尽早干完的目的
－parallel(并行)
打印1～5
(1 to 5).foreach(println(_))
println()
(1 to 5).par.foreach(println(_))
－查看并行集合中元素访问的线程
object boke_demo01 {
def main(args: Array[String]): Unit = {
val result1 = (0 to 100).map { case _ => Thread.currentThread.getName }.distinct
val result2 = (0 to 100).par.map { case _ => Thread.currentThread.getName }.distinct
println(result1) //非并行
println("--------------------------------------------")
println(result2) //并行
}
}
这部分内容没有必要刻意去记忆，语法使用的多了，自然就会熟练的使用，该部分内容了解就可以
1) 如果想在变量名、类名等定义中使用语法关键字(保留字)，可以配合反引号反引号，比如 val `val` = 23
2) 中置操作符：A操作符B 等同于 A.操作符(B)
3) 后置操作符：A操作符 等同于 A.操作符，如果操作符定义的时候不带()则调用时不能加括号
4) 前置操作符：+、-、!、~等操作符A 等同于 A.unary_操作符
5) 赋值操作符：A操作符=B 等同于 A=A 操作符B，比如A +=B 等价 A = A + B
6) 案例演示
object boke_demo01 {
def main(args: Array[String]): Unit = {
val n1 = 1
val n2 = 2
val r1 = n1 + n2 // 3
val r2 = n1.+(n2) // 3 看Int的源码即可说明
val monster = new Monster
monster + 10
monster.+(10)
println("monster.money=" + monster.money) // 20
println(monster ++)
println(monster.++)
println("monster.money=" + monster.money) // 22
!monster
println("monster.money=" + monster.money) // -22
}
}
class Monster {
var money: Int = 0
//对操作符进行重载 (中置操作符)
def +(n: Int): Unit = {
this.money += n
}
//对操作符进行重载(后置操作符)
def ++(): Unit = {
this.money += 1
}
//对操作符进行重载(前置操作符，一元运算符)
def unary_!(): Unit = {
this.money = -this.money
}
}
标签：distinct 懒加载 原理 注意 多核 应用 while循环 函数 执行
原文地址：https://www.cnblogs.com/zhanghuicheng/p/10841223.html
