Комментарий

• Свойства страницы (3 изменено, 0 добавлено, 0 удалено)

Подробности

Свойства страницы

Название

...	...	@@ -1,1 +1,1 @@
1		-Пакетная обработка с async
	1	+Пакетная обработка заявок с асинхронностью (Async)

Родительский документ

...	...	@@ -1,1 +1,1 @@
1		-Архитектура и модели.WebHome
	1	+Разработка.NET.C#.Многопоточность.Сценарии.WebHome

Содержимое

...	...	@@ -1,18 +1,45 @@
	1	+[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность.Асинхронность\. Async Await.WebHome]]
1	1
	3	+
	4	+----
	5	+
2	2	Используемые инструменты
3	3	1) Пакетная обработка
4	4	2) LongPooling
5	5
6		-1) От клиентов поступают заявки на некоторую обработку.
7		-На основе заявки создаеться запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента)
8		-Запрос встате на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом)
9	9
10		-2) Через некоторые промежутки времени запускается некоторый Worker, который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
11		-По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.
12		-
13		-3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки.
	11	+|(% style="width:105px" %)Исполнитель|(% style="width:1370px" %)Алгоритм
	12	+|(% style="width:105px" %)Клиент|(% style="width:1370px" %)1) От клиентов поступают заявки на некоторую обработку.
	13	+На основе заявки создается запись (State) в потокобезопасной коллекции ([[ConcurrentDictionary>>doc:Разработка.NET.C#.Коллекции.System\. Collections\. Concurrent.ConcurrentDictionary.WebHome]]). (В записи также содержится CancalidationToken, позволяющий прервать await клиента)
	14	+Запрос встает на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом)
	15	+|(% style="width:105px" %)Воркер|(% style="width:1370px" %)2) Через некоторые промежутки времени запускается некоторый [[Концепция Worker (Worker and WorkerParallelWrapper)>>doc:Архитектура и модели.Модели.Концепция Worker (Worker and WorkerParallelWrapper).WebHome]], который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
	16	+По окончанию обработки Worker записывает результаты в соответствущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.
	17	+|(% style="width:105px" %)Клиент|(% style="width:1370px" %)3) Клиент выходит с await и забирает свой State, в котором содержится некоторый результат обработки.
14	14	(
15		- Статуст успешно и результат
	19	+ Статус успешно и результат
16	16	либо статус ошибка и сообщенеи об ошибке
17	17	)
18	18
	23	+----
	24	+
	25	+{{code language="C#"}}
	26	+public class BatchContainer<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}}