akka如何启动主任务并阻止其完成？

Question

我正在尝试在 scala 中开始使用 akka。在主 scala 线程中，我想启动一个 akka actor，向它发送一条消息，然后阻塞，直到该 actor 终止。最好的方法是什么？

例如，我有一个测试参与者，它只是重复地向自身发送消息：

class Incrementer() extends Actor {

  val maxMessages = 5
  var counter = 0

  def receive() = {
    case DoIncr() => {
      if (counter < maxMessages) {
        counter += 1
        self ! DoIncr()
      } else {
        self.stop()
      }
    }
  }
}

并且通过以下方式调用它：

val inc = actorOf(new Incrementer()).start()
val result = inc !! DoIncr()
println(result) // this should block this thread, but it doesn't seem to.

// do other stuff

该块只需要 5,000 多毫秒来执行，而不是我期望的几毫秒，所以它似乎与默认未来超时 - 并且程序实际上不会终止。我真正想做的就是对发送 x 条消息的性能进行计时。这是怎么回事？

Answer 1

正如 Viktor 提到的，为了使 !! 成功终止，您必须回复该消息。您看到的是演员的默认超时 5 秒延迟，这是可配置的。更多信息请访问 Akka 网站。

如果您使用 forward 而不是 ! 发送消息，则 self.reply 将响应原始发件人。

您发送给 Akka actor 的第一条消息执行一些在处理其他消息时不会发生的设置。请务必在您的时间安排中考虑到这一点。

更正后的代码如下：

import akka.actor._

object DoIncr

class Incrementer extends Actor {
  val maxMessages = 5
  var counter = 0

  def receive = {
    case DoIncr =>
      if (counter < maxMessages) {
        counter += 1
        self forward DoIncr
      } else {
        self.reply(()) // replying with () since we have nothing better to say
        self.stop()
      }
  }
}

旁白：我做了一些其他更改，以使您的代码符合惯用的 Scala。您的代码无需进行这些更改即可工作，但它现在看起来像更典型的 Scala 代码。

• 不推荐使用没有参数列表的案例类。使用对象来代替。
• 如果你的类没有参数列表，可以省略括号
• Actor的receive方法没有parens；你的实现类也不应该有它们。
• 这纯粹是风格问题，但 case 语句的主体不需要大括号。