Изменения документа Пакетная обработка заявок с асинхронностью (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 15:09
на 2023/01/11 15:09
Изменить комментарий:
К данной версии нет комментариев
Комментарий
-
Свойства страницы (1 изменено, 0 добавлено, 0 удалено)
Подробности
- Свойства страницы
-
- Содержимое
-
... ... @@ -22,4 +22,24 @@ 22 22 23 23 ---- 24 24 25 - 25 +{{code language="C#"}} 26 +public class BatchProcessingContainer<TRequest, TResponse> 27 +{ 28 + private readonly ConcurrentDictionary<Guid, (TRequest Request, TResponse? Response, CancelationTokenSource WaitToken) _Buffer 29 + 30 + public async Task<TResponse> RequestAsync( 31 + TRequest request, 32 + CancelationToken token = default 33 + ); 34 + 35 + 36 + public async ValueTask<(Guid RequestId, TRequest Request)[]> GetForProcessingAsync( 37 + int count? = null 38 + ); 39 + 40 + public async ValueTask SetResultAsync( 41 + Guid requestId, 42 + TResponse response 43 + ) 44 +} 45 +{{/code}}