Akka 中的 Future 超时

Question

我们有一个服务器，可以处理不同参与者的投资组合和证券（在其内部）。对于证券数量较少（<20）的投资组合，这种方法效果很好。当我将安全计数增加到 1000 时，遇到以下问题：

akka.dispatch.FutureTimeoutException: Futures timed out after [5000] ms

我可以通过增加 akka 配置中的超时来绕过此错误，这是正确的做法吗？在早于 1.2 的 akka 版本中，我可以在 actor 中设置 self.timeout，但这已被弃用。

我（间歇性地）面临的另一个问题是，在我的投资组合参与者中加入 futures.map 代码时，整个服务器挂起：

    //fork out for each security
    val listOfFutures = new ListBuffer[Future[Security]]()
    for (security <- portfolio.getSecurities.toList) {
      val securityProcessor = actorOf[SecurityProcessor].start()
      listOfFutures += (securityProcessor ? security) map {
        _.asInstanceOf[Security]
      }
    }
    EventHandler.info(this,"joining results from security processors")
    //join for each security
    val futures = Future.sequence(listOfFutures.toList)
    futures.map {
      listOfSecurities =>
        portfolioResponse = MergeHelper.merge(portfolio, listOfSecurities)
    }.get

Answer 1

您没有说明您使用的是哪个版本的 Akka，并且考虑到我使用水晶球的时间有限，我会假设您使用的是 1.2。

您可以在调用ask/?时指定超时。

（另外，你的代码有点复杂，但我已经在你的其他问题中解决了。）

干杯，
√