Akka、未来和关键部分

Question

class FooActor extends Actor {
  private var state: Int = 0

  def receive = { ... }
}

假设接收处理程序调用一个返回future的操作，我们使用dispatcher作为上下文执行器来映射它，最后我们设置一个onSuccess回调来改变执行元状态。

import context.dispatcher
def receive = {
  case "Hello" => requestSomething() // asume Future[String]
    .map(_.size)
    .onSuccess { case i => state = i }
}

从onsuccess回调中更改执行元的状态，甚至使用执行元调度程序作为执行上下文，这是线程安全的吗？

Answer 1

不是（akka 2.3.4文档）。

在这种情况下，您必须做的是发送一个消息给self以改变状态。如果你需要订购，你可以使用stash和成为。类似这样的东西

import akka.actor.{Stash,Actor}
import akka.pattern.pipe
case class StateUpdate(i:int)
class FooActor extends Actor with Stash{
  private var state: Int = 0
  def receive = ready
  def ready  = {
    case "Hello" => requestSomething() // asume Future[String]
      .map(StateUpdate(_.size)) pipeTo self
      become(busy)
  } 
  def busy {
     case StateUpdate(i) => 
       state=i
       unstashAll()
       become(ready)
     case State.Failure(t:Throwable) => // the future failed
     case evt =>
       stash()   
  }
}

当然，这是一个简单的实现，您可能想要处理超时和其他东西，以避免您的执行元被卡住。

case class StateUpdate(i:int)
class FooActor extends Actor with Stash{
  private var state: Int = 0
  def receive = {
    case "Hello" => requestSomething() // asume Future[String]
      .map(StateUpdate(_.size)) pipeTo self
    case StateUpdate(i) => state=i
  }