Akka Vadeli İstisnalar

Question

Bir geleceğin aktörü bir istisna atarken ne olur? http://doc.akka.io/docs/akka/snapshot/scala/futures.html de Akka belgelerine göre

: İstisna yakalanması halinde bir Aktör veya hareket memuru Geleceği tamamladıktan ise

farketmez, Gelecek yerine geçerli bir bunu içerecektir sonuç. Bir Gelecek bir İstisna içeriyorsa, Await.result çağrısı, yeniden işlenebilmesi için yeniden atılmasına neden olacaktır.

Bu kod parçası çalıştırırken görüyorum budur emin değilim:

class Worker extends Actor { 
    def receive = { 
     case i: Int => throw new RuntimeException 
    }   
    } 

    implicit val system = ActorSystem("MySystem") 
    val worker = system.actorOf(Props(new Worker), name="worker") 
    implicit val timeout = Timeout(5 minutes) 
    val future = worker ? 0 
    val res = Await.result(future, 10 seconds) 

belgelerine göre, Await.result tekrar istisna, ama ne alıyorum olduğunu olmalıdır bir TimeoutException! Birisi bunu açıklayabilir mi?

Answer 1

Oyuncular için istisnayı ve return it as a failure status'u yakalamanız gerekir. Eğer bir zaman aşımı özel alıyoruz böylece Şimdi sen gönderene şey dönen değiliz: her zaman bir sonuç göndermek beri aktörler yok ederken

class Worker extends Actor { 
    def receive = { 
    case i: Int => { 
     try { 
     throw new RuntimeException 
     sender ! "Some good result" 
     } catch { 
     case e: Exception => 
      sender ! akka.actor.Status.Failure(e) // Alert the sender of the failure 
      throw e // Alert any supervisor actor of the failure 
     } 
    } 
    } 
} 

Vadeli, daha incelikle bu biraz işleyebilir (bu verecekti Yukarıdaki gibi aynı sonucu):

val future = Future { 
    throw new RuntimeException 
    }