Actors中期货的执行上下文

Question

我有一个Actor,在某些消息上我正在运行一些返回Future的方法.

 def receive: Receive = {

    case SimpleMessge() =>
        val futData:Future[Int] = ...
        futData.map { data =>
           ... 
        }
}

是否可以通过实际上下文来等待这些数据？或者Await,如果我在SimpleMessage中需要这些数据,我能做的最好吗？

Answer 1

如果你真的需要在处理下一条消息之前等待将来完成,你可以尝试这样的事情:

object SimpleMessageHandler{
  case class SimpleMessage()
  case class FinishSimpleMessage(i:Int)
}

class SimpleMessageHandler extends Actor with Stash{
  import SimpleMessageHandler._
  import context._
  import akka.pattern.pipe

  def receive = waitingForMessage
  def waitingForMessage: Receive = {

    case SimpleMessage() =>
      val futData:Future[Int] = ...
      futData.map(FinishSimpleMessage(_)) pipeTo self
      context.become(waitingToFinish(sender))
  }

  def waitingToFinish(originalSender:ActorRef):Receive = {
    case SimpleMessage() => stash()

    case FinishSimpleMessage(i) =>
      //Do whatever you need to do to finish here
      ...
      unstashAll()
      context.become(waitingForMessage)

    case Status.Failure(ex) =>
      //log error here
      unstashAll()
      context.become(waitingForMessage)      
  }
}

在这种方法中,我们处理a SimpleMessage然后切换处理逻辑以存储所有后续SimpleMessages,直到我们从未来得到结果.当我们得到一个结果,无论是否失败时,我们SimpleMessage会在等待未来的同时取消我们收到的所有其他的东西并继续我们的快乐方式.

这个actor只是在两个状态之间来回切换,这允许你一次只完全处理一个状态SimpleMessage,而不需要阻止Future.