在Scala中花费太多时间时如何终止函数？

Question

最近，我正在学习 Scala 语言。今天我出来一个问题，就是 如何在需要太多时间时终止函数。

例如：

object HelloWorld {
  def main(args: Array[String]) {
    println("Hello, World")
    // How to terminate the sum() function
    // when the time that it takes greater than 2 second?
    val t0 = System.nanoTime : Double
    val total: BigInt = sum(1000000000)
    val t1 = System.nanoTime : Double
    println("Elapsed time " + (t1 - t0) / 1000000.0 + " msecs")

    println(total)

  }

  //Given that sum() is written by others and I cannot change it.
  def sum(k: Int): BigInt = {
    var total: BigInt = 0
    for (i <- 1 to k) {
      total += i
    }
    total
  }
}

上面的scala代码大约需要70s。

Answer 1

使用未来！

val resultFuture : Future[ReturnType] = Future.apply {
 longComputation
}

val resultMaybeCut = Await.result(resultFuture, DurationOfChoice)

作为记录，Await.result(awaitable: Awaitable[T], atMost: Duration) ：

• 如果当前线程在等待时被中断，则抛出 InterruptedException
• 如果在等待指定时间后awaitable 仍未准备好，则抛出 TimeoutException
• 如果 atMost 是 Duration.Undefined 则抛出 IllegalArgumentException

警告（感谢@markusthoemmes）：

这样做不会中断底层的未来计算，它只会让你轻松超时！ （这可能是也可能不是问题）。 如果我相信Kill or timeout a Future in Scala 2.10 没有超级简单的方法可以真正停止底层计算，所以您可能需要参考此处发布的其他解决方案！

Answer 2

现在的计算阻塞了你的主线程。那是您的程序正在运行的线程。在您的计算完成之前，您无法控制在该线程上执行任何操作。

您可以在单独的 Thread 中运行计算，并在您认为耗时过长时从主线程中终止该 Thread。

注意： 作为 Scala 初学者：线程通常不是 Scala 的方式，但在这种情况下，Scala 提供的抽象（即Futures）并不低水平足以达到你想要达到的目标。请不要将低级的Thread 方式视为您每天都应该做的事情。

Answer 3

如果您有一个紧密的循环并且只想在某个超时之前不满足条件时想要退出，则不需要线程：

def sum(k: Int, timeoutMillis: Long): BigInt = {
  val timeoutMillis = System.currentTimeMillis + timeoutMillis
  var total: BigInt = 0
  for (i <- 1 to k) {
    total += i
    if (timeoutMillis < System.currentTimeMillis) 
      throw new RuntimeException("Timed out")
  }
  total
}