Scala Play 2.2 Slick 1.0.1 – future {Try {…}}等待免费可用

以下同步代码工作正常.它解析请求查询字符串并调用Schools.findSchoolsByFilter方法,该方法对表进行scala光滑调??用并根据SchoolFilter对象过滤结果并返回Try [List [School]]

def listSchools = Action { implicit request =>
  db.withSession { implicit s: Session =>
    Schools.findSchoolsByFilter(parseFilter) match {
      case Success(schools) => Ok(toJsArray(schools))
      case Failure(e) => Ok(e.getMessage)
    }
  }
}

如果我将方法更改为异步运行(见下文),并对listSchools进行多次调用,则在大约20秒后抛出此异常.我怀疑它可能是某种竞争状态,类似于这篇文章Play slick and Async – is it a race condition?.我的问题是,我应该如何更改此代码以安全地异步运行它？

def listSchools = Action.async { implicit request =>
  db.withSession { implicit s: Session =>
    Schools.findSchoolsByFilter(parseFilter) map {
      case Success(schools) => Ok(toJsArray(schools))
      case Failure(e) => Ok(e.getMessage)
    }
  }
}
def findSchoolsByFilter(f: SchoolFilter,n: Int)(implicit s: Session) = 
  future { Try {
    ...
}}
case class SchoolFilter(name: Option[String],city: Option[String],state: Option[String],zip: Option[String],district: Option[String])

这是我的依赖项：

libraryDependencies ++= Seq(
  jdbc,cache,"com.typesafe.slick" %% "slick" % "1.0.1","com.github.tototoshi" %% "slick-joda-mapper" % "0.4.0","org.scalatest" % "scalatest_2.10" % "2.0" % "test","org.easymock" % "easymock" % "3.2","org.postgresql" % "postgresql" % "9.3-1100-jdbc4"
)

这是堆栈跟踪：

com.jolbox.bonecp.DefaultConnectionStrategy.getConnectionInternal(DefaultConnectionStrategy.java:88)
com.jolbox.bonecp.AbstractConnectionStrategy.getConnection(AbstractConnectionStrategy.java:90)
com.jolbox.bonecp.BoneCP.getConnection(BoneCP.java:553)
com.jolbox.bonecp.BoneCPDataSource.getConnection(BoneCPDataSource.java:131)
scala.slick.session.Database $$匿名$1.createConnection(Database.scala：82)
scala.slick.session.BaseSession.conn $lzycompute(Session.scala：207)
scala.slick.session.BaseSession.conn(Session.scala：207)
scala.slick.session.Session $class.prepareStatement(Session.scala：29)
scala.slick.session.BaseSession.prepareStatement(Session.scala：201)
scala.slick.jdbc.StatementInvoker.results(StatementInvoker.scala：29)
scala.slick.jdbc.StatementInvoker.elementsTo(StatementInvoker.scala：17)
scala.slick.jdbc.Invoker $class.foreach(Invoker.scala：90)
scala.slick.jdbc.StatementInvoker.foreach(StatementInvoker.scala：10)
scala.slick.jdbc.Invoker $class.build(Invoker.scala：66)
scala.slick.jdbc.StatementInvoker.build(StatementInvoker.scala：10)
scala.slick.jdbc.Invoker $class.list(Invoker.scala：56)
scala.slick.jdbc.StatementInvoker.list(StatementInvoker.scala：10)
scala.slick.jdbc.UnitInvoker $class.list(Invoker.scala：150)
scala.slick.driver.BasicInvokerComponent $QueryInvoker.list(BasicInvokerComponent.scala：19)
models.school.Schools $$anonfun $findSchoolsByFilter $1 $$anonfun $$申请5.apply(School.scala：85)
models.school.Schools $$anonfun $findSchoolsByFilter $1 $$anonfun $$申请5.apply(School.scala：84)
scala.util.Try $.适用(Try.scala：161)
models.school.Schools $$anonfun $findSchoolsByFilter $1.适用(School.scala：84)
models.school.Schools $$anonfun $findSchoolsByFilter $1.适用(School.scala：84)
scala.concurrent.impl.Future $PromiseCompletingRunnable.liftedTree1 $1(Future.scala：24)
scala.concurrent.impl.Future $PromiseCompletingRunnable.run(Future.scala：24)
akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala：42)
akka.dispatch.ForkJoinExecutorConfigurator $AkkaForkJoinTask.exec(AbstractDispatcher.scala：386)
scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
scala.concurrent.forkjoin.ForkJoinPool $WorkQueue.runTask(ForkJoinPool.java:1339)
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

UPDATE

根据Heroku/Play/BoneCp connection issues的建议,我将“com.jolbox”％“bonecp”％“0.8.0.RELEASE”添加到我的库依赖项中,并将以下内容添加到application.conf中,我仍然得到相同的行为.

db.default.idleMaxAge=10 minutes
db.default.idleConnectionTestPeriod=30 seconds
db.default.connectionTimeout=20 second
db.default.connectionTestStatement="SELECT 1"
db.default.maxConnectionAge=30 minutes