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