Parallel.foreach не обрабатывает все предметы

Question

У меня проблема здесь. im пытается использовать Parallel.foreach для преобразования моего datatable в объект списка. вот так.

public List<ProductList> GetProductList(DataTable table) 
{ 
    List<ProductList> list = new List<ProductList>(); 
    Parallel.ForEach(table.AsEnumerable(), item => 
    { 

      string sku = item["product_sku"].ToString(); 
      //int skus = Convert.ToInt16(item["product_sku"]); 

      string price = item["product_price"].ToString(); 

      string tweakerID = item["ID"].ToString(); 
      string finalPrice = item["FinalPrice"].ToString(); 
      list.Add(new ProductList() { SKU = sku, Price = price, ID = id, FinalPrice = finalPrice }); 


    }); 





    list.RemoveAll(item => item == null); 

    return list; 
} 

У меня более 65000 строк продукции. и в дальнейшем. в список добавлено только 63000 продуктов. , но результат не является числом исправлений. например, последние три раза, когда я запускал этот код, я получил 63202, 64025, 62920. и каждый раз его новый номер.

Я также не получаю исключения.

Answer 1

Thats потому, что List<T> не является безопасным. Попробуйте следующее: ConcurrentBag<T>.

ConcurentBag существует в System.Collections.Concurrent пространства имен, которое содержит еще несколько коллекций, содержащих потоки.

Все элементы обработаны, но не все они добавлены в список. Причина в том, что, когда два потока пытаются добавить разные элементы в одно и то же время, список не может справиться с ним и сохраняет только один из них.