Slick AsyncExecutor异常

Question

我有一个用Scala2.11编写的Play2.5+Slick3.2应用程序，它使用Play-Slick2.1.1插件。

slick.dbs.data.db.numThreads=75
slick.dbs.data.db.queueSize=1000

def getSubjects(groupId: Int) : Future[Seq[SubjectDTO]] = Action.async { request =>
  db.run(retrieveSubjects(request.groupId).withPinnedSession).flatMap { subjects => 
    Future.traverse(subjects)(subjectDTOBuilder())
  }
}

private def subjectDTOBuilder() =
  (subject: Subject) => {
    for {
      subjData <- db.run(getSubjectsAdditionalData(subject.id).withPinnedSession)
      subjInfo <- db.run(getSubjectsMoreInfo(subject.id).withPinnedSession)
    } yield SubjectDTO(subject, subjData, subjInfo)
  }

Task slick.basic.BasicBackend$DatabaseDef$$anon$2@286a41fb rejected from slick.util.AsyncExecutor$$anon$2$$anon$1@46d9be94[Running, pool size = 75, active threads = 75, queued tasks = 1000, completed tasks = 55419]"

当我将subjectdtoBuilder重写为：

private def subjectDTOBuilder() =
  (subject: Subject) => {
    val future = db.run(getSubjectsAdditionalData(subject.id).withPinnedSession)
    val future2 = db.run(getSubjectsMoreInfo(subject.id).withPinnedSession)
    for {
      subjData <- future
      subjInfo <- future2
    } yield SubjectDTO(subject, subjData, subjInfo)
  }

我知道现在这些“不相关的”期货被并行执行，但我不知道斯利克例外的实际原因。Slick的线程池有什么问题？有没有人能解释一下导致异常发生的可能原因？

Answer 1

错误消息显示“Queued tasks=1000”。默认任务队列长度也是1000。这意味着一次调度的任务可能太多，因此任务执行器的输入队列溢出。此队列保存所有已排定但仍在等待执行的任务。

因此，解决方案可以是同时调度较少数量的任务或增加队列长度。您可以通过提供自己的显式ExecutionContext实例来配置此行为。