Понимание параллельного программирования на C# с помощью асинхронных примеров

Здесь происходит то, что вы никогда не ждете завершения блока Parallel.ForEach — вы просто возвращаете сумку, в которую он в конечном итоге закачается. Причина этого в том, что поскольку Parallel.ForEach ожидает Action делегатов, вы создали лямбду, которая возвращает void, а не Task. Несмотря на то, что методы async void допустимы, они обычно продолжают свою работу в новом потоке и возвращаются к вызывающей стороне, как только они await создают задачу, и поэтому метод Parallel.ForEach считает, что обработчик выполнен, даже если он выбрасывает оставшуюся работу в отдельный поток. нить.

Вместо этого используйте здесь синхронный метод;

Parallel.ForEach(list, new ParallelOptions() { MaxDegreeOfParallelism = 2 }, index => 
{
    var response = client.GetAsync("posts/" + index).Result;

    var contents = response.Content.ReadAsStringAsync().Result;
    listResults.Add(contents);
    Console.WriteLine(contents);
});

Если вам абсолютно необходимо использовать await внутри, заверните его в Task.Run(...).GetAwaiter().GetResult();

Parallel.ForEach(list, new ParallelOptions() { MaxDegreeOfParallelism = 2 }, index => Task.Run(async () =>
{
    var response = await client.GetAsync("posts/" + index);

    var contents = await response.Content.ReadAsStringAsync();
    listResults.Add(contents);
    Console.WriteLine(contents);
}).GetAwaiter().GetResult();

Однако в этом случае Task.run обычно переходит в новый поток, поэтому мы лишили большей части контроля Parallel.ForEach; лучше использовать async до конца;

var tasks = list.Select(async (index) => {
        var response = await client.GetAsync("posts/" + index);

        var contents = await response.Content.ReadAsStringAsync();
        listResults.Add(contents);
        Console.WriteLine(contents);
    });
await Task.WhenAll(tasks);

Поскольку Select ожидает Func<T, TResult>, он будет интерпретировать лямбда async без return как метод async Task вместо async void и, таким образом, даст нам то, что мы можем явно await

Взгляните на это: Темы нет

Когда вы делаете несколько одновременных веб-запросов, тяжелую работу выполняет не ваш процессор. Это процессор веб-сервера, который обслуживает ваши запросы. Ваш процессор ничего не делает в это время. Это не особое «состояние ожидания» или что-то в этом роде. Аппаратное обеспечение внутри вашей коробки, которое работает, — это ваша сетевая карта, которая записывает данные в вашу оперативную память. Когда ответ будет получен, ваш ЦП будет уведомлен о поступивших данных, чтобы он мог что-то с ними сделать.

Вам нужен параллелизм, когда у вас есть тяжелая работа внутри вашей коробки, а не когда вы хотите, чтобы тяжелая работа выполнялась внешним миром. С точки зрения вашего процессора, даже ваш жесткий диск является частью внешнего мира. Таким образом, все, что относится к веб-запросам, применимо и к запросам, нацеленным на файловые системы и базы данных. Эти рабочие нагрузки называются привязкой ввода-вывода. , чтобы отличать их от так называемых рабочих нагрузок, связанных с процессором.

Для рабочих нагрузок, связанных с вводом-выводом, платформа .NET предлагает инструмент асинхронного Task. В библиотеках есть несколько API, которые возвращают Task объектов. Для достижения параллелизма обычно вы запускаете несколько задач, а затем await выполняете их с помощью Task.WhenAll. Существуют также более продвинутые инструменты, такие как Библиотека потоков данных TPL, созданная на основе Tasks. Он предлагает такие возможности, как буферизация, пакетная обработка, настройка максимальной степени параллелизма и многое другое.