Akka Gotchas在处理期货时

Question

考虑以下代码位：

def receive = {
  case ComputeResult(itemId: Long) =>
    //val originalSender = sender
    computeResult(itemId).map { result =>
      originalSender ! result
    }
}

计算机结果将在未来产生，那么val的引入将如何防止我将结果发送给错误的发件人？假设我有一个完全不同的发送者（发送者1和发送者2）。

Sender1 首先发送一条消息，然后发送 Sender2。如果没有上述方法中的 val，我清楚地看到我的 Sender2 有可能获得实际上针对 Sender1 的结果。

我不明白的是，val的引入将如何阻止我刚才描述的场景？

Answer 1

sender实际上是一个函数（这就是为什么从Akka 2.3开始的约定是编写sender（））。通过将值绑定到原始Sender，我们可以关闭该不可变值并知道它不会改变，即使在Future from完成结果完成之前有另一条消息进来。

因为 receive 是一个函数，所以每次调用都会产生一个名为 originalSender 的新本地值。