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

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

Комментарий

Подробности

Свойства страницы
Содержимое
... ... @@ -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}}