Scala:使用可覆盖的隐式调用带/不带 () 的方法



这是方法的定义,它隐式使用ExecutionContext,并允许客户端覆盖它。两个执行上下文用于测试它:

val defaultEc = ExecutionContext.fromExecutor(
Executors.newFixedThreadPool(5))
线程的名称如下所示:"pool-1-thread-1">

到"pool-1-thread-5">

第二个来自 Scala:

scala.concurrent.ExecutionContext.Implicits.global

线程的名称看起来像:"scala-execution-context-global-11">

客户端可以通过以下方式覆盖默认隐式:

implicit val newEc = scala.concurrent.ExecutionContext.Implicits.global

不幸的是,它只有在没有()的情况下调用隐式方法时才可覆盖:

val r = FutureClient.f("testDefault") //prints scala-execution-context-global-11

不工作:

val r = FutureClient.f("testDefault")() //still prints: pool-1-thread-1

问题是为什么它以这种方式工作?因为它使API的客户端变得更加复杂

这是运行它并播放的完整代码:

object FutureClient {
//thread names will be from 'pool-1-thread-1' to 'pool-1-thread-5'
val defaultEc = ExecutionContext.fromExecutor(
Executors.newFixedThreadPool(5))
def f(beans: String)
(implicit executor:ExecutionContext = defaultEc)
: Future[String] = Future {
println("thread: " + Thread.currentThread().getName)
TimeUnit.SECONDS.sleep(Random.nextInt(3))
s"$beans"
}
}
class FutureTest {
//prints thread: pool-1-thread-1
@Test def testFDefault(): Unit ={
val r = FutureClient.f("testDefault")
while (!r.isCompleted) {
TimeUnit.SECONDS.sleep(2)
}
}
//thread: scala-execution-context-global-11
@Test def testFOverridable(): Unit ={
implicit val newEc = scala.concurrent.ExecutionContext.Implicits.global
val r = FutureClient.f("testDefault")
while (!r.isCompleted) {
TimeUnit.SECONDS.sleep(2)
}
}
//prints pool-1-thread-1, but not 'scala-execution-context-global-11'
//cause the client invokes f with () at the end
@Test def testFOverridableWrong(): Unit ={
implicit val newEc = scala.concurrent.ExecutionContext.Implicits.global
val r = FutureClient.f("testDefault")()
while (!r.isCompleted) {
TimeUnit.SECONDS.sleep(2)
}
}
}

我已经讨论了几个相关主题,但它们与 API 定义相关,因此这是一个新问题,这些主题未涵盖。

要避免的 scala 模式:具有默认值的隐式参数

f("testDefault")(或f("testDefault")(implicitly)(意味着隐式论证取自隐式上下文。

f("testDefault")(newEc)意味着显式指定隐式参数。如果您编写f("testDefault")()这意味着您显式指定隐式参数,但由于未提供该值,因此应从默认值中获取。

相关内容

  • 没有找到相关文章

最新更新