我有一个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
不受后续演员的重新启动或死亡的影响。