Scala学习笔记（7）—— Actor 类

1 Scala Actor 介绍

Scala中的Actor能够实现并行编程的强大功能，它是基于事件模型的并发机制，Scala是运用消息（message）的发送、接收来实现多线程的。使用Scala能够更容易地实现多线程应用的开发。
（注：Scala Actor是scala 2.10.x版本及以前版本的Actor。
Scala在2.11.x版本中将Akka加入其中，作为其默认的Actor，老版本的Actor已经废弃
）

1.1 传统java并发编程与Scala Actor编程的区别

对于Java，我们都知道它的多线程实现需要对共享资源（变量、对象等）使用synchronized 关键字进行代码块同步、对象锁互斥等等。而且，常常一大块的try…catch语句块中加上wait方法、notify方法、notifyAll方法是让人很头疼的。原因就在于Java中多数使用的是可变状态的对象资源，对这些资源进行共享来实现多线程编程的话，控制好资源竞争与防止对象状态被意外修改是非常重要的，而对象状态的不变性也是较难以保证的。
在Scala中，我们可以通过复制不可变状态的资源（即对象，Scala中一切都是对象，连函数、方法也是）的一个副本，再基于Actor的消息发送、接收机制进行并行编程

Scala学习笔记（7）—— Actor 类

1.2 Actor方法执行顺序

首先调用start()方法启动Actor
调用start()方法后其act()方法会被执行
向Actor发送消息

1.3 发送消息的方式

Scala学习笔记（7）—— Actor 类

2 Actor 实战

2.1 案例1

package demo4

import scala.actors.Actor

object MyActor1 extends Actor {
  override def act(): Unit = {
    for (i <- 1 to 10) {
      println("actor-1 " + i)
      Thread.sleep(2000)
    }
  }
}

object MyActor2 extends Actor{
  override def act(): Unit = {
    for( i <- 1 to 10){
      println("actor-2 "+i)
      Thread.sleep(2000)
    }
  }
}

object ActorTest extends App{
  MyActor1.start()
  MyActor2.start()
}

actor-1 1
actor-2 1
actor-1 2
actor-2 2
actor-1 3
actor-2 3
actor-1 4
actor-2 4
actor-1 5
actor-2 5
actor-2 6
actor-1 6
actor-2 7
actor-1 7
actor-1 8
actor-2 8
actor-1 9
actor-2 9
actor-1 10
actor-2 10

Process finished with exit code 0

2.2 案例2 —不断接受消息

说明：在act()方法中加入了while (true) 循环，就可以不停的接收消息
注意：发送start消息和stop的消息是异步的，但是Actor接收到消息执行的过程是同步的按顺序执行

package demo4

import scala.actors.Actor

class MyActor extends Actor{
  override def act(): Unit = {
    while(true){
      receive{
        case "start" => {
          println("starting...")
          Thread.sleep(3000)
          println("started")
        }
        case "stop" =>{
          println("stoping...")
          Thread.sleep(5000)
          println("stoped...")
        }
      }
    }
  }
}

object MyActor{
  def main(args: Array[String]): Unit = {
    val actor =new MyActor
    actor.start()
    actor ! "start"
    actor ! "stop"
    println("Mission completed!!")
  }
}

Mission completed!!
starting...
started
stoping...
stoped...

2.3 案例3 - （react方式会复用线程，比receive更高效）

package demo4

import scala.actors.Actor

class MyActor3 extends Actor {
  override def act(): Unit = {
    loop {
      react {
        case "start" => {
          println("starting...")
          Thread.sleep(5000)
          println("started")

        }
        case "stop" => {
          println("stopping...")
          Thread.sleep(4000)
          println("stopped...")
        }
      }
    }
  }
}

object MyActor3 {
  def main(args: Array[String]): Unit = {
    val actor = new MyActor3
    actor.start()
    actor ! "start"
    actor ! "stop"
    println("Mission complete!!!")
  }
}

Mission complete!!!
starting...
started
stopping...
stopped...