首页 > 代码库 > scala并发编程原生线程Actor、Case Class下的消息传递和偏函数实战
scala并发编程原生线程Actor、Case Class下的消息传递和偏函数实战
參考代码:
import scala.actors._ case class Person(name:String,age:Int) class HelloActor extends Actor{ def act(){ while(true){ receive{ case Person(name,age)=>{ //偏函数 println("Name: "+ name + ":" +"Age:" +age) sender ! "Echo!!!" } case _ => println("Something else...") } } } } object Actor_With_CaseClass { def main(args: Array[String]): Unit = { val hiActor = new HelloActor hiActor.start hiActor ! Person("Spark",6) self.receive{case msg=> println(msg)} // self.receiveWithin(1000){case msg=> println(msg)} //指定超时时间,不会一直等待下去 } }
//不同的Actor通讯的四种模式有:
//1.全局的Actor、2.在构建一个Actor时能够有它的引用即能够传递參数过来、
//3.消息传递时,消息的接收者处理完这个消息后要把结果交给此Actor
//4.返回消息给发送方,scala中使用sender关键词。
详细应用能够到spark源代码Master.scala类中找到,部分代码例如以下:
override def electedLeader(){self ! ElectedLeader} override def revokedLeadership(){self ! RevokedLeadership}
相关来源:DT大数据梦工厂,微信公众号是DT_Spark。每天都会有大数据实战视频公布,请您持续学习。
相关资料:
scala深入浅出实战经典(1-64讲)完整视频、PPT、代码下载:
百度云盘:http://pan.baidu.com/s/1c0noOt6
腾讯微云:http://url.cn/TnGbdC
360云盘:http://yunpan.cn/cQ4c2UALDjSKy 訪问password45e2
scala并发编程原生线程Actor、Case Class下的消息传递和偏函数实战
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。