作者:开心果娟娟 | 来源:互联网 | 2023-09-15 19:23
Scala编程Actor入门引言Scala的Actor类似于Java中的多线程编程。但是不同的是,Scala的Actor提供的模型与多线程有所不同。Scala的Ac
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的创建、启动和消息收发
import scala.actors.Actorclass HelloActor extends Actor {def act() {while (true) {receive {case name: String => println("Hello, " + name)}}}
}val helloActor = new HelloActor
helloActor.start()
helloActor ! "leo"
收发case class类型的消息
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之间互相收发消息
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)}}
}
同步消息和Future
// 默认情况下,消息都是异步的;但是如果希望发送的消息是同步的,即对方接受后,一定要给自己返回结果,那么可以使用!?的方式发送消息。即val reply = actor !? message。// 如果要异步发送一个消息,但是在后续要获得消息的返回值,那么可以使用Future。即!!语法。val future = actor !! message。val reply = future()。