actor

10熱

3答えて

自分のスレッドからアクカのアクタと交流したいです。現在、私はそうです： val res = Await.result(aref ? GroupReceive(fromRank), timeout.duration).asInstanceOf[T] しかし、これは実際に私のスレッドとどのように対話するのですか？受信を非同期にすることを希望します。つまり、受信中にスレッドをハングアップして他の作業

5熱

3答えて

アクターシステムで暗黙的に要求コンテキストを渡す

コラボレーションアクターのシステムに暗黙的に要求コンテキストを伝搬したいと思います。私のシステムには複数のアクターがあり、これらのアクターに渡されるメッセージにはこのRequestContextオブジェクトが含まれている必要があります。 ActorAはMessageAの処理の一部として、それがビジネスロジックを実行し、その後からMessageBを構築ActorAがActorBにメッセージを送信す

5熱

1答えて

Scalaでタスクを中断する方法は？

私が理解しているようにScala Actorsはを中断できません。今私はタイムアウトのタスクがあるとします。タスクがタイムアウト内に終了しない場合、私はそれを停止する必要があります。タスクが割り込み可能であるとします。（割り込み可能なチャネルで割り込みI/Oを実行するなど）。 Javaでは、別のスレッドでタスクを実行し、タイムアウト時にスレッドを中断できます。 Scala Actorsでこれを行

19熱

1答えて

コンストラクタparamsを持つActorに対して、ScalaでTestActorRefを作成するにはどうすればよいですか？

Akka Testing docsはTestActorRefを作成するには、次の方法を与える： import akka.testkit.TestActorRef val actorRef = TestActorRef[MyActor] 私は、コンストラクタの引数を取り、既存の俳優をテストするためにこれを拡張する方法を教えてください。俳優 akka.actor.ActorInitiali

6熱

2答えて

スカラで部分的に実装された部分関数を拡張する

ここではAkkaアクターライブラリを使用しています。アクターライブラリは、さまざまなメッセージを処理するために "アクター"を拡張するアクターが実装する必要がある部分的な関数 "receive"を定義します。私は "clockActor"という特性がActorを拡張し、 "MasterClock"と "SubClock"が "clockActor"を拡張する私のアプリケーションのための特性階層を作

7熱

3答えて

ScalaでFuturesがActorsよりも適切な場合（またはその逆）はいつですか？

いくつかの並行タスクを実行する必要があるとします。各タスクをFutureにラップして完了するまで待つことができます。あるいは、各タスクに対してActorを作成することもできます。各Actorは、（例えば、「開始」メッセージを受信すると）そのタスクを実行し、結果を戻す。 IアプローチとFutureアプローチは、上述の場合を良好であると考えられる理由（Actor Sと）（Future sの）前者と後

7熱

2答えて

Akka - コモン・サービスの俳優：識別または拡張

他の俳優のサービス層の俳優によって一般的に使用されているものがあるとします。たとえば、ドメインオブジェクト取り出し店や、レジストリサービス： case class DomainObject(id: UUID) class Registry extends akka.actor.Actor { def receive: Receive = { case o: DomainOb

6熱

3答えて

akkaでアクター階層を手動で作成する

私のアプリケーションは、アクターのツリー構造を作成できる必要があります。これを行う標準的な方法は、インスタンス化コードをアクタの内部に配置して、子をインスタンス化できるようにすることです。私はむしろ、与えられたパスでアクターをインスタンス化することができると考えています。たとえば、mySystemにアクタAを作成し、次にakka：// mySystem/A/Bと他のアクタを直接作成することができま

16熱

1答えて

アクターごとのアクセルソケット

アクカIOでのScalaの使用は、アクタを厳重にリスニングしてから接続が確立されると、そのソケット（リーディング、ライティングなど）を担当する新しいアクタを作成する方法ですか？これまでのところ私はこれを持っています。問題は、サーバーアクターがデータを受信していることです。ソケットに関連するメッセージを受け取れるように、ソケットの所有権を新しい作成されたClientアクタに転送したいと思います

36熱

1答えて

スカラ俳優とアンビエントリファレンス

Phillip Haller's PhD thesisで彼は興味深い研究分野の1つがアンビエントリファレンスでフレームワークを拡張することであり、Van Cutsenの論文を引用した（5.1未来研究）。抜粋： Scalaのアクターライブラリは、リモート（すなわち、インターVM）アクターの通信のための基本的なサポートを提供するランタイムシステムを含みます。（モバイルアドホックネットワークなど）