Перейти к содержимому
Редактировал(а) Alexandr Fokin 2026/08/20 12:16
От версии 1.2
отредактировано Alexandr Fokin
на 2026/08/02 15:36
Изменить комментарий: К данной версии нет комментариев
К версии 1.1
отредактировано Alexandr Fokin
на 2026/08/02 15:33
Изменить комментарий: К данной версии нет комментариев

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -15,12 +15,8 @@
15 15  Использование нескольких SortedSet позволяет выполнить разделение по типу / приоритету процесса, чтобы ноды Executor могли отбирать только указанные для них типы задач.
16 16  * PubSub channel - используется для оповещения Executor о том, что в определенную очередь поступило сообщение. Executor может попытаться его считать, при наличии у него свободных слотов на обработку (параллелизм).
17 17  )))
18 -|(% style="width:369px" %)В качестве системы резервирования используется HashSet.|(% style="width:759px" %)(((
19 -Позволяет гарантировать уникальность (при резервировании), а также позволяет задействовать ExperationTimeout (автоматическое снятие резервирования, если вдруг нода упада и не смогла снять сама).
20 -
21 -Используется для обработки ситуации, когда задача была взята из очереди в обработку и обрабатывается (в этот промежуток нет смысла помещать в очередь повторно). В конце обработки (при нормальном завершение) резервирование снимается или при падении сработает ExperationTimeout.
18 +|(% style="width:369px" %)В качестве системы резервирования используется HashSet.|(% style="width:759px" %)Позволяет гарантировать уникальность (при резервировании), а также позволяет задействовать ExperationTimeout (автоматическое снятие резервирования, если вдруг нода упада и не смогла снять сама).
22 22  )))
23 -)))
24 24  |(% style="width:93px" %)Плюсы|(% style="width:1151px" %)(((
25 25  * Все временные данные расположены в оперативной памяти.
26 26  Нет записи на диск. Их потеря не критична, она приведет к временной задержке, но система продолжит работу.