Ngoại lệ tương lai của Akka

Question

Điều gì sẽ xảy ra khi một diễn viên của tương lai ném một ngoại lệ?

Theo tài liệu Akka tại http://doc.akka.io/docs/akka/snapshot/scala/futures.html:

Nó không quan trọng nếu một diễn viên hoặc điều phối được hoàn thành tương lai, nếu một ngoại lệ được bắt được trong tương lai sẽ chứa nó thay vì của một hợp lệ kết quả. Nếu một tương lai có chứa một ngoại lệ, gọi Await.result sẽ khiến nó bị ném trở lại để nó có thể được xử lý đúng cách.

Tôi không chắc chắn đây là những gì tôi nhìn thấy khi chạy đoạn mã này:

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) 

Theo tài liệu, Await.result nên ném ngoại lệ một lần nữa, nhưng những gì tôi nhận được là một TimeoutException! Ai đó có thể làm rõ về điều này?

Answer 1

Đối với diễn viên, bạn cần phải nắm bắt ngoại lệ và return it as a failure status. Ngay bây giờ bạn không trở về bất cứ điều gì cho người gửi, do đó bạn sẽ nhận được một ngoại lệ timeout:

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

Futures có thể xử lý này một chút duyên dáng hơn vì họ luôn gửi Kết quả là, trong khi diễn viên không (điều này sẽ cung cấp cho bạn cùng kết quả như trên):

val future = Future { 
    throw new RuntimeException 
    }