我正在寻找 ForkJoinPool 的非全局实例，以便获得全局实例的所有出色的默认并行性和执行语义，并能够控制池的生命周期。
我查看了scala.concurrent 和scala.concurrent.impl, 的源代码，可悲的是，看起来创建默认实例的所有代码都是private[scala.concurrent]，并且也没有间接调用代码的方法。
我只能使用ExecutionContext.fromExecutor(null) 获得具有默认设置的ExecutionContext 的新实例，但无法获取底层ForkJoinPool。也没有办法直接关闭ExecutionContext。
我是否在做一些我不应该做的深奥的事情？因为对我来说，想要的东西似乎很自然：没有全局性的东西的默认语义/配置。
【问题讨论】：
标签： scala concurrency threadpool executorservice fork-join
这不是访问问题，而是形状问题。大象的尾巴：
scala> type ECI = { def createExecutorService: ExecutorService }
defined type alias ECI
scala> val fjp = ExecutionContext.global.asInstanceOf[ECI].createExecutorService
fjp: java.util.concurrent.ExecutorService = scala.concurrent.forkjoin.ForkJoinPool@606dff1[Running, parallelism = 8, size = 0, active = 0, running = 0, steals = 0, tasks = 0, submissions = 0]
或无形：
scala> import shapeless.syntax.typeable._
import shapeless.syntax.typeable._
scala> val fjp = concurrent.ExecutionContext.global.cast[ECI] map (_.createExecutorService) getOrElse ???
fcp: java.util.concurrent.ExecutorService = scala.concurrent.forkjoin.ForkJoinPool@45c26421[Running, parallelism = 8, size = 0, active = 0, running = 0, steals = 0, tasks = 0, submissions = 0]
然后
scala> val eces = ExecutionContext fromExecutorService fjp
eces: scala.concurrent.ExecutionContextExecutorService = scala.concurrent.impl.ExecutionContextImpl$$anon$1@1df3794c
scala> eces.shutdown
【讨论】：
private[path.to.package] 的好处在于，您可以通过 假装在该软件包中来解决它：
package scala.concurrent
import java.util.concurrent.Executor
object Foo {
implicit lazy val myGlobalExecutionContext: ExecutionContextExecutor =
impl.ExecutionContextImpl.fromExecutor(null: Executor)
}
但是，请注意，如果您这样做，您将不再处于 public API 领域，并且在更改 scala 版本时将不得不处理某些不兼容问题。
【讨论】：