Комментарий

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

Подробности

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

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

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

Содержимое

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