Вопросы по теме 'actor'
Переход с параллелизма Java на параллелизм Scala
У меня есть довольно стандартный механизм в Java для решения проблемы:
Рабочие элементы должны быть запланированы для выполнения в определенное время
Затем каждый рабочий элемент должен ожидать, когда условие станет истинным.
Рабочие элементы...
1772 просмотров
schedule
06.04.2024
Scala Remote Actors - подводные камни
При написании кода Scala RemoteActor я заметил несколько подводных камней:
RemoteActor.classLoader = getClass (). GetClassLoader () должен быть установлен, чтобы избежать "java.lang.ClassNotFoundException"
ссылка не всегда работает из-за...
987 просмотров
schedule
19.11.2023
Использовать Post или PostAndAsyncReply с MailboxProcessor F#?
Я видел разные фрагменты, демонстрирующие сообщение Put , которое возвращает unit с MailboxProcessor F#. В некоторых используется только метод Post , в то время как в других используется PostAndAsyncReply , при этом канал ответа немедленно...
1167 просмотров
schedule
06.05.2024
Хорошо ли помещать операции jdbc в актеров?
Я создаю традиционное веб-приложение, которое выполняет операции CRUD базы данных через JDBC. И мне интересно, хорошо ли помещать операции jdbc в актеров из текущего потока обработки запросов. Я провел поиск, но не нашел руководств или примеров...
1509 просмотров
schedule
18.01.2024
Как сделать так, чтобы акторы scala сообщали о завершении задачи?
Мне нужно разбить серию удаленных вызовов на куски. Я думал об использовании актеров.
Я подумал о чем-то вроде этого:
class ControlActor() extends Actor{
var counter = 1000
def act{
for (i <- 1 until 1000) { new RequestActor(this)...
153 просмотров
schedule
02.11.2022
Параллельная обработка файлов в Scala
Предположим, мне нужно параллельно обрабатывать файлы в заданной папке. В Java я бы создал поток FolderReader для чтения имен файлов из папки и пул потоков FileProcessor . FolderReader считывает имена файлов и передает функцию обработки файлов...
5990 просмотров
schedule
17.02.2024
akka Actors — Реализация рабочих процессов, действий или диалогов
Допустим, я хочу реализовать ProgrammableRemote в акке —
ProgrammableRemote
- WatchMovie
1. Tv ! PowerOn
1.1 Tv ! ChangeInput 3
2. DVD ! PowerOn
3. AVReceiver ! PowerOn
3.1 AVReceiver !...
905 просмотров
schedule
17.03.2024
Scala - перечисление против классов случаев
Я создал акка-актера под названием LogActor. LogActors получает метод, обрабатывающий сообщения от других субъектов и регистрирующий их на указанном уровне журнала.
Я могу различать разные уровни двумя способами. Первый:
import LogLevel._...
6639 просмотров
schedule
05.03.2024
Как использовать фьючерсы с Akka для асинхронных результатов
Я пытаюсь одновременно писать в несколько файлов, используя инфраструктуру Akka. Сначала я создал класс с именем MyWriter, который записывает в файл, а затем, используя фьючерсы, я дважды вызываю объект, прыгая, что для меня будут созданы 2 файла, но...
1018 просмотров
schedule
24.11.2022
Akka: Что происходит, когда вы говорите ActorRef, а он ожидает, что вы спросите?
У меня есть следующее:
val future = myActor ? Message
И в моем актере мое сообщение о получении имеет что-то вроде этого:
sender ! Response
Если я сделаю следующее и проигнорирую ответ, будут ли какие-либо негативные последствия?...
2848 просмотров
schedule
04.11.2022
Как регистрировать все входящие сообщения от Akka (Java)
В Scala вы можете обернуть функцию получения с помощью LoggingReceive. Как добиться того же от Java API?
def receive = {
LoggingReceive {
case x ⇒ // do something
}
}
2214 просмотров
schedule
30.01.2024
ActorSelection не отвечает, когда используется подстановочный знак
Когда я вызываю actorSelection с подстановочным знаком и нет подходящих актеров, я ожидаю получить в ответ ActorIdentity(None,None) , но вместо этого ничего не происходит. Это нормальная ситуация или я что-то пропустил?
class A extends Actor...
286 просмотров
schedule
06.06.2024
Работники Erlang udp - хотите иметь больше слушателей udp на одном порту
Я делаю игровой сервер на Erlang и хочу иметь один процесс для каждого подключенного клиента. Предполагается, что этот процесс позаботится обо всех UDP-сообщениях, отправляемых на сервер клиентом, обрабатывая их и отвечая при необходимости.
Как...
693 просмотров
schedule
16.09.2022
Паттерн проектирования: как реализовать цепочку акторов, обрабатывающих одно логическое сообщение
Я начинаю смотреть на Akka, и мне интересно, как правильно реализовать конвейер актеров, сотрудничающих для обработки сообщения. Позвольте мне взять пример использования, чтобы проиллюстрировать мой вопрос:
У меня есть сообщение, которое...
873 просмотров
schedule
24.09.2022
Множественные вызовы Future в методе получения Актера
Я пытаюсь сделать два внешних вызова (к базе данных Redis) внутри метода receive Актера. Оба вызова возвращают Future , и мне нужен результат первого Future внутри второго. Я заключаю оба вызова в транзакцию Redis, чтобы никто другой не мог...
1243 просмотров
schedule
08.10.2022
Являются ли актеры AKKA хорошим решением для оптимизации моей установки?
Я работаю над проектом, в котором большая часть одновременного чтения и записи в БД снижает производительность. Представьте, что мне нужно время от времени переиндексировать всю БД, поэтому самый простой способ — установить флаг «грязный» в значение...
117 просмотров
schedule
15.12.2023
Ошибка актера Greenfoot не в мире
Когда мой враг доберется до нижней части экрана, я хочу удалить его, и если враг будет поражен пулями, я хочу удалить его. Ошибка: java.lang.IllegalStateException: Актер не в мире. Была предпринята попытка использовать местоположение актера, пока...
405 просмотров
schedule
04.01.2024
Интеграция Service Fabric, Akka.net и постоянного актора
У меня есть фрагмент кода из рабочего примера. В этом примере выполняется вызов REST (WebAPI) и опрос в структуре служб для опроса запросов. Есть пять участников (1) FileImportValidator для проверки имени файла (2) FileParser для анализа файла...
1996 просмотров
schedule
11.01.2024
Как ограничить доступ локальному актеру
Я ищу методы инкапсуляции, такие как private для членов класса. Я хотел бы, чтобы актер предоставил возможность принимать некоторые распространенные безопасные сообщения и привилегии, которые могут изменить состояние нежелательным образом. Я также...
29 просмотров
schedule
12.11.2023
Вызов клиента Azure Service Fabric к службе субъекта с удаленного компьютера возвращает ошибку неизвестного адреса
При попытке подключения к удаленному кластеру разработки с помощью следующего примера кода:
var proxy = ActorProxy.Create<IActor1_NoS>(ActorId.NewId(), "fabric:/applicationname");
Я получаю следующую ошибку:...
1484 просмотров
schedule
30.05.2024
