Изменения документа Примеры
Редактировал(а) Alexandr Fokin 2026/08/26 19:05
От версии 8.48
отредактировано Alexandr Fokin
на 2026/08/18 12:24
на 2026/08/18 12:24
Изменить комментарий:
К данной версии нет комментариев
К версии 8.37
отредактировано Alexandr Fokin
на 2026/07/27 20:29
на 2026/07/27 20:29
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,13 +1,8 @@ 1 -| |(% style="width:188px" %)**Пример задачи**|(% style="width:1268px" %)**Наборы решений** 2 -|1|(% style="width:188px" %)((( 3 -(% class="wikigeneratedid" id="H144043E43443844243543B44C44143A438439A043F44043E446435441441438N43443E44743544043D43844543F44043E44643544144143E432." %) 4 -1 родительский процесс и N дочерних процессов. 5 -)))|(% style="width:1268px" %)((( 1 +|1|(% style="width:188px" %)1 родительский процесс и N дочерних процессов.|(% style="width:1268px" %)((( 6 6 |В данном примере имеется в виду, что дочерние процессы могут выполняться параллельно другу и независимо друг от друга, но в конце должны оповестить родительский процесс о необходимости продолжения обработки. 7 7 Если речь идет о каких-либо зависимостях порядка выполнения в дочерних процессах, то это может контролировать дочерний процесс (выделяя группу, которую сейчас можно запустить и ожидая окончания). 8 8 |((( 9 9 |((( 10 -(% class="wikigeneratedid" id="H41243044043843043D4421:CounterTrigger." %) 11 11 Вариант 1: CounterTrigger. 12 12 ))) 13 13 |((( ... ... @@ -51,7 +51,7 @@ 51 51 |((( 52 52 Вариант №4: 53 53 54 -SimpleStreamTrigger + Timer. 49 +SimpleStreamTrigger + Timer (один из лучших вариантов). 55 55 56 56 * Триггер проверяет условие завершения всех дочерних процессов (можно прикинуть количество незавершенных дочерних процессов). 57 57 ** Если все обработано, то пробуждает процесс и деактивируется. ... ... @@ -67,8 +67,7 @@ 67 67 * Если сигналов нет, то нет пустых срабатываний в отличие от варианта 2 (т.к. нет поступления сигнала от дочерних процессов). 68 68 ))) 69 69 |((( 70 -|Вариант №5: 71 -SimpleStreamTrigger + Счетчик в [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]]. (на текущий момент самый лучший вариант). 65 +|Вариант №5: Trigger + Счетчик в [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]]. 72 72 |InMemory счетчик, нагрузка на БД и конкуренция. 73 73 Дочерний процесс уменьшает счетчик. И публикует событие только если счетчик достиг 0. 74 74 Совмещает преимущества из варианта 1.1 (при этом не нагружает БД), в случае ошибки переключается на режим 1.4. ... ... @@ -81,10 +81,7 @@ 81 81 1. До коммита транзакции атомарно добавляем значение в MemberSet и уменьшаем счетчик на 1. Если счетчик равен 0, то публикуем TriggerEvent 82 82 (добавляем в ручную компенсацию вызов из пункта 1 (при откате изоляции шага и компенсации транзакции)). 83 83 1. После коммита транзакции удаляем запись из MemberSet. 84 -(Если мы падаем тут, то процесс уже перешел на другой шаг или даже завершился, поэтому наличие единичной остаточной записи в memberSet не будет критичным). 85 85 1. Trigger получает событие. (Необязательно) в хендлере может првоерить значения счетчиков и MemberSet. 86 - 87 -MemberSet используется для уменьшения вероятности увеличить или уменьшить счетчик дважды одним экземпляром дочернего процесса. 88 88 ))) 89 89 |((( 90 90 В случае обнаружения повреждения обработка фактически переходит в режим 1.4: начинает публиковать событий каждый раз и используется задержка. ... ... @@ -137,33 +137,6 @@ 137 137 |(% style="width:888px" %)Родительский процесс ожидает завершения дочерних процессов (см. пример 1).|(% style="width:266px" %) 138 138 ))) 139 139 ))) 140 -|5|(% style="width:188px" %)Распределение заявок между исполнителями 141 -(Заготовка).|(% style="width:1268px" %)((( 142 -|(% style="width:94px" %)Описание|(% style="width:1156px" %)Есть поток заявок на деталь (создание детали требует ресурсов, 1 станок, время). 143 -Есть N станков. Опционально: у станка есть уровень ресурсов и коэффициент скорости работы. 144 -Реализация системы распределения и обработки. 145 -|(% style="width:94px" %)Вариант 1|(% style="width:1156px" %)((( 146 -| |Планирование без очереди к станку. 147 -| |((( 148 -* У процесса планировщика есть 149 -** StreamTrigger на поток заявок. 150 -(Можно использовать расширение SignalCode, чтобы временно игнорировать откладывать этот сигнал пока все слоты станков заняты). 151 -** StreanTrigger на поток сигналов об освобождении слота станка. 152 -))) 153 -| |Процесс планировщик назначает заявку на свободный станок. 154 -Вопрос наиболее эффективной функции выбора (оценка наибольшее количество ресурсов, наилучшая скорость обработки и др.). 155 -Когда все станки заняты планировщик ожидает освобождения станков. 156 -))) 157 -|(% style="width:94px" %)Вариант 2|(% style="width:1156px" %)((( 158 -| |Планировщик с очередью к станку. 159 -| |((( 160 -* У процесса станка есть StreamTrigger, на который планировщик подает сигнал в добавления задачи в его очередь. 161 -* У процесса планировщика есть StreamTrigger на поток заявок. 162 -))) 163 -| |При поступлении заявки процесс планировщик сразу назначает в очередь на какой либо станок. 164 -Вопрос наиболее эффективной функции выбора (оценка размера очереди, достаточности у станка ресурсов для ее обработки, общего количества ресурсов, скорости работы станка и др.). 165 -))) 166 -))) 167 167 168 168 ---- 169 169