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