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