Перейти к содержимому

Про передачу сигнала на процесс

Версия 1.5 от Alexandr Fokin на 2026/05/05 15:59
  
Описание колонок
  
ТриггерИспользуется ли триггер
Избыточная задержка сигналаСвойство обозначающее, что процесс может получить сигнал (и продолжить обработку) позже чем мог бы (при использовании других подходов).
Stream триггерТриггер, отслеживающий состояние процесса (выполняется он или нет).
Реализуется через отправку TriggerEvent в момент остановки выполнения процесса (делается автоматически если зарегистрирован).
Пробуждает процесс (передает сигнал), только после того как процесс остановил выполнение.
Wakeup conditionМодуль wakeup condition проверяет условие наличия новых сигналов перед остановкой процесса.
От разработчика требуется реализация хендлера проверки условия.
Wakeup state

Модуль wakeup state добавляет отдельную таблицу для синхронизации.
Используется только в сочетании с Wakeup condition.
Решает 2 задачи:
1) Информация о выполнении процесса считывается из Wakeup state (без взятия блокировки процесса). Если процесс выполняется, то сигнал считается доставленным и никаких обновлений не требуется.
2) Синхронизация проверки условия Wakeup condition, гарантия что сигнал не будет утерян.
В конце сессии обработки процесса Wakeup state блокируется и только после этого проверяется условие наличие новых сигналов Wakeup condition, это гарантирует что ни один поступивший сигнал не будет утерян.

Такой подход позволяет минимизировать ожидание на блокировках.

Типы передачи сигналов
 ТипПримерТриггерИзбыточная задержка сигналаStream триггерWakeup conditionWakeup state
1Если внешний сигнал единичный и процесс гарантировано остановлен, то его можно подать сразу на процесс (без триггера).

Линейный процесс отправил запрос и ждет 1 событие ответ.
Хендлер события пробуждает процесс напрямую.

-----
2Если внешний сигнал множественный или процесс может периодически запускаться, то сигнал нужно подавать через триггер.      
2.1Несколько конкурирующих триггеров с cannot hold lock timeout.
Если не удалось получить блокировку процесса, то выполнение триггера откладывается на некоторый timeout.		 ++---
2.2Если используется один stream триггер, то можно обойтись без таблицы wakeup state entity.Transactional outbox.+-++--
2.3Несколько конкурирующих триггеров. +--++
3Периодическая проверкаПроцесс пробуждается каждые N timeout, используется только 1 timer trigger.++---