actor

    0

    1答えて

    私はScalaでakkaアクターを使用しています。私は受け取ったメッセージを処理している間に定期的に他のメッセージのためにそのメールボックスをチェックし、このメッセージに続いてその変数を変更することができるアクターを持つ方法があるかどうかを知りたい。 のようなスキーム: class Actor1 (constructors){ def receive={ case "go"

    4

    1答えて

    対context.actorOf あなたはsystem.actorOf と context.actorOf の違いは何である私に説明してもらえます ?これに

    0

    1答えて

    私は、主要なタスク 俳優Aを完了する必要があり、次の要件 を持っています。メッセージは、それがために俳優のBに渡し「特別」である場合には、主要なタスクを実行します処理し、タスク アクターBを終了:主要なタスクのために特別な論理タスクを実行し、AとBは一緒にこの 実装 public static class ActorA extends UntypedActor { public vo

    1

    1答えて

    私はシミュレーションを行い、データを返すアクターを持っています。私はシミュレーションを複数回実行できるようにしたいので、各アクタの内部状態をリセットする必要があります。 アクターの内部状態をリセットして、作成時と同じ状態にするにはどうすればよいですか?

    0

    1答えて

    Androidアプリケーションのバックグラウンド作業は、順次プロセス(つまり、BlockingQueueでコマンドをリッスンするスレッド)を通信することによって行われます。 スレッド/役者はMainApplicationに初期化されます。 BlockingQueue上のいくつかのコマンドがonResumeが呼び出される前に到着することができ、たとえばActivity.onPause中にこれらのスレ

    1

    1答えて

    最近、akkaのアクターとhttpモジュールを使いこなし始めました。しかし、私はちょっと面倒な小さな変わった話、つまりシングルトンの俳優をつくった。 はここで2つの例です: 1) 私は、メモリ内キャッシュを持っているが、私のサービスは非常に小さい(そのアプリではなく)ので、私は本当にメモリモデルでは、このような。私はマップにユーザーに関連するほとんどの情報を保持することができます(しかし、リストの

    0

    1答えて

    サービスをアクタに挿入する方法がわかりません。 私はいくつかのアプローチを試してみましたが、これは一番合うと思います。 私は、パラメータとして次のアクターにwebsocketを提供することが大きな問題だと思います。 Injectをクラス・シグネチャにプルすると、シグネチャの競合が原因でコンパイルが実行されません。 サービスを注入するために暗黙のクラス宣言を追加しようとしましたが、これもうまくいきま

    0

    1答えて

    以下のコードを見て、私の出力がdeadLettersを指している理由を説明してください。 class DemoActor extends Actor { def receive = { case "foo" => println(sender()) } } object Main extends App { val actorSystem = Act

    2

    1答えて

    私はsbtタスクを実行します。終了後の通常のシナリオでは、ターミナルで停止する必要があります。しかし、端末は次の入力の意味を待っていません。タスクが起動した後にスレッドと呼ばれるものがいくつか出ていないと仮定します。 sbtタスクによって開始されたすべてのプロセスを終了して終了するにはどうすればいいですか? どのサービスが停止していないのかをデバッグすることはできましたが、それには時間がかかります

    1

    1答えて

    プロダクションでLagomアプリケーションをセットアップしようとしています。私はLightbend for ConductRライセンスに連絡してみましたが、年齢を聞いたことはありません。だから、今私は別のアプローチを探しています。私は複数の質問があります。 アプリケーションの規模が今はかなり小さいので、私は(他の選択肢にオープン)、静的なサービスロケータを使用すると、今の私の作品だと思います。また