第67讲：Scala并发编程匿名Actor、消息传递、偏函数实战解析及其在Spark源码中的应用解析学习笔记

第67讲：Scala并发编程匿名Actor、消息传递、偏函数实战解析及其在Spark源码中的应用解析

学习笔记

匿名actor就是直接用scala.actors.Actor就可以了

import scala.actors.Actor._

import scala.actors.Actor

object Actor_Message extends Actor { //继承Actor

def act () {

while(true){
/*循环自己的邮箱，发现邮件匹配上时*/

receive {
/*偏函数，有apply isDefinedAt方法（判断消息是否已被定义为要处理的消息）*/

case msg => println("Message content Actor from inbox: " + msg)

}

}

}

}

def main(args: Array[String] {

val actor_Message = actor{ /*创建匿名actor,此处actor的a是小写，一定要注意*/

while(true){
/*循环自己的邮箱，发现邮件匹配上时*/

receive {
/*偏函数*/

case msg => println("Message content from inbox: " + msg)

}

}

}

val double_Message = actor{

while(true){

receive {

case msg: Double => println("Double Number from inbox: " + msg)

case _ => println("Something Unkown: ") // 下划线可以匹配任何情况

}

}

}

Actor_Message.start

Actor_Message ! "hadoop"

actor_Message ! "Spark"

double_Message ! Math.PI

double_Message ! "hadoop" //因msg是double类型的，发送字符串时无响应

//需要临时Actor时倾向于使用匿名Actor

/*

receive是偏函数，使用case匹配，如果没有匹配时会报错。

偏函数，有apply isDefinedAt方法（判断消息是否已被定义为要处理的消息）

receive中如果没有case，不会报错，只会忽略。

偏函数只会对收到的消息中第一个定义为isDefinedAt为true的消息传递给偏函数的apply方法，apply方法再通过case匹配

如果邮箱中没有isDefinedAt为true的消息，receive所在的actor处于阻塞状态。一直等待消息到来。

*/

/*

akka中有同样的actor的偏函数。

*/

//本节课非常重要，今后会基于此课内容讲解。

以上内容是从王家林老师DT大数据课程第67讲的学习笔记。

DT大数据微信公众账号：DT_Spark

scala第67讲视频观看链接：
http://yun.baidu.com/s/1mg9tsvu
我的百度网盘共享内容：http://pan.baidu.com/s/1qWK9CMo