1.Actor的建立、啟動和訊息收發

//相當於java的thread
//java多執行緒是共享全域性的加鎖的程式設計機制

/** Actor trait就類似於Java中的Thread和Runnable一樣，
是基礎的多執行緒基類和介面。我們只要重寫Actor trait的act方法，
即可實現自己的執行緒執行體，與Java中重寫run方法類似。
actor內部使用receive和模式匹配接收訊息**/

import scala.actors.Actor
class HiActor extends Actor{
  def act (){
    while(true){
      receive{
        case
 
 name :String => println(name)
      }
    }
  }
}

   val actor = new HiActor
   actor.start
   actor ! "spark"

2.收發case class型別的訊息

 // Scala Actor支援執行緒之間的精準通訊；即一個actor可以給其他actor直接傳送訊息。
// 要給一個actor傳送訊息，actor接收訊息之後，scala模式匹配功能來進行不同訊息的處理。
 import scala.actors.Actor
case class Basic(name:String,age :Int)
 

case class Worker(name:String,age :Int)
class basicActor extends Actor{
  def act(){
    while(true){
      receive{
        case Basic(name,age)=> println("basic information"+name +" "+age)
        case Worker(name,age)=> println("Worker information"+name +" "+age)
      }
    }
  }
}
   val
 
 b = new basicActor
   b.start
   b ! Basic("scala",13)
   b ! Worker("spark",7)

   b !? Worker("spark",7) //等待回覆

3.Actor之間互相收發訊息

import scala.actors.Actor
case class Message(content: String, sender: Actor)
class LeoTelephoneActor extends Actor {
  def act() {
    while (true) {
      receive {
        case Message(content, sender) => {
          println("leo telephone: " + content); sender ! "I'm leo, please call me after 10 minutes." }
      }
    }
  }
}


class JackTelephoneActor(val leoTelephoneActor: Actor) extends Actor {
  def act() {
    leoTelephoneActor ! Message("Hello, Leo, I'm Jack.", this)
    receive {
      case response: String => println("jack telephone: " + response)
    }
  }
}

val c=new LeoTelephoneActor
val cc=new JackTelephoneActor(c)
c.start()
cc.start()

// 預設情況下，訊息都是非同步的；但是如果希望傳送的訊息是同步的
val reply = actor !? message

// 如果要非同步傳送一個訊息，但是在後續要獲得訊息的返回值，那麼可以使用Future。即!!語法。
val future = actor !! message
val reply = future()