scala – 访问ExecutionContext

发布时间：2020-12-16 19:24:47 所属栏目：安全来源：网络整理

导读：我有这个特点 trait NonBlockingGoodness extends DataStore { import akka.dispatch.{ Future,ExecutionContext } import akka.util.duration._ import akka.util.Timeout implicit val ec = ExecutionContext.fromExecutorService(yourExecutorServiceGoes

我有这个特点

trait NonBlockingGoodness extends DataStore {
  import akka.dispatch.{ Future,ExecutionContext }
  import akka.util.duration._
  import akka.util.Timeout

  implicit val ec = ExecutionContext.fromExecutorService(yourExecutorServiceGoesHere)
  implicit lazy val timeout = Timeout(5 seconds)     
}

我想在另一个特征中访问ExecutionContext

trait AsyncGoodness extends NonBlockingGoodness {
  import akka.dispatch.Future

  def doSomething = {
    Future { "Future is the bomb." }
  }

但是,我收到了错误

Could not find implicit value for parameter executor: akka.dispatch.ExecutionContext

更新：
我想出了如何在范围内获取ExecutionContext

trait AsyncGoodness extends NonBlockingGoodness {
  import akka.dispatch.ExecutionContext
  import akka.dispatch.Future

  def doSomething()(implicit executor: ExecutionContext) = {
    Future { "Future is the bomb." }
  }

但是,我有一个后续问题.由于我在AsyncGoodness中可能有多个使用ExecutionContext的方法,有没有办法在特征级别传递它,而不是像我上面那样在每个方法传递它.

解决方法

我知道你宁愿不必再输入任何东西,但是这样的东西对你有用.

trait NonBlockingGoodness {
  import scala.concurrent.{ Future,ExecutionContext }
  import scala.concurrent.util.duration._
  import akka.util.Timeout

  object Implicit {
     implicit val ec = ExecutionContext.Implicits.global
     implicit lazy val timeout = Timeout(5 seconds)
  }

}

trait AsyncGoodness extends NonBlockingGoodness {
  import scala.concurrent.Future
  import Implicit._
  def doSomething = {
    Future { "Future is the bomb." }
  }
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!