Результаты поиска по запросу "actor"

3 ответа

Как перегрузить оператор взрыва (!) В модели Scala Actor?

В реализации модели Actor в Scala мы можем переопределить оператор bang (!). Можем ли мы изменить операцию передачи сообщений, перегрузив этот оператор? Пример сценария: мне нужно включить регистрацию информации, когда любой актер вызывает ...

1 ответ

временное моделирование с актерской моделью

у нас есть однопоточное приложение, которое моделирует взаимодействие сотен тысяч объектов с течением времени с моделью общей памяти. очевидно, он страдает от невозможности масштабирования на многопроцессорном оборудовании. Прочитав немного о ...

1 ответ

Как создать TestActorRef в Scala для Actor с параметрами конструктора?

Акка Тестирование документов [http://doc.akka.io/docs/akka/snapshot/scala/testing.html]дать следующий способ создания TestActorRef: import akka.testkit.TestActorRef val actorRef = TestActorRef[MyActor]Как расширить это для тестирования ...

ТОП публикаций

2 ответа

Как правильно использовать актеров акка в скале

Я относительно новичок в представлениях об актерах, и мне было интересно, могу ли я получить некоторую критику в отношении того, что я делаю. Для части проекта мне нужен актер, который сообщает собравшимся актерам время. Актеры-слушатели должны ...

3 ответа

с помощью инъекции guice с актером выбрасывает нулевой указатель

Я получаю исключение нулевого указателя при внедрении поля сервера, который запускается как актер akka. Вводная часть: private ActorRef myActor = Akka.system().actorOf( new Props(Retreiver.class)); @Override public void onStart(Application app) ...

1 ответ

составление нескольких черт в akka актеров

Я создаю несколько черт, которые расширяют Актер. Затем я хочу создать актерский класс, который использует некоторые из этих черт. Однако я не уверен, как объединить методы receive из всех признаков в методе receive класса Actor. Черты: trait ...

3 ответа

Альтернативы использованию «вар» для государства с актерами?

Я часто использую переменные с актерами Акки, чтобы поддерживать состояние. Например, если мне нужно, чтобы мой актер вел список предметов, я мог бы сделать что-то вроде: class ListActor extends Actor{ var xs : List[Int] = List() def receive = { ...

1 ответ

Поддерживает ли Akka обмен сообщениями в процессе без сериализации объектов?

Нужно использовать Akka Actors для передачи событий между потоками Java в одной и той же JVM. Некоторые из этих событий содержат большие объекты (10-100 МБ). Я хочу избежать сериализации этих объектов при экономии места в памяти, передавая только ...

1 ответ

Akka Routing: отправка ответа на маршрутизатор заканчивается как мертвые буквы

Я играю с Actor Routing, и я не могу отправить ответ обратно маршрутизатору, чтобы другой актер из списка маршрутизации мог это заметить, чего я здесь не вижу;) Я использую: sender.tell([Message], context.parent)чтобы ответить маршрутизатору, ...