Question

We have a server that processes portfolio and securities (inside it) in different actors. For portfolio with smaller number of securities (<20) this works fine. When i increase the number of security count to 1000, encountered following issues:

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

我可以绕过这一错误,在kka config内部增加时间,这是正确的事情吗? 在1.1.2之前的“kka”版本中,i可以自行确定。行为者内部的时间不明确,但时间不明确。

我(有时)面临的另一个问题是,整个服务器在加入未来时hang。我组合行动者的地图编码:

    //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。

你们在提出要求时,可以具体指明时间表?

(此外,你的法典只是一纸空文,但我已经在你的其他问题中解决了。)

Cheers, √

友情链接