Изменения документа Про передачу сигнала на процесс
Редактировал(а) Alexandr Fokin 2026/06/18 22:07
От версии 1.2
отредактировано Alexandr Fokin
на 2026/05/05 15:53
на 2026/05/05 15:53
Изменить комментарий:
К данной версии нет комментариев
К версии 1.16
отредактировано Alexandr Fokin
на 2026/05/29 17:46
на 2026/05/29 17:46
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -5,32 +5,42 @@ 5 5 |(% style="width:232px" %)Избыточная задержка сигнала|(% style="width:1151px" %)Свойство обозначающее, что процесс может получить сигнал (и продолжить обработку) позже чем мог бы (при использовании других подходов). 6 6 |(% style="width:232px" %)Stream триггер|(% style="width:1151px" %)Триггер, отслеживающий состояние процесса (выполняется он или нет). 7 7 Реализуется через отправку TriggerEvent в момент остановки выполнения процесса (делается автоматически если зарегистрирован). 8 -|(% style="width:232px" %)Wakeup condition|(% style="width:1151px" %)Модуль wakeup condition проверяет условие наличия новых сигналов перед остановкой процесса. 8 +Пробуждает процесс (передает новый сигнал), только после того как процесс перешел в состояние ожидания. 9 +|(% style="width:232px" %)Wakeup condition|(% style="width:1151px" %)((( 10 +Модуль wakeup condition проверяет условие наличия новых сигналов перед остановкой процесса. 9 9 От разработчика требуется реализация хендлера проверки условия. 10 -|(% style="width:232px" %)Wakeup state|(% style="width:1151px" %)((( 11 -Модуль wakeup state добавляет отдельную таблицу для синхронизации. 12 +))) 13 +|(% style="width:232px" %)Wakeup lock (Wakeup state)|(% style="width:1151px" %)((( 14 +Модуль wakeup lock добавляет отдельную таблицу для синхронизации. 12 12 Используется только в сочетании с Wakeup condition. 13 -Решает 2 задачи: 14 -1) Информация о выполнении процесса считывается из Wakeup state (без взятия блокировки процесса). Если процесс выполняется, то сигнал считается доставленным и никаких обновлений не требуется. 15 -2) Синхронизация проверки условия Wakeup condition, гарантия что сигнал не будет утерян. 16 -В конце сессии обработки процесса Wakeup state блокируется и только после этого проверяется условие наличие новых сигналов Wakeup condition, это гарантирует что ни один поступивший сигнал не будет утерян. 17 17 18 - Такойподход позволяетминимизировать ожиданиенаблокировках.17 +[[Гарантированная конкурентная доставка сигнала>>doc:Проекты и репозитории.Библиотеки.Движок cccc1808\. ProcessEngine.Гарантированная конкурентная доставка сигнала.WebHome]] 19 19 ))) 20 20 ))) 21 21 |Типы передачи сигналов|((( 22 -| |(% style="width:662px" %)Тип|(% style="width:513px" %)Пример|Триггер|Избыточная задержка сигнала|Stream триггер|Wakeup condition|Wakeup state23 -|1|(% style="width:662px" %) Есливнешнийсигналединичный и процессгарантированоостановлен,то его можно подать сразу на процесс(без триггера).|(% style="width:513px" %)(((21 +| |(% style="width:662px" %)Тип|(% style="width:513px" %)Пример|Триггер|Избыточная задержка сигнала|Stream триггер|Wakeup condition|Wakeup lock 22 +|1|(% style="width:662px" %)Низкая интенсивность сигналов, низкая конкуренция за процесс.|(% style="width:513px" %)((( 24 24 Линейный процесс отправил запрос и ждет 1 событие ответ. 25 -Хендлер пробуждает процесс напрямую. 24 +Хендлер события пробуждает процесс напрямую. 26 26 )))|-|-|-|-|- 27 -|2|(% style="width:662px" %)Если внешний сигнал множественный или процесс может периодически запускаться, то сигнал нужно подавать через триггер.|(% style="width:513px" %) | | | | | 26 +|2|(% style="width:662px" %)Высокая интенсивность сигналов, высокая конкуренция за процесс. 27 +Сигнал нужно подавать через триггер.|(% style="width:513px" %) | | | | | 28 28 |2.1|(% style="width:662px" %)Несколько конкурирующих триггеров с cannot hold lock timeout. 29 -Если не удалось получить блокировку процесса, то выполнение триггера откладывается на некоторый timeout.|(% style="width:513px" %) |+|+|-|-|- 30 -|2.2|(% style="width:662px" %)Если используется один stream триггер, то можно обойтись без таблицы wakeup state entity.|(% style="width:513px" %)Transactional outbox.|+|-|+|+-|- 31 -|2.3|(% style="width:662px" %)Несколько конкурирующих триггеров.|(% style="width:513px" %) |+|-|-|+|+ 32 - 33 - 29 +Если не удалось получить блокировку процесса, то выполнение триггера откладывается на некоторый timeout.|(% style="width:513px" %)__Триггеры <-> Процесс.__|+|+|-|-|- 30 +|2.2|(% style="width:662px" %)Один stream триггер. 31 +Высокая частота сигналов, но низкая конкуренция (условие активации триггера наличие необработанного сигнала и остановка процесса). 32 +Можно использовать без таблицы Wakeup lock.|(% style="width:513px" %)__Simple stream trigger <-> Процесс.__ 33 +\\Transactional outbox. См [[Примеры>>doc:Проекты и репозитории.Библиотеки.Движок cccc1808\. ProcessEngine.Примеры.WebHome]] 3.|+|-|+|+-|- 34 +|2.2.1|(% style="width:662px" %)Каскад триггеров. 35 +Подход, когда 1 корневой simple stream trigger передает сигнал на процесс. 36 +А другие триггеры процесса передают сигнал не на процесс напрямую, а на stream триггер. 37 +Данный подход позволяет использовать несколько триггеров (как в варианте 2.3), но при этом полностью убирает конкуренцию (не требует wakeup lock (и может работать без wakeup condition)).|(% style="width:513px" %)__Дочерние триггеры 38 +<-> Корневой триггер (Simple stream trigger) 39 +<-> Процесс__|+|-|+|+-|- 40 +|2.3|(% style="width:662px" %)Несколько конкурирующих триггеров. 41 +Высокая интенсивность сигналов, высокая конкуренция за процесс. 42 +Для сглаживания конкуренции используется Wakeup lock (share блокировка минимизирует блокировку и сглаживает конкуренцию).|(% style="width:513px" %)__Триггеры <-> Процесс.__|+|-|-|+|+ 43 +|3|(% style="width:662px" %)Периодическая проверка|(% style="width:513px" %)Процесс пробуждается каждые N timeout, используется только 1 timer trigger. См. [[Примеры>>doc:Проекты и репозитории.Библиотеки.Движок cccc1808\. ProcessEngine.Примеры.WebHome]] 1 (блок 2).|+|+|-|-|- 34 34 ))) 35 35 | | 36 36