王家林亲授《DT大数据梦工厂》大数据实战视频 Scala 深入浅出实战经典(1-87讲)完整视频、PPT、代码下载:
百度云盘:http://pan.baidu.com/s/1c0noOt6
腾讯微云:http://url.cn/TnGbdC
360云盘:http://yunpan.cn/cQ4c2UALDjSKy 访问密码 45e2
土豆:http://www.tudou.com/programs/view/LwsfuGIsWEk/
优酷:http://v.youku.com/v_show/id_XMTI5MjUzMzM5Ng==.html?from=s1.8-1-1.2
爱奇艺:http://www.iqiyi.com/w_19rru5bi79.html#vfrm=2-3-0-1
腾讯视频:http://v.qq.com/boke/page/u/0/y/u01605cwzly.html
技术爱好者尤其是大数据爱好者 可以加DT大数据梦工厂的qq群
DT大数据梦工厂① :462923555
DT大数据梦工厂②:437123764
DT大数据梦工厂③ :418110145
微信公众账号: DT_Spark
王家林老师微信号: 18610086859
王家林老师QQ: 1740415547
王家林老师邮箱: 18610086859@126.com
本视频由王家林老师, 亲自讲解, 完全通过代码实战把您带人大数据的时代.
package com.parllay.scala.actor
import scala.actors.Actor
import scala.actors.Actor._
/**
* Created by richard on 15-8-27.
* 第67讲:Scala并发编程匿名Actor、消息传递、偏函数解析
*/
object Actor_Message extends Actor {
def act(): Unit = {
while(true){
receive {
case msg => println("Message content index from inbox:" + msg)
}
}
}
}
object Actor_Messages {
def main(args: Array[String]) {
val actor_message = actor {
//循环, 如果没有消息,处于阻塞状态,直到有消息进来.
while(true) {
//recieve 偏函数
receive { //首先符合isDefinedAt=true的消息才会把消息传递给apply处理进行case匹配. 不符合的就不处理. 不返回异常的.
case msg => println("Message content index from inbox:" + msg)
}
}
}
val double_message = actor {
while(true) {
receive {
case msg : Double => println("Double number from inbox :" + msg)
case _ => println("Something Unknown")
}
}
}
Actor_Message.start()
//发消息
Actor_Message ! "继承actor"
actor_message ! "匿名actor"
double_message ! Math.PI
double_message ! "Hadoop"
}
}