有可能在演员内部使用Akka调度程序吗？

Question

我想有可能让演员睡一会儿。演员们应该自己决定他们要睡多久。由于thread.sleep（）不是一种推荐的方法，所以我想到在Akka中使用调度程序。因此，我定义一个actor是指另一个actor可以注册被唤醒。

class Scheduler extends Actor {

  def receive = {
    case Sleep(duration) => context.system.scheduler.scheduleOnce(duration) {
      sender ! Ring
    }
  }
}

但发送方从未接收到振铃消息。所以我的问题是

• 是否建议在执行元内部使用计划程序进行计划？
• 发送方为什么从未收到振铃消息？
• 如果不可能这样做，建议采用什么方法解决问题？

Answer 1

让我首先回答标题问题：是的，在一个actor内部使用调度程序是可能的。

case Sleep(duration) =>
  context.system.scheduler.scheduleOnce(duration, self, Ring)

你没有说出你真正想要达到的目标，所以我在这里做了一个有根据的猜测，你希望演员--它通常会做一些叫“X”的事情--做一些叫“Y”的事情，暂时中止“X”activity。这一问题的全部解决办法是

class Sleepy extends Actor {
  def receive = {

    ... // cases doing “X”

    case Sleep(duration) =>
      case object WakeUp
      context.system.scheduler.scheduleOnce(duration, self, WakeUp)
      context.become({
        case WakeUp => context.unbecome()
        // drop the rest
      }, discardOld = false)
  }
}

同样也可以使用FSM特性并在正常和休眠状态之间切换来实现。当然，您可以在睡眠时做任何您想做的事情，例如，在Akka 2.1中混合stash特性，并在睡眠时为所有（或部分）消息调用stash()，在获得wakeup消息时调用unstashall()；或者你可以做点别的什么。演员很灵活。

演员从不真正睡觉，他们总是处理传入的消息。如上所示，您可以定义这意味着什么，但基本原则是，您不能挂起一个执行元，这样它就不会处理其邮箱中的消息。