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