⚙️ Параллельная асинхронная обработкаВ высоконагруженных приложениях часто требуется запустить несколько независимых операций параллельно и дождаться их завершения полностью или частично.
🛠
Дождаться всех задач —
Task.WhenAll Когда нужно запустить сразу несколько независимых операций и обработать результаты только после того, как все они завершатся.
1. Запускаем задачи параллельно:
var loadUsers = LoadUsersAsync(); // загрузка списка пользователей
var loadOrders = LoadOrdersAsync(); // загрузка списка заказов
var loadCatalog = LoadCatalogAsync(); // загрузка каталога товаров
2. Ждём завершения всехawait Task.WhenAll(loadUsers, loadOrders, loadCatalog);
3. Получаем результатыvar users = await loadUsers; // List<User>
var orders = await loadOrders; // List<Order>
var catalog = await loadCatalog; // List<Product>
Console.WriteLine($"Пользователей: {users.Count}, заказов: {orders.Count}, позиций: {catalog.Count}");
Для задач с возвращаемым значением WhenAll вернёт массив результатов в том же порядке.
Если нужно ограничить количество одновременных операций — обёрните запуск через
SemaphoreSlim.
Передавайте
CancellationToken во все методы, чтобы можно было прервать все сразу.
🛠 Дождаться первой завершившейся задачи —
Task.WhenAnyКогда важно получить результат как можно скорее и дальше обработать только первый ответ.
1. Запускаем конкурирующие задачи
var t1 = GetFromCacheAsync(userId, ct);
var t2 = GetFromDatabaseAsync(userId, ct);
var t3 = GetFromApiAsync(userId, ct);
2. Ждём первую завершившуюся
Task<Task<User?>> first = Task.WhenAny(t1, t2, t3);
Task<User?> winner = await first;
3. Получаем и обрабатываем результатUser? user = await winner;
if (user != null)
Console.WriteLine($"Данные получены от {GetSourceName(winner)}");
else
Console.WriteLine("Пустой ответ от первого источника");
Передавайте единый CancellationToken через CancellationTokenSource, чтобы отменять все задачи разом.
Назначайте разумный таймаут через
Task.WhenAny с
Task.Delay, чтобы не ждать вечно:
var timeoutTask = Task.Delay(TimeSpan.FromSeconds(5), ct);
var winner = await Task.WhenAny(t1, t2, t3, timeoutTask);
if (winner == timeoutTask) throw new TimeoutException();
Для большого числа конкурирующих операций рассматривайте использование
Channel или
Dataflow вместо запуска сотен
Task.
🐸Библиотека шарписта #буст
