小编Int*_*tio的帖子

我通过Akka actor调用def activateReward并执行OracleClient.rewardActivate(用户)有时非常慢(数据库不在我的责任范围内,属于另一家公司).

当数据库很慢时,线程池耗尽,并且无法有效地分配更多线程来运行回调future.onComplete,因为回调和期货在同一个执行上下文中工作.

请告知如何从为日期OracleClient.rewardActivate(用户)分配的线程异步执行回调中的代码

class RewardActivatorHelper {

  private implicit val ec = new ExecutionContext {
    val threadPool = Executors.newFixedThreadPool(1000)
    def execute(runnable: Runnable) {threadPool.submit(runnable)}
    def reportFailure(t: Throwable) {throw t}
  }

  case class FutureResult(spStart:Long, spFinish:Long)

  def activateReward(msg:Msg, time:Long):Unit = {
    msg.users.foreach {
      user =>
        val future:Future[FutureResult] = Future {
          val (spStart, spFinish) = OracleClient.rewardActivate(user)
          FutureResult(spStart, spFinish)
        }

        future.onComplete {
          case Success(futureResult:FutureResult) =>
            futureResult match {
              case res:FutureResult => Logger.writeToLog(Logger.LogLevel.DEBUG,s"started:${res.spStart}finished:${res.spFinish}")
              case _ => Logger.writeToLog(Logger.LogLevel.DEBUG, "some error")
            }

          case Failure(e:Throwable) => Logger.writeToLog(Logger.LogLevel.DEBUG, e.getMessage) …