scala actor多线程（十五）

Scala的Actor相似于Java中的多线程编程。可是不一样的是，Scala的Actor提供的模型与多线程有所不一样。Scala的Actor尽量地避免锁和共享状态，从而避免多线程并发时出现资源争用的状况，进而提高多线程编程的性能。此外，Scala Actor的这种模型还能够避免死锁等一系列传统多线程编程的问题。编程

Spark中使用的分布式多线程框架，是Akka。Akka也实现了相似Scala Actor的模型，其核心概念一样也是Actor。所以只要掌握了Scala Actor，那么在Spark源码研究时，至少便可看明白Akka Actor相关的代码。可是，换一句话说，因为Spark内部有大量的Akka Actor的使用，所以对于Scala Actor也至少必须掌握，这样才能学习Spark源码。多线程

一、Actor的建立、启动和消息收发（案例：Actor Hello World）并发

// Scala提供了Actor trait来让咱们更方便地进行actor多线程编程，就Actor trait就相似于Java中的Thread和Runnable同样，是基础的多线程基类和接口。咱们只要重写Actor trait的act方法，便可实现本身的线程执行体，与Java中重写run方法相似。 // 此外，使用start()方法启动actor；使用!符号，向actor发送消息；actor内部使用receive和模式匹配接收消息 // 案例：Actor Hello World
object test{ def main(args: Array[String]): Unit = { import scala.actors.Actor //已弃用，改为import akka.actor.Actor，需加模块
    class HelloActor extends Actor { def act() { while (true) { receive { case name: String => println("Hello, " + name) } } } } val helloActor = new HelloActor helloActor.start() helloActor ! "leo" } }

二、收发case class类型的消息（案例：用户注册登陆后台接口）框架

// Scala的Actor模型与Java的多线程模型之间，很大的一个区别就是，Scala Actor自然支持线程之间的精准通讯；即一个actor能够给其余actor直接发送消息。这个功能是很是强大和方便的。 // 要给一个actor发送消息，须要使用“actor ! 消息”的语法。在scala中，一般建议使用样例类，即case class来做为消息进行发送。而后在actor接收消息以后，可使用scala强大的模式匹配功能来进行不一样消息的处理。 // 案例：用户注册登陆后台接口
case class Login(username: String, password: String) case class Register(username: String, password: String) class UserManageActor extends Actor { def act() { while (true) { receive { case Login(username, password) => println("login, username is " + username + ", password is " + password) case Register(username, password) => println("register, username is " + username + ", password is " + password) } } } } val userManageActor = new UserManageActor userManageActor.start() userManageActor ! Register("leo", "1234"); userManageActor ! Login("leo", "1234")

三、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) } } } object test{ def main(args: Array[String]): Unit = { val leo=new LeoTelephoneActor val jack=new JackTelephoneActor(leo) leo.start jack.start } }

四、同步消息和Future分布式

// 默认状况下，消息都是异步的；可是若是但愿发送的消息是同步的，即对方接受后，必定要给本身返回结果，那么可使用!?的方式发送消息。即val reply = actor !? message。 // 若是要异步发送一个消息，可是在后续要得到消息的返回值，那么可使用Future。即!!语法。val future = actor !! message。val reply = future()。