scala - 计算 ExecutionContext 中的线程数

Question

假设我想知道给定 ExecutionContext 中有多少个线程.
所以我正在写一个这样的函数

def count(implicit ec: ExecutionContext): Int = {
  val promise = Promise[Unit]
  val counter = new AtomicInteger(0)
  for (_ <- 0 to 1000) Future {
    counter.getAndIncrement()
    Await.ready(promise.future, Duration.Inf)
  }
  val result = counter.get()
  promise.success(())
  result
}

它不适用于 ExecutionContext.global至少所以我改变了实现:

def count(implicit ec: ExecutionContext): Int = {
  val barrier = new CyclicBarrier(1000)
  var isReset = false
  for (_ <- 0 to 1000) Future { if (!isReset) barrier.await() }
  val result = barrier.getNumberWaiting
  barrier.reset()

  // make all futures complete and release all threads to allow JVM to exit
  isReset = true 

 result
}

它有效，但我想知道

为什么第一个实现不起作用；

如何改进“障碍”实现(例如摆脱 isReset )；

在 ExecutionContext 中计算线程数的最佳方法是什么？是。

Answer 1

例如，尝试转换到特定的执行者

implicit val ec = scala.concurrent.ExecutionContext.Implicits.global
Future(42)
ec.asInstanceOf[java.util.concurrent.ForkJoinPool].getPoolSize // : Int = 1