actor

1熱

1答えて

を集約以下の俳優が一度分子と分母の両方が受信された除算を行い、 package funnelTest import akka.actor.{Actor, ActorSystem, Props} object Main extends App { val system1 = ActorSystem("funnelTest") val input = system1.ac

2熱

1答えて

別のツリーブランチからアクセルacessing俳優

私はいくつかの俳優とAkkaアプリケーションを持っています。アクターツリーは次のようになります。 /user /one TARGET /two /three SOURCE TARGETアクターにメッセージを送信する必要があります。しかし、私はそれを正しく行う方法を知らない。毎回ActorSelectionからActorRefを解決すると、非常に悪いよ

2熱

1答えて

libgdxアクタは位置を変更しません

アクタを独自のactor.act()メソッドで移動すると、位置が完全に更新されます。しかし、私が俳優を移動させると、moveBy()メソッドまたはmoveByアクションでアクターが移動しますが、アクターは移動しますが、そのgetX（）およびgetY（）値は移動前と同じになります。彼がそのact()メソッドによって移動されていないときに、俳優がその位置を更新する方法はありますか？ローカル座標で俳優の

2熱

1答えて

次のように、私は定期的にAPIを照会アッカの俳優を構築しました

アッカ俳優のうち、メッセージを取得します。 val cancellable = system.scheduler.schedule(0 milliseconds, 5 seconds, actor, QueryController(1)) 俳優を、本質的には次のとおりです。 object UpdateStatistics { /**

1熱

1答えて

アクカの俳優メイルボックス（スカラ）からのすべてのメッセージのクリーニング

アクターのメールボックスからすべてのメッセージを消去する方法はありますか？実際には、私はいくつかの頻度（例えば1秒）でそれを行う必要があります。はいの場合 - >これを行う最も簡単な方法は何ですか？

2熱

3答えて

この非同期アクター初期化イディオムの名前はありますか？

初期化するために非同期的に取得されたデータを必要とするアクタを作成するたびに、自分自身がこのようなイディオムを使用していることがわかります。名前はありますか？（そして、それはそれを行うための最良の方法です？） class AsyncInitActor(db: Database, someId: UUID) extends Actor with ActorStash { case cla

2熱

2答えて

アクターモデルでMVCCを実現する方法

私は、私のEmployeeエンティティをアクターとして表現しています。私は俳優としてもモデル化された2つのサービスを持っています。両方とも、メッセージを送信することによって受け取った従業員の俳優の状態を操作します。さて、両方のサービスが同じ俳優を処理しているとしましょう。今ではこれで結構です従業員の俳優は、2つのサービスAから以下の順に状態変化するメッセージを受け取ることは完全に可能であるとB E

0熱

1答えて

カスタムakkaメールボックスの設定（Scala）

MyUnboundedMessageQueueSemanticsの特性に由来するCustomMailBoxというカスタムメールボックスを作成しました。私は私の俳優こうして作成した後 custom-dispatcher { mailbox-requirement = "com.MyUnboundedMessageQueueSemantics" } akka.actor.ma

1熱

2答えて

リクエストをブロックするためのAkkaアクタープール

ブロックプールを使用してブロックリクエストを作成しようとしています。問題は、各リクエストがプール全体をブロックしており、アイテムが順番に処理されていることです。これが可能であるかどうかは不明です。誰かが city-dispatcher { type = Dispatcher executor = "thread-pool-executor" thread-pool

1熱

1答えて

アクタを使用して監視する、定義された回数だけ定義された回数だけ同じメッセージを再試行する方法

akka.ioのフォールトトレランスhttp://doc.akka.io/docs/akka/current/java/fault-tolerance.htmlのコードをフォローしています。このコードをreference.Myの必要条件としています。アクターがメッセージでクラッシュし、スーパーバイザによって再起動されたとします。次に彼は彼のメールボックスに次のメッセージを処理し始めます。クラ