Изменения документа Задачи. Распределение, резервирование, очередь.
Редактировал(а) Alexandr Fokin 2026/08/20 12:16
От версии 1.5
отредактировано Alexandr Fokin
на 2026/08/18 15:16
на 2026/08/18 15:16
Изменить комментарий:
К данной версии нет комментариев
К версии 1.7
отредактировано Alexandr Fokin
на 2026/08/18 15:19
на 2026/08/18 15:19
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -15,7 +15,7 @@ 15 15 ExecutorRunner -> (Queue with reserve) -> Executor. 16 16 |(% style="width:93px" %)Компоненты|(% style="width:1151px" %)((( 17 17 |(% style="width:369px" %)В качестве очереди выступает один или группа SortedSet и PubSub channel.|(% style="width:759px" %)((( 18 -* SortedSet - позволяет хранить заявки на обработку (без дублей) и имеет упорядоченность (можно указать критерий, например приоритет илидата создания).18 +* SortedSet - позволяет хранить заявки на обработку (без дублей) и имеет упорядоченность (можно указать критерий, например приоритет / дата создания/ дата последней обработки). 19 19 Использование нескольких SortedSet позволяет выполнить разделение по типу / приоритету процесса, чтобы ноды Executor могли отбирать только указанные для них типы задач. 20 20 * PubSub channel - используется для оповещения Executor о том, что в определенную очередь поступило сообщение. Executor может попытаться его считать, при наличии у него свободных слотов на обработку (параллелизм). 21 21 ))) ... ... @@ -30,7 +30,7 @@ 30 30 Нет записи на диск. Их потеря не критична, она приведет к временной задержке, но система продолжит работу. 31 31 * При выборке из БД достаточно только чтения. Не требуется ни транзакция, ни блокировка, ни запись. 32 32 * Максимально быстрое попадание в Executor (Если обработчик публикует сразу в Queue (наличие такой возможности)). 33 -* Возможность реализации разделения по типам процессов (нода обрабатывает только определенные типы). 33 +* Возможность реализации разделения по типам процессов (нода обрабатывает только определенные типы и конфигурацию можно менять в любой момент). 34 34 * Возможность разделения на Single и Range процессы и реализация различного потребления из очереди (когда мы хотим обработать в одной транзакции 1 или N процессов). 35 35 ))) 36 36 |(% style="width:93px" %)Минусы|(% style="width:1151px" %)(((