multithreading - 如何编写等待事件的未来

Question

我有一个客户端/服务器套接字，它可以做一些 rpc 事情。我对 finagle 有所了解，我发现 Future 的隔离非常优雅。所以我的问题是如何在scala中编写一个等待事件的Future（我的客户端请求的服务器回复）。该实现可能会使用已识别的请求，但我缺乏的是要求未来等待事件而无需忙碌等待的方式。

Answer 1

创建一个Promise代替Future并向您的事件添加一个侦听器，以实现承诺。将承诺的未来返回给您的客户（在 Twitter Util 未来库中它是承诺本身，在 Scala 2.10 中它是p.future）。

Answer 2

为此，您需要查看Akka Actors

这是一个演员的例子

class MyActor extends Actor {
   val log = Logging(context.system, this)
   def receive = {
      case "test" ⇒ log.info("received test")
      case _      ⇒ log.info("received unknown message")
   }
}