タイムアウトのあるブロックを実行するための標準のScala関数はありますか？

Question

タイムリーな結果を返すかもしれないし、返さないサービスを呼び出す必要があります。 Rubyのtimeoutのように - 私は仕事をする標準機能があります

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

書くことができるようにしたいのですが？

Answer 1

- 中標準ライブラリ関数がないので、私はFuturesルートをダウンしました。

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") 
    } 

私はこれは良いScalaのスタイルであるかどうかについてどのようなフィードバックに感謝するだろう！

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 Patternの実装ですCircuit Breaker for Scalaを見ている可能性があります。基本的にそれはあなたがタイムアウトを制御し、障害が（READMEから）

使い方はScalaで次のようになり、外部リソースへのアクセスが発生した場合、何が起こるべきことができます：

他の回答に信用して

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


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

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

Answer 5

まだ言及されていないものは、awaitEitherです。これは、アクターパッケージのFuturesオブジェクトのメソッドです。次いで

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} 
} 

このような例示的なものを使用することができるために、完了することが先物の対の最初から結果を返すawaitEither alarm戻り値の型に割り当てることができるUnitしたがって、awaitEitherはパターンマッチングできるものを返します。