将来包装时是否可以使用阻止执行组件消息

Question

我当前的应用程序基于 akka 1.1。它有多个ProjectAnalysisActors每个负责处理特定项目的分析任务。当此类参与者收到通用启动消息时，将启动分析。完成一个步骤后，只要定义了下一步，它就会向自己发送一条消息。执行代码基本上如下所示

sealed trait AnalysisEvent {
   def run(project: Project): Future[Any]
   def nextStep: AnalysisEvent = null
}
case class StartAnalysis() extends AnalysisEvent {
   override def run ...
   override def nextStep: AnalysisEvent = new FirstStep
}
case class FirstStep() extends AnalysisEvent {
   override def run ...
   override def nextStep: AnalysisEvent = new SecondStep
}
case class SecondStep() extends AnalysisEvent {
   ...
}
class ProjectAnalysisActor(project: Project) extends Actor {
    def receive = {
        case event: AnalysisEvent =>
            val future = event.run(project)
            future.onComplete { f =>
                self ! event.nextStep
            }
    }
}

我很难为每个

分析步骤的运行方法实现我的代码。目前，我在每个运行方法中创造了一个新的未来。在这个未来，我将所有后续消息发送到不同的子系统中。其中一些是非阻塞即发即弃消息，但其中一些返回的结果应在下一个分析步骤开始之前存储。

目前，典型的运行方法如下所示

def run(project: Project): Future[Any] = {
    Future {
        progressActor ! typicalFireAndForget(project.name)
        val calcResult = (calcActor1 !! doCalcMessage(project)).getOrElse(...)
        val p: Project = ... // created updated project using calcResult
        val result = (storage !! updateProjectInformation(p)).getOrElse(...)
        result
    }
}

由于应该避免那些阻止消息，我想知道这是否是正确的方法。在此用例中使用它们是否有意义，还是我是否仍应避免使用它们？如果是这样，什么是适当的解决方案？

Answer 1

显然，ProjectAnalysisActor的唯一目的是链接未来的调用。其次，运行方法似乎也在等待结果继续计算。

所以我认为你可以尝试重构你的代码来使用未来的组合，如下所述：http://akka.io/docs/akka/1.1/scala/futures.html

def run(project: Project): Future[Any] = {
  progressActor ! typicalFireAndForget(project.name)
  for( 
      calcResult <- calcActor1 !!! doCalcMessage(project);
      p = ... // created updated project using calcResult
      result <- storage !!! updateProjectInformation(p)
  ) yield (
    result
  )
}