Изменения документа Движок cccc1808. ProcessEngine
Редактировал(а) Alexandr Fokin 2026/09/04 13:05
От версии 31.27
отредактировано Alexandr Fokin
на 2026/08/17 13:09
на 2026/08/17 13:09
Изменить комментарий:
К данной версии нет комментариев
К версии 31.6
отредактировано Alexandr Fokin
на 2026/05/08 20:34
на 2026/05/08 20:34
Изменить комментарий:
К данной версии нет комментариев
Сводка
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,21 +1,12 @@ 1 1 |(% style="width:132px" %) |(% style="width:1301px" %)((( 2 2 |Теги поиска|cccc1808. ProcessEngine, cccc1808.ProcessEngine, Process engine 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 Для надежного хранения данных процессов и триггеров. ... ... @@ -46,13 +46,7 @@ 46 46 * Скорее всего можно сделать под RabbitMq. 47 47 * Если запускать в одном экземпляре, то можно обойтись inmemory реализаций. 48 48 ))) 49 -|(% style="width:150px" %)InMemory|(% style="width:1177px" %)((( 50 -* Реализация системы очереди распределения и резервирования задач в класетере. 51 -Реализация [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]]. 52 -* Для использования ExternalCounter реализация под [[Redis>>doc:Разработка.Базы данных.NoSQL.Ключ-значение структура.Redis.WebHome]]. Нетранзакционный счетчик для триггера. 53 -([[Примеры>>doc:.Тема\. Сигналы и триггеры.Примеры.WebHome]] 1.5) 54 54 ))) 55 -))) 56 56 |(% style="width:132px" %)Особенности|(% style="width:1301px" %)((( 57 57 |(% style="width:159px" %)Пакетные транзакции (батчинг).|(% style="width:1168px" %)((( 58 58 Возможность использовать и комбинировать типы выполнения для разных типов процессов: ... ... @@ -62,8 +62,7 @@ 62 62 ))) 63 63 |(% style="width:159px" %)Изоляция шагов и процессов (внутри оной транзакции)|(% style="width:1168px" %)((( 64 64 * Изоляция через db savepoint. 65 -* Для [[EntityFramework ~| EntityFrameworkCore>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]] возможность делать InMemory снимок [[Создание снимка ChangeTracker>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.Сценарии и проблемы.Создание снимка ChangeTracker.WebHome]] 66 -(может использоваться если все изменения накапливаются InMemory (без прямой записи в БД) или же с указанием ручной компенсации, а также ошибка на записи в БД не велика). 50 +* Для [[EntityFramework ~| EntityFrameworkCore>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.WebHome]] возможность делать InMemory снимок [[Создание снимка ChangeTracker>>doc:Разработка.NET.Работа с БД.EntityFramework | EntityFrameworkCore.Сценарии и проблемы.Создание снимка ChangeTracker.WebHome]]. 67 67 * Допустима реализация на основе того, что InMemory состояние процесса (и задействованных бизнес сущностей) реализовано в виде Immutable компонентов. В этом случае достаточно просто сохранять и восстанавливать ссылку. 68 68 Но предполагаю, что в большинстве бизнес моделей не так и это не не будет востребованным. 69 69 ))) ... ... @@ -96,13 +96,8 @@ 96 96 2) N/2 за вторую сессию выполнения (транзакцию) и уснуть до окончания дочерних процессов. 97 97 1. Процесс - групповое действие (когда нужно применить действие к строкам таблицы по указанному фильтру). 98 98 ))) 99 -|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)((( 100 -(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 101 - 102 -Также есть возможность использовать как дополнительное ограничение по некоторой оценке при пакетной обработке. 103 -(Например мы загрузили 10 процессов, у каждого по 50 необработанных сообщений, мы отбираем только limit 400 сообщений и связанные процессы для текущей транзакции). 83 +|(% style="width:159px" %)Range preload process data|(% style="width:1168px" %)(Необязательно) возможность в начале сессии обработки пакетно предзагружать данные и бизнес сущности для процессов (Range query) из обрабатываемого батча для оптимизации чтения (если используется обработка пакета процессов в одной транзакции). 104 104 ))) 105 -))) 106 106 107 107 ---- 108 108