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