java - 有时间限制的计算

Question

我正在尝试编写一个允许我在给定时间窗口内运行计算的结构。像这样的东西:

def expensiveComputation(): Double = //... some intensive math

val result: Option[Double] = timeLimited( 45 ) { expensiveComputation() }

此处 timeLimited 将运行 expensiveComputation，超时为 45 分钟。如果达到超时，则返回 None，否则将结果包装到 Some 中。

我正在寻找一个解决方案:

• 在性能和内存方面相当便宜；
• 将在 当前线程中运行限时任务。

有什么建议吗？

编辑

我了解我原来的问题没有解决方案。假设我可以为计算创建一个线程(但我不喜欢使用线程池/执行程序/调度程序)。最快、最安全和最干净的方法是什么？

Answer 1

运行给定的代码块或在超时时抛出异常:

@throws(classOf[java.util.concurrent.TimeoutException])
def timedRun[F](timeout: Long)(f: => F): F = {

  import java.util.concurrent.{Callable, FutureTask, TimeUnit}

  val task = new FutureTask(new Callable[F]() {
    def call() = f
  })

  new Thread(task).start() 

  task.get(timeout, TimeUnit.MILLISECONDS)
}