Изменения документа Пакетная обработка заявок с асинхронностью (Async)
Редактировал(а) Alexandr Fokin 2023/01/23 23:00
<
>
отредактировано Alexandr Fokin
на 2023/01/11 14:49
на 2023/01/11 14:49
отредактировано Alexandr Fokin
на 2023/01/11 15:04
на 2023/01/11 15:04
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -1,18 +1,25 @@ 1 +[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность.Асинхронность\. Async Await.WebHome]] 1 1 3 + 4 +---- 5 + 2 2 Используемые инструменты 3 3 1) Пакетная обработка 4 4 2) LongPooling 5 5 6 -1) От клиентов поступают заявки на некоторую обработку. 7 -На основе заявки создаеться запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента) 8 -Запрос встате на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом) 9 9 10 -2) Через некоторые промежутки времени запускается некоторый Worker, который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать. 11 -По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента. 12 - 13 -3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки. 11 +|(% style="width:105px" %)Исполнитель|(% style="width:1370px" %)Алгоритм 12 +|(% style="width:105px" %)Клиент|(% style="width:1370px" %)1) От клиентов поступают заявки на некоторую обработку. 13 +На основе заявки создается запись (State) в потокобезопасной коллекции ([[ConcurrentDictionary>>doc:Разработка.NET.C#.Коллекции.System\. Collections\. Concurrent.ConcurrentDictionary.WebHome]]). (В записи также содержится CancalidationToken, позволяющий прервать await клиента) 14 +Запрос встает на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом) 15 +|(% style="width:105px" %)Воркер|(% style="width:1370px" %)2) Через некоторые промежутки времени запускается некоторый [[Концепция Worker (Worker and WorkerParallelWrapper)>>doc:Архитектура и модели.Модели.Концепция Worker (Worker and WorkerParallelWrapper).WebHome]], который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать. 16 +По окончанию обработки Worker записывает результаты в соответствущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента. 17 +|(% style="width:105px" %)Клиент|(% style="width:1370px" %)3) Клиент выходит с await и забирает свой State, в котором содержится некоторый результат обработки. 14 14 ( 15 - Статус туспешно и результат19 + Статус успешно и результат 16 16 либо статус ошибка и сообщенеи об ошибке 17 17 ) 18 18 23 +---- 24 + 25 +