快捷導(dǎo)航

C# List 并發(fā)丟數(shù)據(jù)問(wèn)題原因及解決方案

更新時(shí)間：2021年02月20日 08:41:35 作者：丹楓無(wú)跡

這篇文章主要介紹了C# List 并發(fā)丟數(shù)據(jù)問(wèn)題原因及解決方案，幫助大家更好的理解和使用c#，感興趣的朋友可以了解下

項(xiàng)目中出了個(gè) BUG，就在我眼皮子底下，很明顯的一個(gè) BUG，愣是看了兩天才看出來(lái)。

我有多個(gè)任務(wù)并發(fā)，任務(wù)執(zhí)行完成后都有一個(gè)返回結(jié)果，我用一個(gè) List 將結(jié)果收集起來(lái)，等所有任務(wù)完成后，發(fā)送出去。結(jié)果一直丟數(shù)據(jù)。

我反復(fù)檢查邏輯都沒(méi)有問(wèn)題，最后恍然 List 是非線程安全的。

大家都知道 List 是非線程安全的，但是如果僅有 Add 操作呢？估計(jì)有些人就會(huì)認(rèn)為沒(méi)問(wèn)題。

下面的代碼，期望輸出的結(jié)果是 1000，然而，注釋掉 lock 后，結(jié)果就不一樣了。

class Program
{
 static List<Person> persons;

 static void Main(string[] args)
 {
  persons = new List<Person>();

  object sync = new object();

  Parallel.For(0, 1000, (i) =>
  {
   Person person = new Person
   {
    ID = i,
    Name = "name" + i
   };
   lock (sync)
    persons.Add(person);
  });

  Console.WriteLine(persons.Count);
  Console.ReadLine();
 }

 class Person
 {
  public int ID { get; set; }
  public string Name { get; set; }
 }
}

利用安全集合ConcurrentBag取代list

測(cè)試程序

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace MyConcurrent
{
  class Program
  {
    /// <summary>
    /// ConcurrentBag并發(fā)安全集合
    /// </summary>
    public static void ConcurrentBagWithPallel()
    {
      ConcurrentBag<int> list = new ConcurrentBag<int>();
      Parallel.For(0, 10000, item =>
      {
        list.Add(item);
      });
      Console.WriteLine("ConcurrentBag's count is {0}", list.Count());
      int n = 0;
      foreach (int i in list)
      {
        if (n > 10)
          break;
        n++;
        Console.WriteLine("Item[{0}] = {1}", n, i);
      }
      Console.WriteLine("ConcurrentBag's max item is {0}", list.Max());
    }
    
 
    /// <summary>
    /// 函數(shù)入口
    /// </summary>
    /// <param name="args"></param>
    static void Main(string[] args)
    {
      Console.WriteLine("ConcurrentBagWithPallel is runing" );
      ConcurrentBagWithPallel();
 
      Console.Read();
    }

以上就是C# List 并發(fā)丟數(shù)據(jù)問(wèn)題原因及解決方案的詳細(xì)內(nèi)容，更多關(guān)于C# List 并發(fā)丟數(shù)據(jù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: