Изменения документа Примеры
Редактировал(а) Alexandr Fokin 2026/06/21 12:18
От версии 8.24
отредактировано Alexandr Fokin
на 2026/06/21 12:18
на 2026/06/21 12:18
Изменить комментарий:
К данной версии нет комментариев
К версии 8.15
отредактировано Alexandr Fokin
на 2026/05/05 18:23
на 2026/05/05 18:23
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (2 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Родительский документ
-
... ... @@ -1,1 +1,1 @@ 1 -Проекты и репозитории.Библиотеки.Движок cccc1808\. ProcessEngine. Тема\. Сигналы и триггеры.WebHome1 +Проекты и репозитории.Библиотеки.Движок cccc1808\. ProcessEngine.WebHome - Содержимое
-
... ... @@ -24,14 +24,11 @@ 24 24 |((( 25 25 Вариант №2: 26 26 27 -Мы просто стави мTimerTrigger на условно 1-5-10 минут (насколько важна задержка) и перепроверяем условие завершения.27 +Мы просто ставит timerTrigger на условно 1-5-10 минут (насколько важна задержка) и перепроверяем условие завершения. 28 28 В этом случае будет 29 29 30 -* Из минус: что родительский процесс узнает о завершении дочерних процессов с задержкой. 31 -Если дочерний процесс падает в ошибку, TimerTrigger все равно будет крутиться и создавать пустую нагрузку. 32 -* Из плюсов: будет меньше пишущей нагрузки на БД чем в варианте 1 (но больше читающей - на проверку) т.к. у нас не будет CounterTrigger, но будет периодический запрос на проверку завершения всех дочерних процессов (аналогично страхующему триггер). 33 -* [Расширенный]: Дочерние процессы в блоке wakeup condition проверяют наличие незавершенных процессов. 34 -** Если все процессы завершены или (незавершенных процессов мало и нет процессов с ошибкой), то можно опубликовать событие на TimerTrigger на сброс или установку минимальной задержки. 30 +* Из минус: что родительский процесс узнает о завершении дочерних процессов с задержкой (хотя в задержке можно использовать функцию от количества необработанных дочерних процессов, но тогда нужно считать количество или хотя бы что оно не больше N). 31 +* Из плюсов: будет меньше пишущей нагрузки на БД (но больше читающей - на проверку) т.к. у нас не будет CounterTrigger, но будет периодический запрос на проверку завершения всех дочерних процессов (аналогично страхующему триггер). \ 35 35 ))) 36 36 |((( 37 37 Вариант №3: ... ... @@ -41,27 +41,9 @@ 41 41 За счет такого способа у нас также отсутствует конкуренция передачи сигнала в родительский процесс. 42 42 Но мы ограничены выполнением дочерних процессов одной одной сервиса. 43 43 Сложнее контролировать распределение нагрузки, если будет вложенный параллелизм. 44 -Также решает проблему, если дочерний процесс содержит ожидание (например асинхронный запрос-ответ) , тут будет конкуренция сигнала от хендлера ответа к родительскому процессу.41 +Также решает проблему, если дочерний процесс содержит ожидание (например асинхронный запрос-ответ). 45 45 ))) 46 -|((( 47 -Вариант N4: 48 - 49 -SimpleStreamTrigger + Timer (один из лучших вариантов). 50 - 51 -* Триггер проверяет условие завершения всех дочерних процессов (можно прикинуть количество незавершенных дочерних процессов). 52 -** Если все обработано, то пробуждает процесс и деактивируется. 53 -** Иначе: 54 -*** деактивируется (до поступления хотя бы одного сигнала), 55 -*** взводит признак стрима - процесс ожидает, 56 -*** взводит флаг новых сигналов на 0, 57 -*** выставляет задержку от оценки количества необработанных процессов (< N - малая задержка, иначе большая задержка). 58 -* [Расширенный]: Дочерние процессы в блоке wakeup condition проверяют наличие незавершенных процессов. 59 -** Если все процессы завершены или (незавершенных процессов мало и нет процессов с ошибкой), то можно опубликовать событие на SimpleStreamTrigger на сброс или установку минимальной задержки (в дополнение к сигналу). 60 -* Читающей нагрузки будет немного больше чем в варианте 2 (чтение триггера на поступлении сигнала), 61 -но пишущей нагрузки будет меньше чем в варианте 1 (запись - только на активации новым сигналом). 62 -* Если сигналов нет, то нет пустых срабатываний в отличие от варианта 2 (т.к. нет поступления сигнала от дочерних процессов). 63 63 ))) 64 -))) 65 65 |2|(% style="width:188px" %)Transaction outbox stream process.|(% style="width:1268px" %)[[image:TransactionOutbox. Sequence.jpg]] 66 66 |3|(% style="width:188px" %)Stream trigger|(% style="width:1268px" %)((( 67 67 | |((( ... ... @@ -100,27 +100,3 @@ 100 100 |(% style="width:888px" %)Родительский процесс ожидает завершения дочерних процессов (см. пример 1).|(% style="width:266px" %) 101 101 ))) 102 102 ))) 103 - 104 ----- 105 - 106 -==== Внутренние ссылки: ==== 107 - 108 -====== Дочерние страницы: ====== 109 - 110 -{{children/}} 111 - 112 -====== Обратные ссылки: ====== 113 - 114 -{{velocity}} 115 -#set ($links = $doc.getBacklinks()) 116 -#if ($links.size() > 0) 117 - #foreach ($docname in $links) 118 - #set ($rdoc = $xwiki.getDocument($docname).getTranslatedDocument()) 119 - * [[$escapetool.xml($rdoc.fullName)]] 120 - #end 121 -#else 122 - No back links for this page! 123 -#end 124 -{{/velocity}} 125 - 126 -----