Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/05/11 11:57
От версии 31.14
отредактировано Alexandr Fokin
на 2026/05/11 11:41
на 2026/05/11 11:41
Изменить комментарий:
К данной версии нет комментариев
К версии 31.3
отредактировано Alexandr Fokin
на 2026/04/27 13:28
на 2026/04/27 13:28
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -3,25 +3,16 @@ 3 3 Очередь задач, Система обработки процессов, Движок обработки процессов. 4 4 [[Процесс>>doc:Архитектура и модели.Модели.Процесс.WebHome]] 5 5 |Описание|Универсальный движок для выполнения процессов и очередей задач, позволяющий комбинировать несколько подходов к обработке (см особенности). 6 -|Термины|((( 7 -* Процесс является единицей исполнения. В реализации может содержать машину состояний. 8 -* Система триггеров используется для таймеров и передачи сигналов для процессов (с оптимизацией нагрузки). 9 -))) 6 +|Термины|Процесс является единицей исполнения. В реализации может содержать машину состояний. 7 +Система триггеров используется для таймеров и передачи сигналов для процессов (с оптимизацией нагрузки). 10 10 |Репозиторий|[[https:~~/~~/github.com/cccc1808/cccc1808.ProcessEngine>>https://github.com/cccc1808/cccc1808.ProcessEngine]] 11 -|Некоторые цели|((( 12 -* Реализация механизмов для эффективной конкурентной передачи сигнала в процесс. 13 -* Реализация механизмов для минимизации задержки передачи сигнала в процесс. 14 -* Возможность управлять параметрами, влияющими на Throughput и Latency. 15 -* Минимизация нагрузки на БД. 16 16 ))) 17 -))) 18 -|(% style="width:132px" %)Развертывание|(% style="width:1301px" %)((( 10 +|(% style="width:132px" %)Разветывание|(% style="width:1301px" %)((( 19 19 |(% style="width:150px" %)База данных|(% style="width:1177px" %)((( 20 20 Для надежного хранения данных процессов и триггеров. 21 21 22 -* Есть реализация под [[EntityFramework>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]]. 23 -* Есть реализация под [[linq2db>>doc:Разработка.NET.Работа с БД.linq2db.WebHome]] (cccc1808/feature/linq2db). 24 -* Модель позволяет сделать реализацию под другие решения (за счет наличия IProcessContainer и методов Update). В коде процесса может использоваться как ChangeTracker, так и прямое обновление БД. 14 +* Сейчас есть реализация под EntityFramework. 15 +* Но модель позволяет сделать реализацию под другие решения ([[linq2db>>doc:Разработка.NET.Работа с БД.linq2db.WebHome]] или чистый Ado.Net) (за счет наличия IProcessContainer и методов Update). 25 25 26 26 Для текущей реализации в качестве хранилище может выступать БД, поддерживающая: 27 27 ... ... @@ -88,13 +88,8 @@ 88 88 2) N/2 за вторую сессию выполнения (транзакцию) и уснуть до окончания дочерних процессов. 89 89 1. Процесс - групповое действие (когда нужно применить действие к строкам таблицы по указанному фильтру). 90 90 ))) 91 -|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)((( 92 -(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 93 - 94 -Также есть возможность использовать как дополнительное ограничение по некоторой оценке при пакетной обработке. 95 -(Например мы загрузили 10 процессов, у каждого по 50 необработанных сообщений, мы отбираем только top 400 сообщений и связанные процессы, а другие оставляем другим нодам). 82 +|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 96 96 ))) 97 -))) 98 98 99 99 ---- 100 100