Комментарий

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

Подробности

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

Содержимое

...	...	@@ -1,5 +1,6 @@
1	1	[[Асинхронность. Async Await>>doc:Разработка.NET.C#.Многопоточность.Асинхронность\. Async Await.WebHome]]
2	2
	3	+[[ConcurrentDictionary>>doc:Разработка.NET.C#.Коллекции.System\. Collections\. Concurrent.ConcurrentDictionary.WebHome]]
3	3
4	4	----
5	5
...	...	@@ -8,38 +8,16 @@
8	8	2) LongPooling
9	9
10	10
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, в котором содержится некоторый результат обработки.
	12	+| |
	13	+|1) От клиентов поступают заявки на некоторую обработку.
	14	+На основе заявки создается запись (State) в потокобезопасной коллекции. (В записи также содержиться CancalidationToken, позволяющий прервать await клиента)
	15	+Запрос встате на ожидание обработки с await. (LongPooling не разрываем соединение с клиентом)|
	16	+|2) Через некоторые промежутки времени запускается некоторый [[Концепция Worker (Worker and WorkerParallelWrapper)>>doc:Архитектура и модели.Модели.Концепция Worker (Worker and WorkerParallelWrapper).WebHome]], который берет группу заявок из потокобезопасной коллекции и начинает их обрабатывать.
	17	+По окончанию обработки Worker записывает результаты в соответсвущие State и вызывает CancalidationToken, чтобы разблокировать ожидающего клиента.|
	18	+|3) Клиент выходит с await и забирает свой State, в котором содержиться некоторый результат обработки.
18	18	(
19		- Статус успешно и результат
	20	+ Статуст успешно и результат
20	20	либо статус ошибка и сообщенеи об ошибке
21		-)
	22	+)|
22	22
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}}
	24	+