Описание тега akka-dispatcher
1
ответ
Операция блокировки в Actor НЕ занимает все диспетчеры по умолчанию
Я изучаю Akka Actor недавно. Я прочитал документ диспетчеров в Actor. Мне любопытно по поводу операции блокировки у актера. Последняя тема в документе описывает, как решить проблему. И я пытаюсь воспроизвести пример эксперимента в документе. Вот мой…
04 авг '17 в 16:12
0
ответов
Как мне контролировать исполнение актерской системы в Akka во время выполнения?
Я пытался найти способ управления передачей сообщений во время выполнения в системе акторов с помощью какого-либо внешнего (отдельного от системы акторов) контроллера. Другими словами, с учетом действующей системы (которую я не хочу менять): как мне…
25 мар '18 в 15:31
3
ответа
Scala/Akka: почему фьючерсы в фьючерсах работают последовательно при запуске в Akka Dispatcher
Мы наблюдали странное поведение, когда пытались запустить несколько фьючерсов из метода приема актера. Если мы используем наши сконфигурированные диспетчеры как ExecutionContext, фьючерсы запускаются в том же потоке и последовательно. Если мы исполь…
06 апр '18 в 14:15
1
ответ
Использование диспетчера Akka для обработки фьючерсов
У меня есть HTTP-сервис на основе спрея. У меня есть поток, который работает внутри этого приложения HTTP. Теперь, когда этот поток выполняет много операций ввода-вывода, я решил использовать отдельный пул потоков. Я посмотрел документацию Akka, что…
03 май '16 в 11:14
1
ответ
Как создать BalancingDispatcher, используя Akka в Java?
Я хочу масштабировать свое приложение ВВЕРХ и ВНИЗ в зависимости от отсутствия запросов от пользователей, для этого я хочу поделиться одним и тем же почтовым ящиком со всеми действующими действующими лицами. Я думаю, что Balancing Dispatcher решит м…
20 сен '17 в 06:53
1
ответ
Akka Streams Reactive Kafka - OutOfMemoryError под большой нагрузкой
Я запускаю приложение Akka Streams Reactive Kafka, которое должно работать при большой нагрузке. После запуска приложения в течение примерно 10 минут, приложение закрывается с OutOfMemoryError, Я попытался отладить дамп кучи и обнаружил, что akka.di…
27 сен '17 в 00:13
1
ответ
Акка Балансировочный пул с пул-пулом-исполнителем переменного размера
Вот мой вариант использования: Я хочу создать маршрутизатор Balancing-Pool размера x (x - это число экземпляров / маршрутов, которое определяется во время выполнения), причем каждый из маршрутов имеет свой собственный выделенный поток. Предполагаетс…
16 дек '16 в 22:52
2
ответа
Почему Акка отключает диспетчер, когда нет задач?
Я хочу иметь фиксированный пул потоков с когда-то созданными потоками. Итак, я создаю собственный ExecutorServiceConfigurator: class FixedThreadPoolExecutorServiceConfigurator(config: Config, prerequisites: DispatcherPrerequisites) extends ExecutorS…
20 фев '19 в 09:41
1
ответ
Что делает опция конфигурации "throughput-deadline-time"?
Я наткнулся на throughput-deadline-time Свойство конфигурации для диспетчеров Akka, и оно выглядит как интересный вариант, однако единственное упоминание о нем, которое я смог найти во всей документации, заключается в следующем: # Throughput deadlin…
05 июн '18 в 08:00
0
ответов
Вы можете изменить почтовый ящик мертвых писем akka.net, изменив почтовый ящик диспетчера?
Сначала я попытался изменить требование к почтовому ящику диспетчера по умолчанию, но получаю исключение: Mailbox Mapping for [CustomMailbox.PmfMailboxType] not configured Это конфиг: akka.actor.default-dispatcher { mailbox-requirement = "CustomMail…
16 апр '19 в 13:54
1
ответ
Как правильно настроить диспетчер в ядре asp.net
Я добавляю прикрепленный диспетчер в свою конфигурацию akka.net, так как я читаю это, чтобы своевременно отправлять сообщения об отправке актеру, но, следуя конфигурации akka, я придумал это using (_actorSystem = ActorSystem.Create("SchedulerAutoAct…
29 июн '19 в 04:34
1
ответ
Когда использовать больше экземпляров одного и того же актера Akka?
Некоторое время я работал с Akka, но сейчас подробно изучаю его систему актеров. Я знаю, что есть исполнитель опроса потоков, исполнитель соединения вилки и исполнитель афинити. Я знаю, как работает диспетчер, и все остальное. Кстати, эта ссылка дае…
22 июл '20 в 18:15
0
ответов
Конфигурация диспетчера Akka для повторно используемых акторов
Я пытаюсь запланировать диспетчер для актеров, привязанных к процессору, и немного не понимаю, как он впишется в мой макет актеров. У меня есть следующая раскладка актеров на акка: В mapperX акторы на самом деле являются одним и тем же классом актор…
12 ноя '19 в 17:57
1
ответ
Создание потока в Akka Dispatcher
Я работаю над моделью Akka Actor. У меня есть пример использования, в котором более 1000 актеров будут активными, и я должен их обработать. Я подумал об управлении счетчиком потоков с помощью конфигурации, определенной в application.conf. Но нет. по…
18 мар '20 в 19:54
0
ответов
Как спроектировать диспетчер Akka для работы с большой нагрузкой и быстрого реагирования?
Скажем, в моей системе akka есть несколько акторов akka, один из которых отвечает за большую рабочую нагрузку (большое количество сообщений akka и потребление ЦП), а другие отвечают за обслуживание пользователей и связь между узлами, которые требуют…
22 апр '20 в 06:32
1
ответ
Выделение сообщения актора потоку диспетчера
Известно, что потоки Dispatcher отвечают за выполнение сообщений актора. Используя параметр пропускной способности, мы можем определить no. сообщений, обработанных потоком диспетчера перед переходом к другому субъекту Но я не уверен, как поток диспе…
21 апр '20 в 13:48
1
ответ
Почему ActorSystem не создает актера для работы с настраиваемым диспетчером
Привет, у вас есть конфигурация безопасного типа в файле application-typed.conf. akka { loggers = ["akka.event.slf4j.Slf4jLogger"] loglevel = "DEBUG" logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" actor { provider = "local" } } custom-thread…
06 май '21 в 23:33
0
ответов
Как управлять миллионами отдельных актеров с настройкой AKKA Cluster?
У меня есть вариант использования, в котором данные миллионов клиентов обрабатываются отдельным субъектом. И все субъекты создаются на нескольких узлах и формируются в виде кластера.Когда я получаю сообщение, я должен отправить его конкретному актер…
29 апр '22 в 11:58
0
ответов
Какая конфигурация диспетчера в AKKA эффективна для параллельной обработки нескольких акторов?
Когда мы используем закрепленный диспетчер, мы должны назначить один поток для актера.В диспетчере по умолчанию у нас есть пул потоков с выделенными потоками, используемыми многими акторами. Если мы используем диспетчер с 1000 потоков и для 5000 уча…
14 июн '22 в 07:07
0
ответов
Проблема с обрезкой в «Запомнить объекты» Actor Cluster Sharding
В кластере актеров с тремя узлами во время последовательного перезапуска узлов некоторые из вновь созданных записей сущностей перезаписывают старые значения для определенных ключей в «Запомнить сущности» ORSet. Эта проблема при обрезке возникает пос…
23 авг '23 в 10:37