是否有一个标准的Scala函数用于运行带超时的块？

Question

我需要调用一个可能返回或不返回及时结果的服务。我希望能写

val result = runWithTimeout(5000, valReturnedOnTimeout) { service.fetch } 

有没有一个标准功能，将做的工作 - 像Ruby的timeout？

Answer 1

以信誉其他的答案 - 在没有任何标准库函数，我已经走下了期货路线。

import scala.concurrent._ 
    import scala.concurrent.duration._ 

    def runWithTimeout[T](timeoutMs: Long)(f: => T) : Option[T] = { 
    Await.result(Future(f), timeMins milliseconds).asInstanceOf[Option[T]] 
    } 

    def runWithTimeout[T](timeoutMs: Long, default: T)(f: => T) : T = { 
    runWithTimeout(timeoutMs)(f).getOrElse(default) 
    } 

这样

@Test def test { 
    runWithTimeout(50) { "result" } should equal (Some("result")) 
    runWithTimeout(50) { Thread.sleep(100); "result" } should equal (None) 
    runWithTimeout(50, "no result") { "result" } should equal ("result") 
    runWithTimeout(50, "no result") { Thread.sleep(100); "result" } should equal("no result") 
    } 

我会的任何反馈表示感谢，这是否是一个很好的斯卡拉风格！

Answer 2

您可以在一个新的线程中启动它，然后等待它完成Thread.join。如果你传递一个参数来加入，它最多等待几毫秒。

val t = new Thread { 
    override def run() { 
    //... 
    } 
} 
t.start() 
t.join(5000) 

Answer 3

可能Futures和它的alarm有窍门吗？

Answer 4

你可以使用一个未来

import scala.actors.Futures._ 

val myfuture = 
    future { 
    Thread.sleep(5000) 
    println("<future>") 
    "future " 
} 

awaitAll(300,myfuture) foreach println _ 

但也看看Circuit Breaker for Scala是的 Circuit Breaker Pattern一个实现。基本上，它可以让你控制超时，如果发生故障访问外部资源

使用看起来像这样在斯卡拉（自述）会发生什么：

. . . 
addCircuitBreaker("test", CircuitBreakerConfiguration(timeout=100,failureThreshold=10)) 
. . . 


class Test extends UsingCircuitBreaker { 
    def myMethodWorkingFine = { 
    withCircuitBreaker("test") { 
     . . . 
    } 
    } 

    def myMethodDoingWrong = { 
    withCircuitBreaker("test") { 
     require(false,"FUBAR!!!") 
    } 
    } 
} 

Answer 5

还没有提到的东西是等待，这是一个关于actors包的Futures对象的方法。 awaitEither返回从第一一对期货的结果来完成，因此，例如像这样，可以使用：

awaitEither(future{task}, alarm(timeoutPeriod)) 

，然后在方法装扮成提示：

def runWithTimeout[T](timeoutPeriod: Int, timeoutValue: T)(task: => T) = { 
    awaitEither(future{task}, alarm(timeoutPeriod)) match {case() => timeoutValue case x => x} 
} 

报警返回可赋值给Any类型的val的单元，因此awaitEither返回可与模式匹配的东西。