scala – 如何在没有Akka的情况下实现actor模型？

这里是JVM世界中最简单高效的演员,其基于来自Viktor Klang的极简主义Scala演员的API：
https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/src/test/scala/com/github/gist/viktorklang/Actor.scala

它在使用中非常方便且安全,但在消息接收方面不是类型安全的,并且不能在进程或主机之间发送消息.

主要特点：

>最简单的FSM类API,仅有3种状态(Stay,Become and Die)：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/src/test/scala/com/github/gist/viktorklang/Actor.scala#L28-L30
> minimalistic错误处理 – 只需正确转发到执行程序线程的默认异常处理程序：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/src/test/scala/com/github/gist/viktorklang/Actor.scala#L52-L53
>快速异步初始化需要大约200 ns来完成,所以不需要额外的期货/演员来进行耗时的演员初始化：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/out0.txt#L447
>最小的内存占用,即处于被动状态的~40字节(BTW新的String()在JVM堆中花费相同的字节数)：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/out0.txt#L449
>消息处理效率非常高,4核CPU的吞吐量约为90M msg /秒：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/out0.txt#L466
>在消息发送/接收方面非常有效,延迟~100 ns：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/out0.txt#L472
>每个演员通过批处理参数调整公平性：https://github.com/plokhotnyuk/actors/blob/41eea0277530f86e4f9557b451c7e34345557ce3/src/test/scala/com/github/gist/viktorklang/Actor.scala#L32

有状态计数器的示例：

def process(self: Address,msg: Any,state: Int): Effect = if (state > 0) { 
     println(msg + " " + state)
     self ! msg
     Become { msg => 
        process(self,msg,state - 1)
     }
  } else Die

  val actor = Actor(self => msg => process(self,5))

结果：

scala> actor ! "a"
a 5

scala> a 4
a 3
a 2
a 1