Zamanaşımı olan bir bloğu çalıştırmak için standart bir Scala işlevi var mı?

Question

Zamanında sonuçları olan veya olmayan bir hizmeti aramam gerekiyor. Ruby'nin timeout gibi - İşi yapacak standart bir işlevi var mı

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

yazabilmek istiyorum?

Answer 1

- in Herhangi bir standart kütüphane fonksiyonunun yokluğu, Futures rotasına gittim.

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

Böylece

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

Bunun iyi Scala tarzıdır olmadığı konusunda herhangi bir geri bildirim için minnettar olurdum! Henüz söz edilmemiştir

Answer 2

Yeni bir Konuda başlatabilir ve ardından Thread.join ile bitirmesini bekleyebilirsiniz. Katılmak için bir parametre iletirseniz, en çok milisaniye bekler.

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

Answer 3

Kudreti Futures ve onun alarm hile yapmak?

Answer 4

İlerideki bir

import scala.actors.Futures._ 

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

awaitAll(300,myfuture) foreach println _ 

kullanmak Ama aynı zamanda Circuit Breaker Pattern bir uygulamasıdır Circuit Breaker for Scala bir göz olabilir. Temel olarak size aşımını kontrol etmek ve bir arıza (readme itibaren)

Kullanımı Scala şöyle harici kaynağa erişen oluşursa ne olur gerektiğini olanak tanır:

diğer cevaplara kredi ile

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


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

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

Answer 5

şey awaitEither, aktörler paketin Vadeli nesne üzerinde bir yöntemdir.

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

ve daha sonra bir yöntemde giyinmiş önerildiği gibi:

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

awaitEither böyle örneğin bir şey kullanılabilir, böylece tamamlamak için vadeli bir çift ilk sonucunu döndürür alarmı, herhangi bir tipte bir atama ile atanabilir Birimi, her iki durumda da eşleştirilebilecek bir şey döndürür.