actor中消息接收

import scala.actors.Actor
import scala.actors.Actor._
object ActorMessage extends Actor{
    def act(){
      while(true){
        receive{//他的工做机制是 先电泳 isDefaultAt 若是返回true 再调用apply方法
          case msg=> println{"Message content from inbox:"+msg}
        }
      }
    }
}
object startMessage{
  def main(args: Array[String]){
    ActorMessage.start
    ActorMessage!"hadoop"
  }
}
相关文章
相关标签/搜索