java - 从 Executor 创建 ExecutorService

Question

我正在使用 Scala，它提供了自己的“执行上下文”抽象(与 Java 的 Executor 大致相同)。我想与另一个需要 ExecutorService 的 Java 库进行交互。是否可以围绕 Executor 构造一个 ExecutorService 包装器？

我知道 ExecutorService 是 Executor 的子类。但就我而言，我只有后者，需要从中构建前者。

如果构造的 ExecutorService 不提供关闭/等待功能，那对我来说没问题。我真正关心的是在给定 execute 实现的情况下合理地实现 submit。

Answer 1

Turning an ExecutionContext to an ExecutorService (or rather and ExecutorService AND an ExecutionContext) using Scala 2.10+

import scala.concurrent.{ExecutionContext, ExecutionContextExecutorService}
import java.util.concurrent.{ AbstractExecutorService, TimeUnit }
import java.util.Collections

object ExecutionContextExecutorServiceBridge {
  def apply(ec: ExecutionContext): ExecutionContextExecutorService = ec match {
    case null => throw null
    case eces: ExecutionContextExecutorService => eces
    case other => new AbstractExecutorService with ExecutionContextExecutorService {
      override def prepare(): ExecutionContext = other
      override def isShutdown = false
      override def isTerminated = false
      override def shutdown() = ()
      override def shutdownNow() = Collections.emptyList[Runnable]
      override def execute(runnable: Runnable): Unit = other execute runnable
      override def reportFailure(t: Throwable): Unit = other reportFailure t
      override def awaitTermination(length: Long,unit: TimeUnit): Boolean = false
    }
  }

或者尝试 Wrapping a scala.concurrent.ExecutionContext into java.concurrent.ExecutorService