#c_sharp #net
Пример от andreycha паттерна throttling:
public async Task CheckServers()
{
var servers = new List(10000) { ... };
const int ConcurrencyLevel = 100;
// запускаем первые 100 запросов
var tasks = servers.Take(ConcurrencyLevel).Select(GetVersion).ToList();
int nextIndex = ConcurrencyLevel;
while (tasks.Count > 0)
{
// дожидаемся завершения любого запроса
var completedTask = await Task.WhenAny(tasks);
// удаляем его из списка
tasks.Remove(completedTask);
// добавляем новый запрос, если таковые остались
if (nextIndex < servers.Count)
{
tasks.Add(GetVersion(servers[nextIndex++]));
}
string rfbVersion = await completedTask;
// работаем с версией
}
}
Как в подобной реализации красиво задать параметр TaskCreationOptions.LongRunning
задачам? Это вообще возможно без использования Task.Factory.StartNew?
Ответы
Ответ 1
Смотрите. Давайте разделим Task'и и другие асинхронные функции на те, которые ограничены процессором (то есть, занимают фиксированный поток длительное время), и остальные. Для первых функций TaskCreationOptions.LongRunning имеет смысл, т. к. мы не хотим надолго блокировать поток из пула потоков. Но такие функции обычно предоставляются в виде синхронных функций, которые мы запускаем через Task.Run. Так что можно, при желании, запустить и через Task.Factory.StartNew. Для остальных асинхронных функций нету понятия «поток, в котором функция бежит», и большую часть времени Task не бежит нигде, просто ожидая окончания await. Для таких функций TaskCreationOptions.LongRunning лишено смысла, и задать его сложно (если и можно вообще). Но в этом случае эта опция и не нужна.
Комментариев нет:
Отправить комментарий