actor

2熱

1答えて

2つのローカルインスタンスがAkkaアクターと通信するために必要な最小限のコードは何ですか？

マシン上でアプリケーションの2つのインスタンスを開始するために必要な最小限のコードは、互いにメッセージを送受信できますか？私の知る限り理解し、私がメッセージを処理できる俳優を開始するが必要になります。このインスタンスには、メッセージを送信できる別のインスタンスがあることを伝えます。どうすればいいですか？ Akka's home pageから

1熱

2答えて

Akkaのデバッグ出力を無効にする方法はありますか？

Akkaを使っている間、私は単純なコマンドラインアプリを実装しました。しかし、アッカはまたのようなコマンドラインに文を印刷します。このデバッグ出力を無効にする（または他のどこかにリダイレクト）する方法はあり [GENERIC] [27.10.11 22:57] [RemoteClientStarted([email protected],/127.0.0.1:3000)] [GENERIC]

3熱

1答えて

Akka - 反射を使ってアクターを作成する

正確なタイプが実行時に構成ファイルから読み取られるだけのアクターを作成する必要があります。そのアクターのコンストラクターは自明ではありません。つまり、構成ファイルで定義されているいくつかのパラメーターが必要です。今まで、私は次のように、この使用して反射を行うことを試みた： val actor = actorOf(constructor.newInstance(parameters: _*).as

6熱

1答えて

スカラーの俳優の数が多いのは、

です。httpサーバーを実装したいのですが。私はリクエストごとに新しいアクタを作成します。だから私のCPUが更新されるとスケールアップすることができます。メモリ使用の問題が発生しますか？それは俳優がgcの間にいくつかの奇妙な行動をしていると言われています。コードが何らかの形でそのようになります。 class Worker extends Actor { def act = reac

6熱

1答えて

Akkaで「自己」とは何ですか？

Akkaサンプルを読んだだけで、self.replyの定義方法は理解できません。私が見る限り、self replyはreceiveブロック内でメッセージに返信します。しかし、replyまではselfの方法ですが、selfは何ですか？ PS：あなたは、Akkaの基本とリモートアクターについてScalaで良いクイックスタート記事をお勧めしますか？ここにコメントを投稿することができたらうれしいです。今す

7熱

1答えて

Akkaを使用したフォーク＆ジョイン

問題文：私は、並列に処理する必要がある有価証券のポートフォリオを持っています。 Javaでは、私は各セキュリティを処理するためにスレッドプールを使用し、カウントダウンにラッチを使用します。完了したら、いくつかのマージなどを行います。私はSecurityProcessor（アクター）にメッセージを送り、すべての未来が完了するのを待ちます。最後に、MergeHelperを使用して後処理を行います。

3熱

1答えて

別のスレッドを排他的に使用して実行するScalaアクターを設定するにはどうすればよいですか？

私が理解する限り、Scalaはスレッドプールを管理して、アクターを実行し、それらの間でスレッドを共有します。私は別のスレッドで排他的に実行するように特定のアクターを設定し、他のアクターと共有することはできませんか？

0熱

2答えて

java mavenプロジェクトのスカラクラスを使用したコンパイルエラー

私はjava mavenプロジェクトを持っています。私はEclipse用のscalaプラグインをインストールし、自分のプロジェクトにscala natureを追加しました。さて、私はいくつかのカスタムスカラーアクターと他のユーティリティクラスを書いています。これらのスカラークラスを私のJavaコードで使用しています。コードを書いている間、それは私がきれい/ビルドをMavenを行う際.Butが、それ

0熱

1答えて

自己俳優が返答に掛かります

私はScala版1 30.3（p589）に従っています。ここでは、現在のスレッドのアクターとして 'self'を使用して、replのアクターをデバッグすることができると説明しています。しかし、Scala 2.9.1に従うと、スレッドは受信時にハングします。 $ scala -unchecked -deprecation Welcome to Scala version 2.9.1.final (

2熱

2答えて

Scala Actors：アクターを停止/中断するための組み込みの方法はありますか？ Javaでは

私は、たとえば、スレッドとの趣味を持っています。その後、 Thread thread = new Thread() { @Override public void run() { //use this while loop, I can stop/ interrupt the thread when I want while (!isInterrupted