scala - Actors 中 future 的执行上下文

Question

我有一个 Actor，并且在某些消息上我正在运行一些返回 Future 的方法。

 def receive: Receive = {

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

是否可以传递实际上下文来等待此数据？或者，如果我需要 SimpleMessage 中的这些数据，Await 是我能做的最好的事情？

Answer 1

如果您确实需要等待 future 完成后再处理下一条消息，您可以尝试如下操作:

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)      
  }
}

在这种方法中，我们处理一个 SimpleMessage，然后切换处理逻辑来存储所有后续收到的 SimpleMessage，直到我们得到 future 的结果。当我们得到结果时，无论是否失败，我们都会在等待 future 的同时取消所有收到的其他 SimpleMessage 并继续我们的快乐之路。

这个 actor 只是在两种状态之间来回切换，这样您一次只能完全处理一个 SimpleMessage，而无需阻止 Future。