Изменения документа Движок cccc1808. ProcessEngine

Редактировал(а) Alexandr Fokin 2026/04/27 13:28

От версии 27.5
отредактировано Alexandr Fokin
на 2026/04/10 20:15
Изменить комментарий: К данной версии нет комментариев
К версии 27.1
отредактировано Alexandr Fokin
на 2026/04/10 19:43
Изменить комментарий: Загрузить новое изображение TransactionOutbox. Sequence.jpg

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -101,13 +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 -За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
108 -* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
109 -* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
110 -)))
104 +|(% style="width:94px" %) |(% style="width:1002px" %)Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
105 +Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
111 111  |(% style="width:94px" %)Алгоритм триггера.|(% style="width:1002px" %)(((
112 112  * При получении события о засыпании процесса:
113 113  Фиксирует смещение процесса обработки и сравнивает со смещением сообщения.
... ... @@ -117,6 +117,7 @@
117 117  Если процесс не спит (по флагу в триггере), то ничего не делает.
118 118  Если процесс спит (по флагу), то пробуждает процесс.
119 119  
115 +
120 120  Отслеживает смещение обработки процесса и последнего события.
121 121  Ожидает от процесса события о том, что он все обработал, его последнее смещение и он идет спать.
122 122  Если есть сообщения со смещением больше чем указал процесс, то делает гарантированное пробуждение процесса.
... ... @@ -126,26 +126,4 @@
126 126  )))
127 127  )))
128 128  
129 -----
130 -
131 -==== Внутренние ссылки: ====
132 -
133 -====== Дочерние страницы: ======
134 -
135 -{{children/}}
136 -
137 -====== Обратные ссылки: ======
138 -
139 -{{velocity}}
140 -#set ($links = $doc.getBacklinks())
141 -#if ($links.size() > 0)
142 - #foreach ($docname in $links)
143 - #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
144 - * [[$escapetool.xml($rdoc.fullName)]]
145 - #end
146 -#else
147 - No back links for this page!
148 -#end
149 -{{/velocity}}
150 -
151 -----
125 +