1.简介
Scala的actor提供了一种基于事件的轻量级线程。只要使用scala.actors.Actor伴生对象的actor()方法，就可以创建一个actor。它接受一个函数值/闭包做参数，一创建好就开始运行。用!()方法给actor发消息，用receive()方法从actor接收消息。receive()也可以闭包为参数，通常用模式匹配处理接收到的消息。
scala提供了一种完全有别于java的并发实现，那就是Actor消息机制。不像java那样基于共享数据和锁的机理，scala基于消息实现并发，没有共享数据。
2.代码快速入门
package com.dingxin.entrance import scala.actors.Actor
/**
* scala并发编程
* 基于Actor消息机制，适用于scala2.10及之前版本，新版本使用akka
* Created by zhen on 2019/1/22.
*/ object Left_Actor extends Actor{
def act(){
for(i <- 1 to 10){
println(Thread.currentThread().getName + " step : " + i)
Thread.sleep(1000)
}
}
}
object Right_Actor extends Actor{
def act(){
for(i <-1 to 10){
println(Thread.currentThread().getName + " step : " + i)
Thread.sleep(1000)
}
}
}
object My_Actor {
def main(args: Array[String]) {
// 启动消息机制
Left_Actor.start() // 每个都是一个线程
Right_Actor.start()
}
}
3.结果
ForkJoinPool-1-worker-13 step : 1
ForkJoinPool-1-worker-11 step : 1
ForkJoinPool-1-worker-11 step : 2
ForkJoinPool-1-worker-13 step : 2
ForkJoinPool-1-worker-11 step : 3
ForkJoinPool-1-worker-13 step : 3
ForkJoinPool-1-worker-13 step : 4
ForkJoinPool-1-worker-11 step : 4
ForkJoinPool-1-worker-11 step : 5
ForkJoinPool-1-worker-13 step : 5
ForkJoinPool-1-worker-13 step : 6
ForkJoinPool-1-worker-11 step : 6
ForkJoinPool-1-worker-11 step : 7
ForkJoinPool-1-worker-13 step : 7
ForkJoinPool-1-worker-13 step : 8
ForkJoinPool-1-worker-11 step : 8
ForkJoinPool-1-worker-13 step : 9
ForkJoinPool-1-worker-11 step : 9
ForkJoinPool-1-worker-11 step : 10
ForkJoinPool-1-worker-13 step : 10
4.分析
Actor消息机制使用start开启，这和java类似，每一个start都是一个线程，彼此之间基于消息实现并发编程，没有共享数据！