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

Сводка

• Свойства страницы (1 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Содержимое

...	...	@@ -98,11 +98,24 @@
98	98	Этот триггер выполняется периодически с более крупной временной задержкой. В случае обнаружения потери TriggerEvent, он поднимет заклинивший родительский процесс и он будет обработан (но позже). Можно установить этому триггеру низкий приоритет.
99	99	)))
100	100	|(% style="width:870px" %)[[image:Родительский дочерний процесс. Sequence.jpg]]
	101	+|(% style="width:870px" %)(((
	102	+Возможен вариант №2, когда мы просто ставит timerTrigger на условно 1-5 минуту (насколько важна задержка) и перепроверяем условие завершения (по нагрузке на БД будет еще меньше). Из минус, что родительский процесс узнает о завершении дочерних процессов с задержкой (хотя в задержке можно использовать функцию от количества необработанных дочерних процессов, но тогда нужно считать количество).
	103	+
	104	+* Но тут будет join нагрузка на БД (если шаг проверки выполняется пакетно), иначе будет просто много одиночны запросов на чтение (условно раз в минуту).
	105	+* Если дочерний процесс остановиться в ошибке, то родительский либо также продолжит крутиться в проверке, либо должен также пробросить ошибку в себя чтобы приостановиться.
	106	+В случае с решением 1, со страхующим триггером это можно обойти через фильтрующий индекс если мы начинаем идти сразу с таблицы процессов (т.е. процессы с ошибкой сразу будут игнорироваться).
	107	+* Но все равно, именно данный движек может позволить настроить 2 процесса таким образом, что 1 процесс будет исполняться (1 процесс - 1 транзакция) в параллельном режиме (пока создаются множественные дочерние процессы), 2 процесс будет исполняться в пакетном режиме (N процессов - 1 транзакция) чтобы проверять выполнение условия завершения дочерних процессов через запрос (один пакетный).
	108	+
	109	+плюсы: меньше пишущей нагрузки (т.к. триггер со счетчиком будет делать условно одну запись на процесс в 5-20 секунд), а тут будет одна запись в 1 минуту на обновление таймера.
	110	+минусы: больше читающей нагрузки с join (раз 1-5 минуту нужно будет выполнить join незавершенных процессов с дочерними). У решения 1 тоже есть такая нагрузка, но на страхующем триггер (условно раз 10-30 минут).
101	101	)))
	112	+)))
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	104	|(% style="width:94px" %) |(% style="width:1002px" %)(((
105	105	* Позволяет убрать лишние запросы пробуждения процесса (когда он и так запущен).
	117	+* Позволяет полностью убрать задержку после остановки процесса (если есть новое сообщения, то он сразу же будет пробужден).
	118	+За счет того, что триггер точно знает, что есть новые сообщения и процесс только что уснул.
106	106	* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
107	107	* Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса.
108	108	)))
...	...	@@ -124,4 +124,26 @@
124	124	)))
125	125	)))
126	126
127		-
	140	+----
	141	+
	142	+==== Внутренние ссылки: ====
	143	+
	144	+====== Дочерние страницы: ======
	145	+
	146	+{{children/}}
	147	+
	148	+====== Обратные ссылки: ======
	149	+
	150	+{{velocity}}
	151	+#set ($links = $doc.getBacklinks())
	152	+#if ($links.size() > 0)
	153	+ #foreach ($docname in $links)
	154	+ #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument())
	155	+ * [[$escapetool.xml($rdoc.fullName)]]
	156	+ #end
	157	+#else
	158	+ No back links for this page!
	159	+#end
	160	+{{/velocity}}
	161	+
	162	+----