Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/04/27 13:28
От версии 27.1
отредактировано Alexandr Fokin
на 2026/04/10 19:43
на 2026/04/10 19:43
Изменить комментарий:
Загрузить новое изображение TransactionOutbox. Sequence.jpg
К версии 27.12
отредактировано Alexandr Fokin
на 2026/04/11 01:41
на 2026/04/11 01:41
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -98,11 +98,19 @@ 98 98 Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет. 99 99 ))) 100 100 |(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]] 101 +|(% style="width:870px" %)((( 102 + 101 101 ))) 104 +))) 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 -Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 107 +|(% style="width:94px" %) |(% style="width:1002px" %)((( 108 +* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен). 109 +* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден). 110 +За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул. 111 +* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение). 112 +* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса. 113 +))) 106 106 |(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)((( 107 107 * При получении события о засыпании процесса: 108 108 Фиксирует смещение процесса обработки и сравнивает со смещением сообщения. ... ... @@ -112,7 +112,6 @@ 112 112 Если процесс не спит (по флагу в триггере), то ничего не делает. 113 113 Если процесс спит (по флагу), то пробуждает процесс. 114 114 115 - 116 116 Отслеживает смещение обработки процесса и последнего события. 117 117 Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать. 118 118 Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса. ... ... @@ -122,4 +122,26 @@ 122 122 ))) 123 123 ))) 124 124 125 - 132 +---- 133 + 134 +==== Внутренние ссылки: ==== 135 + 136 +====== Дочерние страницы: ====== 137 + 138 +{{children/}} 139 + 140 +====== Обратные ссылки: ====== 141 + 142 +{{velocity}} 143 +#set ($links = $doc.getBacklinks()) 144 +#if ($links.size() > 0) 145 + #foreach ($docname in $links) 146 + #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument()) 147 + * [[$escapetool.xml($rdoc.fullName)]] 148 + #end 149 +#else 150 + No back links for this page! 151 +#end 152 +{{/velocity}} 153 + 154 +----