Paraller Еогеасп в C#

Question

Я получаю индекс из ошибки диапазона, если я запускаю ниже код

var list=new list<PriceDetails>(); 
Parallel.ForEach(productResults.Items, productPrices => 
{ 
    var priceDetail=new PriceDetails { price=productPrices.prices.firstordefault();} 
    list.add(priceDetail); 
} 

Пожалуйста, приведите пример, который решает выше проблем с использованием одновременно?

Answer 1

Проблема, с которой вы сталкиваетесь, - List.Add(, не поддерживает несколько потоков, используя ее в то же время. Лучшим решением является использование PLinq для создания List<PriceDetails> через его функции и ToList().

var list = productResults.Items 
       .AsParallel() 
       .Select(productPrices => new PriceDetails { price = productPrices.prices.firstordefault()}) 
       .ToList(); 

Этот код будет проходить через вашу коллекцию источника параллельно строить свои новые классы затем объединить все, чтобы список и присвоить его переменной.

Тем не менее, я бы проверил это с и без AsParallel(). Параллель имеет накладные расходы, и создание нового класса обычно является дешевым ураном. Вы можете обнаружить, что ваш код работает быстрее без модификатора AsParallel().

Answer 2

List<T> разработан в соответствии с предположением, что он никогда не доступен из нескольких потоков одновременно. небезопасно манипулировать им из нескольких потоков параллельно. Вам понадобится использовать структуру данных другого типа, которую делает, поддерживая это, например, что-то в System.Collections.Concurrent. Хорошо, это или вы могли бы просто не делать этого параллельно, чтобы начать. Я не вижу причин распараллеливать эту задачу в первую очередь.