Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/05/11 11:57
От версии 31.20
отредактировано Alexandr Fokin
на 2026/05/11 11:56
на 2026/05/11 11:56
Изменить комментарий:
К данной версии нет комментариев
К версии 31.4
отредактировано Alexandr Fokin
на 2026/05/08 20:22
на 2026/05/08 20:22
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -3,26 +3,17 @@ 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 -* Наличие общей платформы (компонентов и абстракций), которая решает широкий спектр задач за счет конфигурации. 17 17 ))) 18 -))) 19 19 |(% style="width:132px" %)Развертывание|(% style="width:1301px" %)((( 20 20 |(% style="width:150px" %)База данных|(% style="width:1177px" %)((( 21 21 Для надежного хранения данных процессов и триггеров. 22 22 23 -* Есть реализация под [[EntityFramework>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]].14 +* Есть реализация под EntityFramework. 24 24 * Есть реализация под [[linq2db>>doc:Разработка.NET.Работа с БД.linq2db.WebHome]] (cccc1808/feature/linq2db). 25 -* Модель позволяет сделать реализацию под другие решения (за счет наличия IProcessContainer и методов Update). В коде процесса может использоваться как ChangeTracker, так и прямое обновление БД.16 +* Модель позволяет сделать реализацию под другие решения (за счет наличия IProcessContainer и методов Update). 26 26 27 27 Для текущей реализации в качестве хранилище может выступать БД, поддерживающая: 28 28 ... ... @@ -56,8 +56,7 @@ 56 56 ))) 57 57 |(% style="width:159px" %)Изоляция шагов и процессов (внутри оной транзакции)|(% style="width:1168px" %)((( 58 58 * Изоляция через db savepoint. 59 -* Для [[EntityFramework ~| EntityFrameworkCore>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]] возможность делать InMemory снимок [[Создание снимка ChangeTracker>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.Сценарии и проблемы.Создание снимка ChangeTracker.WebHome]] 60 -(может использоваться если все изменения накапливаются InMemory (без прямой записи в БД) или же с указанием ручной компенсации, а также ошибка на записи в БД не велика). 50 +* Для [[EntityFramework ~| EntityFrameworkCore>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]] возможность делать InMemory снимок [[Создание снимка ChangeTracker>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.Сценарии и проблемы.Создание снимка ChangeTracker.WebHome]]. 61 61 * Допустима реализация на основе того, что InMemory состояние процесса (и задействованных бизнес сущностей) реализовано в виде Immutable компонентов. В этом случае достаточно просто сохранять и восстанавливать ссылку. 62 62 Но предполагаю, что в большинстве бизнес моделей не так и это не не будет востребованным. 63 63 ))) ... ... @@ -90,13 +90,8 @@ 90 90 2) N/2 за вторую сессию выполнения (транзакцию) и уснуть до окончания дочерних процессов. 91 91 1. Процесс - групповое действие (когда нужно применить действие к строкам таблицы по указанному фильтру). 92 92 ))) 93 -|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)((( 94 -(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 95 - 96 -Также есть возможность использовать как дополнительное ограничение по некоторой оценке при пакетной обработке. 97 -(Например мы загрузили 10 процессов, у каждого по 50 необработанных сообщений, мы отбираем только limit 400 сообщений и связанные процессы для текущей транзакции). 83 +|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 98 98 ))) 99 -))) 100 100 101 101 ---- 102 102