Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/04/27 13:28
От версии 27.3
отредактировано Alexandr Fokin
на 2026/04/10 19:46
на 2026/04/10 19:46
Изменить комментарий:
К данной версии нет комментариев
К версии 27.1
отредактировано Alexandr Fokin
на 2026/04/10 19:43
на 2026/04/10 19:43
Изменить комментарий:
Загрузить новое изображение TransactionOutbox. Sequence.jpg
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -101,12 +101,8 @@ 101 101 ))) 102 102 |(% style="width:32px" %)2|(% style="width:171px" %)Transaction outbox stream process.|(% style="width:1066px" %)[[image:TransactionOutbox. Sequence.jpg]] 103 103 |(% style="width:32px" %)3|(% style="width:171px" %)Stream trigger|(% style="width:1066px" %)((( 104 -|(% style="width:94px" %) |(% style="width:1002px" %)((( 105 -* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен). 106 -* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден). 107 -* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 108 -* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса. 109 -))) 104 +|(% style="width:94px" %) |(% style="width:1002px" %)Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен). 105 +Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 110 110 |(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)((( 111 111 * При получении события о засыпании процесса: 112 112 Фиксирует смещение процесса обработки и сравнивает со смещением сообщения. ... ... @@ -116,6 +116,7 @@ 116 116 Если процесс не спит (по флагу в триггере), то ничего не делает. 117 117 Если процесс спит (по флагу), то пробуждает процесс. 118 118 115 + 119 119 Отслеживает смещение обработки процесса и последнего события. 120 120 Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать. 121 121 Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса.