23 scala 并发编程 actor
更多干货
概述
Scala的Actor类似于Java中的多线程编程。但是不同的是，Scala的Actor提供的模型与多线程有所不同。Scala的Actor尽可能地避免锁和共享状态，从而避免多线程并发时出现资源争用的情况，进而提升多线程编程的性能。此外，Scala Actor的这种模型还可以避免死锁等一系列传统多线程编程的问题。 Spark中使用的分布式多线程框架，是Akka。Akka也实现了类似Scala Actor的模型，其核心概念同样也是Actor
first actor
import scala.actors.Actor
object First_Actor extends Actor {
def act() {
println(Thread.currentThread().getName())
for (i <- 1 to 10) {
println("Step : " + i)
Thread.sleep(2000)
}
}
}
object Second_Actor extends Actor {
def act() {
println(Thread.currentThread().getName())
for (i <- 1 to 10) {
println("Step Further : " + i)
Thread.sleep(2000)
}
}
}
object Hello_Actor {
def main(args: Array[String]) {
First_Actor.start
Second_Actor.start
}
}Scala提供了Actor trait来让我们更方便地进行actor多线程编程，就Actor trait就类似于Java中的Thread和Runnable一样，是基础的多线程基类和接口。我们只要重写Actor trait的act方法，即可实现自己的线程执行体，与Java中重写run方法类似。
此外，使用start()方法启动actor；使用!符号，向actor发送消息；actor内部使用receive和模式匹配接收消息
import scala.actors.Actor
class HelloActor extends Actor {
def act() {
while (true) {
receive {
case name: String => println("receive Hello, " + name)
}
}
}
}
object HelloActor {
def main(args: Array[String]): Unit = {
val helloActor = new HelloActor
helloActor.start()
helloActor ! "nick"
}
}例子
import scala.actors.Actor
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)
}
}
}
}
object UserManageActor {
def main(args: Array[String]): Unit = {
val userManageActor = new UserManageActor
userManageActor.start()
userManageActor ! Register("nick", "1234");
userManageActor ! Login("nick", "1234")
}
}Scala的Actor模型与Java的多线程模型之间，很大的一个区别就是，Scala Actor天然支持线程之间的精准通信；即一个actor可以给其他actor直接发送消息。这个功能是非常强大和方便的。
要给一个actor发送消息，需要使用“actor ! 消息”的语法。在scala中，通常建议使用样例类，即case class来作为消息进行发送。然后在actor接收消息之后，可以使用scala强大的模式匹配功能来进行不同消息的处理。
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 JackTelephoneActor {
def main(args: Array[String]): Unit = {
val leoActor = new LeoTelephoneActor()
val jackActor = new JackTelephoneActor(leoActor)
leoActor.start
jackActor.start
}
}