Редактировал(а) Alexandr Fokin 2023/01/23 23:00

От версии 1.1 >
отредактировано Alexandr Fokin
на 2020/07/14 12:04
К версии < 3.6 >
отредактировано Alexandr Fokin
на 2023/01/11 15:04
>
Изменить комментарий: К данной версии нет комментариев

Комментарий

Подробности

Свойства страницы
Название
... ... @@ -1,1 +1,1 @@
1 -Пакетная обработка с async
1 +Пакетная обработка заявок с асинхронностью (Async)
Родительский документ
... ... @@ -1,1 +1,1 @@
1 -Архитектура и модели.WebHome
1 +Разработка.NET.C#.Многопоточность.Сценарии.WebHome
Содержимое
... ... @@ -1,10 +1,25 @@
1 +[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность.Асинхронность\. Async Await.WebHome]]
1 1  
2 -1) От клиентов поступают заявки на некоторую обработку.
3 -На основе заявки создаеться запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента)
4 -Запрос встате на ожидание обработки с await.
5 5  
6 -2) Через некоторые промежутки времени запускается некоторый Worker, который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
7 -По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.
4 +----
8 8  
9 -3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки. (Успешно выполнени и результата или ошибка)
6 +Используемые инструменты
7 +1) Пакетная обработка
8 +2) LongPooling
10 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, в котором содержится некоторый результат обработки.
18 +(
19 + Статус успешно и результат
20 + либо статус ошибка и сообщенеи об ошибке
21 +)
22 +
23 +----
24 +
25 +