actor

1熱

1答えて

私はscala.actors._をテストするには、以下の簡単なコードを書いた： // java version "1.7.0_02" // Scala code runner version 2.9.1.final // Windows 7 Ultimate sp1 64-bit import scala.actors._ import scala.collection.mutable.A

3熱

2答えて

はAkkaの俳優にScalaのアクターを回す：

のメソッドを呼び出すために1つのインスタンスは、最近、私はアッカ役者にScalaの俳優からの切り替えが、アッカの俳優ではなく、インスタンスオブジェクトのActorRefを使用していることに気づいた。 val actorRef: ActorRef = Actor.actorOf(new MyActor) だから私が試しました： val myActor = new MyActor val act

5熱

2答えて

Erlang/Scala 1つのノードから別のノードへアクターを移動する

SALSAという名前のActor Oriented Programmingでは、アクターを1台のマシンから別のマシンに移動することができます。これは、ScalaまたはErlangを使用して実行できるものであるかどうかは、2つのアクター指向のプログラミング言語であり、その背後には多くの勢いがあります。これらの言語のいずれかがこの機能をサポートしている場合は、このような実装方法を参照する資料を教え

5熱

1答えて

Akka-2インスタンスは、メールボックスをオーバーフローさせずにn TimeUnitsごとにメッセージを送信します。

Akka-2インスタンスは無限ループのままで、処理するデータがないか10分ごとにチェックする必要があります。ループを設計して、インスタンスが自分自身を呼び出し、何らかの作業をしてから一定時間スリープするようにするにはどうすればよいですか？また、メールボックスサイズをもうクエリできないことがわかりました。作業タスク（この場合はディスパッチ機能）がアクティブである限り、どのようにメッセージが無視さ

2熱

2答えて

スカラの俳優がぶら下がった

RSSフィード項目を取得し、処理してデータベースに保存する少数の俳優を産んでいます。これは、cronで実行されているオブジェクトの主な方法によって行われます。私はこれらの俳優を作成し、彼らに割り当てられた前の仕事を完了すると、彼らに仕事を出します。私のメインクラスは、ひとりの俳優、つまり俳優のプールに仕事を奪い取る俳優を生み出します。結局のところ、メインの方法はハングアップしているようです。終了し

17熱

2答えて

Akka 2のディスパッチャの違いと使用パターンは何ですか？

dispatchers in Akka 2の相違点や推奨される使い方を理解することができませんでした。私はBalancingDispatcherとCallingThreadDispatcherのふるまいを理解していると思いますが、私はDispatcherとPinnedDispatcherについて考えていません。 SharabilityとBulkheadingのどちらの概念もわかりません。

1熱

1答えて

Scalatest FunSuiteとAkka Actors

Akkaのアクターを使用し、sbtから実行するScalaTestテストスイートを作成したいと思います。私はこれを行うにしようとすると： class Tests extends FunSuite with BeforeAndAfterAll { override protected def beforeAll() { class Actor1 extends Actor {

2熱

1答えて

スカラの俳優のスマートなルーティング

私は3人のアクターの数が少ない（つまり10人と言います）タスクを実行する必要があります。しかし、実行時間が変わる可能性があるため、最初はすべてのタスクを配布したくありません。だからこそ私は1つのタスクをすべて送信する必要があります。また、いずれかのタスクが完了すると、新しいタスクが与えられます。この方法では、最初のタスクが3秒かかり、0.5秒しか休まず、3秒で完了します。 (() => Thre

0熱

1答えて

メッセージが渡されたときに返される未来が予想されるかどうかをAkkaの俳優が区別しなければなりませんか？

私はそれを理解しているので、俳優には「火と忘れて」というメッセージを送ることができます！演算子、または "Send-and-Receive-Future"スタイルを？オペレーター。メッセージを介して渡される俳優？ self.replyを呼び出す必要があります。そうしないと、送信者はタイムアウト例外を受け取ります。一方、メッセージを介して渡される俳優！メッセージが別のアクタから渡されていない場合はs

22熱

2答えて

アクターベースのWebサービス - 正しく行う方法？

私と私の同僚は過去数ヶ月間、プッシュ通知をiPhoneデバイスに送信するためのサーバー側システムを構築しました。基本的には、ユーザーはRESTfulなWebサービス（Spray-Server、最近はSpray-canをHTTP層として使用するように更新されています）を介してこれらの通知を登録し、Akkaのスケジューラを使用して今後ディスパッチする1つまたは複数のメッセージをスケジュールします。こ