multithreading - イベントを待つ未来の書き方

Question

いくつかの rpc 処理を行うクライアント/サーバー ソケットがあります。私はフィナグルについて少し知っており、未来との分離は非常にエレガントだと思います。したがって、私の質問は、イベント (クライアント要求のサーバー応答) を待機する Future を scala で記述する方法です。実装はおそらく識別されたリクエストを使用しますが、私が欠けているのは、ビジーな待機なしでイベントを待機するように未来に依頼する方法です。

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