Комментарий

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

Подробности

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

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

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

Содержимое

...	...	@@ -1,23 +1,46 @@
1		-[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность.Асинхронность\. Async Await.WebHome]]
	1	+[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность и асинхронность.Асинхронность\. Async Await.WebHome]]
2	2
3		-[[ConcurrentDictionary>>doc:Разработка.NET.C#.Коллекции.System\. Collections\. Concurrent.ConcurrentDictionary.WebHome]]
	3	+[[Модели>>doc:Архитектура и модели.Модели.WebHome]]
4	4
5	5	----
6	6
7		-
8	8	Используемые инструменты
9	9	1) Пакетная обработка
10	10	2) LongPooling
11	11
12		-1) От клиентов поступают заявки на некоторую обработку.
13		-На основе заявки создаеться запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента)
14		-Запрос встате на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом)
15	15
16		-2) Через некоторые промежутки времени запускается некоторый Worker, который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
17		-По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.
18		-
19		-3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки.
	12	+|(% style="width:105px" %)Исполнитель|(% style="width:1370px" %)Алгоритм
	13	+|(% style="width:105px" %)Клиент|(% style="width:1370px" %)1) От клиентов поступают заявки на некоторую обработку.
	14	+На основе заявки создается запись (State) в потокобезопасной коллекции ([[ConcurrentDictionary>>doc:Разработка.NET.C#.Коллекции.System\. Collections\. Concurrent.ConcurrentDictionary.WebHome]]). (В записи также содержится CancalidationToken, позволяющий прервать await клиента)
	15	+Запрос встает на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом)
	16	+|(% style="width:105px" %)Воркер|(% style="width:1370px" %)2) Через некоторые промежутки времени запускается некоторый [[Концепция Worker (Worker and WorkerParallelWrapper)>>doc:Архитектура и модели.Модели.Модель Worker (Worker and WorkerParallelWrapper).WebHome]], который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
	17	+По окончанию обработки Worker записывает результаты в соответствущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.
	18	+|(% style="width:105px" %)Клиент|(% style="width:1370px" %)3) Клиент выходит с await и забирает свой State, в котором содержится некоторый результат обработки.
20	20	(
21		- Статуст успешно и результат
	20	+ Статус успешно и результат
22	22	либо статус ошибка и сообщенеи об ошибке
23	23	)
	23	+
	24	+----
	25	+
	26	+{{code language="C#"}}
	27	+public class BatchProcessingContainer<TRequest, TResponse>
	28	+{
	29	+ private readonly ConcurrentDictionary<Guid, (TRequest Request, TResponse? Response, CancelationTokenSource WaitToken) _Buffer
	30	+
	31	+ public async Task<TResponse?> RequestAsync(
	32	+ TRequest request,
	33	+ CancelationToken token = default
	34	+ );
	35	+
	36	+
	37	+ public async ValueTask<(Guid RequestId, TRequest Request)[]> GetForProcessingAsync(
	38	+ int count? = null
	39	+ );
	40	+
	41	+ public async ValueTask SetResultAsync(
	42	+ Guid requestId,
	43	+ TResponse response
	44	+ )
	45	+}
	46	+{{/code}}