俳優内のFuture.pipeToの処理

Question

私の俳優の中で、サードパーティのライブラリ（未来を後戻りさせる）への呼び出しがあります。私はその未来を自己に配管しているので、返信をメールボックスのメッセージとして処理することができます。

class MyActor{ 
    def receive:Receive = { 
    case x:Message => { 
     val future = callToThridPartyLib(x) 
     future pipeTo self 
    } 
    case x:Reply => { 
     //process reply received on future completion 
    } 
    } 
} 

私の質問は、このアプローチのオーバーヘッドは何

1. ですか？

2. このようなパイプごとに別々のスレッドが割り当てられますか。 ステートメント？

3. そうなら、 スレッドがすべて使い果たされるのを避けるためにpipeToを管理するスレッドプールが必要ですか？

は、基本的にビクターが言う何

Answer 1

ありがとう、しかし： はpipeToのオーバーヘッドが非常に低いです：それは、一つのメッセージを送りつの閉鎖を作成します。それだけです。スレッドを追加する必要はありません。 Futureが完了したスレッドからメッセージが送信され、すべてのアクターメッセージのように、指定されたアクターに対して構成されたディスパッチャーで受信されます。

callToThirdPartyLibでもExecutionContextの世話をする必要があります。内部でブロッキング呼び出しを使用していて、デフォルトのAkkaディスパッチャを使用してコードを実行すると、スレッドが不足することがあります。しかし、これは質問のために話題にはならないようです。