我的演员重新启动的未来会发生什么

  • 本文关键字:未来 重新启动 scala akka future
  • 更新时间 :
  • 英文 :


我有一个Akka Actor(Arcworker),该演员具有一对一的主管策略来重新启动任何例外。

def idle: Receive = {
    case UnitOfWork(data, service) =>
      {
        data.HelperRef = Some(ftpHelper)
        val futurework = service(data)
        futurework pipeTo self
        context.become(busy)
      }
}

这个未来的工作需要一些时间才能完成。我的arcworker看着主人,如果大师死了,它会重新开始,并进入非初始化状态。那时,我不希望我的Arcworker收到未来工作的结果。

所以我的问题:
1)如果我提出异常并让主管照顾重新启动Arcworker,我将来会发生什么?2)如果我做上下文。(我认为主管不会处理,但想确认)3)有没有办法取消我的未来工作,以防我没有其他选择?

谢谢 manas

由演员创建的 Future不受后续演员的重新启动或死亡的影响。

最新更新