Scala 深刻淺出實戰經典 第67講:Scala併發編程匿名Actor、消息傳遞、偏函數解析

王家林親授《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羣html

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._app

/**
* 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)
}
}
}
}oop

object Actor_Messages {大數據

def main(args: Array[String]) {url

val actor_message = actor {
//循環, 若是沒有消息,處於阻塞狀態,直到有消息進來.
while(true) {
//recieve 偏函數
receive { //首先符合isDefinedAt=true的消息纔會把消息傳遞給apply處理進行case匹配. 不符合的就不處理. 不返回異常的.
case msg => println("Message content index from inbox:" + msg)
}
}
}scala

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"

}

}

相關文章
相關標籤/搜索