Пакетная обработка заявок с асинхронностью (Async)
Версия 3.5 от Alexandr Fokin на 2023/01/11 14:52
Используемые инструменты
1) Пакетная обработка
2) LongPooling
| 1) От клиентов поступают заявки на некоторую обработку. На основе заявки создается запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента) Запрос встате на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом) | |
| 2) Через некоторые промежутки времени запускается некоторый Концепция Worker (Worker and WorkerParallelWrapper), который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать. По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента. | |
| 3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки. ( Статуст успешно и результат либо статус ошибка и сообщенеи об ошибке ) |