scala下實現actor多線程基礎

package cn.huimin.testimport akka.actor._object NewWrite extends App{  private val system = ActorSystem("newWrite")  private val talker: ActorRef = system.actorOf(Props[SimpleTalker],"talker")  talker ! HmInFifo("nihao")  talker ! aaa("dafd",12)  system.shutdown()  var flg = true  private val terminated: Boolean = system.isTerminated  println(terminated)  while (flg){    if(system.isTerminated){      flg = false    }  }  System.exit(0)}case class HmInFifo(name:String)case class HmInFifo2(name:String)case class aaa(name:String,age:Int)class SimpleTalker extends Actor{  override def receive: Receive = {    case HmInFifo(name)=> println(s"adfsdaf $name")    case HmInFifo2(name)=>println(s"$name,adhfadjfl")    case aaa(name,age)=>{      println(s"my name is $name,and my age is $age")      Thread.sleep(5000)    }  }}
相關文章
相關標籤/搜索