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