scala - preStart 钩子(Hook) : a message to the actor itself

Question

假设我覆盖了 preStart钩住并向self发送消息:

Class SomeActor extends Actor {

  override def preStart(): Unit = {
    self ! SomeMessage
  }

  ...

}

我可以期待 SomeMessage将是队列中的第一条消息？

Answer 1

不，因为actor创建是异步发生的，有人可能在构造函数或preStart之前将消息排入队列。实际运行。如果您需要确保先处理此消息，则需要使用 become和 stash :

self ! SomeMessage

def receive = initial

def initial: Receive = {
  case SomeMessage =>
    // do stuff
    unstashAll()
    context become initialized
  case _ => stash()
}

def initialized: Receive = {
  // your normal behavior
}

您需要混合 akka.actor.Stash特征并配置此actor以使用 DequeBasedMailbox .