Вопросы по теме 'actor'

Вызов нескольких субъектов из блокирующего вызова
Вероятно, это простая проблема для ума, образованного scala, но я все еще новичок;) У меня есть базовый актер, который отправляет задачу нескольким рабочим акторам и отвечает ее результатом на блокирующий внешний вызов через!? a = new a...
244 просмотров
schedule 11.02.2023

Вызов блокирующего Актера из Актера
Учитывая, что я вызываю Actor изнутри, блокирует ли это вызов Actor или он все еще обрабатывает другие запросы? class worker extends Actor() { def act() = { loop { react { msg => var foo = another_actor !?...
808 просмотров
schedule 20.11.2022

определение сообщения актора scala
Нужно ли мне определять класс для сообщения, которое я хочу получить на актере scala? я пытаюсь понять, где я ошибаюсь def act() { loop { react { case Meet => foundMeet = true ; goHome case Feromone(qty)...
1424 просмотров
schedule 17.05.2023

Как это реализовано на языках, поддерживающих модель акторов?
Модель акторов хорошо описана Гул Ага в его техническом отчете «Актеры: модель параллельных вычислений в распределенных системах». На странице 49 он объясняет команду «стать»: become <expression> После вызова «стать X» актер...
873 просмотров
schedule 02.05.2024

программа зависает при использовании нескольких фьючерсов с несколькими удаленными акторами
Я запускаю двух удаленных актеров на одном хосте, которые просто повторяют все, что им отправляется. Затем я создаю другого актера, который отправляет некоторое количество сообщений (используя !! ) обоим актерам, и сохраняю объекты List of Future,...
764 просмотров
schedule 02.09.2023

Актеры Scala вместо Java Futures
Проблема : мне нужно написать приложение для обработки нескольких сотен файлов, на выполнение каждого из которых уйдет несколько сотен мегабайт и несколько секунд. Я написал его с использованием Future[Report] объектов, созданных с помощью...
1126 просмотров
schedule 05.05.2024

Обнаружение сервера удаленного актора Akka
Я хотел бы развернуть программное обеспечение удаленных участников, созданное с помощью akka, на кластере. Система состоит из нескольких рабочих узлов и одного главного узла. Проблема в том, что я не могу заранее знать IP-адрес узлов кластера (но я...
3616 просмотров
schedule 10.01.2024

Пример клиент-сервер с акторами Scala
Как лучше всего реализовать следующий пример? Актер server получает Requests , обрабатывает их, создает новый Response для каждого Request и отправляет Response обратно отправителю Request . Актер client отправляет Requests и...
1807 просмотров
schedule 23.12.2023

Подкласс Scala Actor не может получить доступ к mailboxSize?
У меня есть такой код: package something import scala.actors.Actor import scala.actors.Actor._ class Foo extends Actor { private val random = new Random() def doWork() { if (self.mailboxSize >= 3) { println("Actor loaded, use...
437 просмотров
schedule 15.05.2022

Отправка сообщений функциям в Scala
Я работаю над книгой Брюса Тейта Семь языков за семь недель. и мне трудно понять его реализацию sizer.scala (Scala: день 3). В частности, рассмотрим следующий объект Singleton object PageLoader { def getPageSize(url : String) =...
540 просмотров
schedule 24.06.2023

Как реализовать аутентификацию с помощью удаленных акторов?
Я работаю над карточной игрой, и кажется, что актеры — особенно удаленные актеры — подошли бы. У меня возникли проблемы с выяснением того, как реализовать понятие входа в систему с использованием удаленных актеров. Если игрок запускает толстый...
1486 просмотров
schedule 14.09.2022

Фреймворк Akka (Scala) — агенты для хранения большого сложного состояния
Недавно я открыл для себя фреймворк akka и понял, что он хорошо подходит для одного из моих проектов. Я должен сказать, что я очень впечатлен этим до сих пор. В моем проекте мне нужно, чтобы более 1 млн сущностей получали обновления состояния с...
2314 просмотров
schedule 23.03.2024

Распределенные актеры в Akka
Я новичок в Akka и новичок в распределенном программировании в целом. Используя компонент Akka Mist, я создал контролируемых субъектов для асинхронной обработки HTTP-запросов. В настоящее время все работает на одной физической машине с локальными...
2245 просмотров

Отменить все сообщения, кроме последнего, в акторе Scala
У меня есть SwingWorker актер, который вычисляет график для отображения из объекта параметров, который он получает; затем рисует график в ветке EDT. Некоторые элементы графического интерфейса могут изменять параметры этого графика. Когда они...
185 просмотров
schedule 05.06.2024

Синхронные вызовы в модели akka/actor
В последнее время я изучаю Akka, и это похоже на отличную основу для создания масштабируемых серверов на JVM. Однако большинство библиотек в JVM блокируются (например, JDBC), поэтому не теряете ли вы преимущества производительности от использования...
1261 просмотров
schedule 09.05.2024

разветвляться и присоединяться с помощью Akka
постановка задачи: у меня есть портфель ценных бумаг, которые необходимо обрабатывать параллельно. В Java я использовал пул потоков для обработки каждой безопасности и использовал защелку для обратного отсчета. После завершения я делаю некоторые...
1322 просмотров
schedule 17.04.2022

Отслеживание иерархии отправителей в Scala акторах
В настоящее время я поддерживаю пару Scala-приложений на основе акторов, и один вопрос, который я постоянно задаю: Кто отправляет это сообщение? Например, я нахожу кусок кода, который печатает страшное сообщение, которое я нашел в журналах:...
196 просмотров
schedule 04.04.2023

Блокировка в будущем scala?
У меня есть очень длинная последовательность строк, которые по отдельности должны быть обработаны некоторой функцией обработки, а затем собраны как другой объект последовательности. Проблема кажется идеально подходящей для атаки типа fork/join....
422 просмотров
schedule 06.05.2023

Сценарии для игрового актера
Я хотел бы добавить несколько сценариев к своим моделям/актерам. Когда загружается новая модель или изменяется сценарий, актер реагирует. На данный момент у меня есть базовый класс Lua, в котором есть, например, функция Update(), и каждая...
431 просмотров
schedule 29.01.2024

Akka TypedActor против написания собственного статического интерфейса для класса Actor
Я использую Akka и Scala около месяца, и меня несколько беспокоит замена явных интерфейсов сообщениями. Рассмотрим следующего простого актера Akka: case class DoMyHomework() class Parent extends Actor { def receive = { case d: DoMyHomework...
4260 просмотров
schedule 03.01.2024