本文共 1953 字，大约阅读时间需要 6 分钟。
////// 總結1： paraller.ForAll，parallel.ForEach ,并行操作共享變量Num,List時，因不同線程同時訪問，可能會得不到預想 的結果: /// 1.1. 開啟多個線程，并行無序遍歷全部集合的元素，完成后再執行后面的語句。 /// 1.1 int Num ++ ，執行完后，得不到預期每次加1的結果 /// 1.2 listParallel.Add(o) 執行完后，listParallel.Count()不對，里面的元素也不正確， 還有可能不是原集合里的元素，出現0,""等數據類型 的默認值。 /// 總結2： 并行寫入數據庫表時，寫入總行數正確；自增長ID字段寫入正常，不會重復，這是SQL SERVER 的機制作用； /// 主鍵數據值字段不會重複（取自集合的唯一值字段），表示每個元素都有遍歷到，且不到重複遍歷。 /// 總結3： 使用線程安全集合 ConcurrentBag . 避免上述的一些問題。 /// ConcurrentBag進一步參考：https://docs.microsoft.com/zh-tw/dotnet/api/system.collections.concurrent.concurrentbag-1?view=net-5.0 /// /// /// private void btnParallel_Click(object sender, EventArgs e) { //測試 // Console.WriteLine("Begin"); int num = 0; List list = new List (); List listParallel = new List (); for (int i = 1; i < 200001; i++) { list.Add(i); } ConcurrentBag cb = new ConcurrentBag ();//線程安全集合 //Enumerable.Range(1, 200000).AsParallel().ForAll(o => list.AsParallel().ForAll (o=> { //多個線程并行，無序遍歷集合元素Console.WriteLine("Thread...{0},Number:{1}", Thread.CurrentThread.ManagedThreadId.ToString(), o")); num++; listParallel.Add(o); cb.Add(o); //測試并行寫入數據庫表。結果顯示: 自增長ID正常；寫入總行數正確；主鍵數據值不會重複，表示每個元素都有遍歷到，且不到重複遍歷。 SqlParameter[] param = { new SqlParameter("@val",o) }; sqlherpler.exesql("insert into test(val) values (@val)", param); }); Console.WriteLine($"Num++: {num.ToString()}"); Console.WriteLine($"List count: {listParallel.Count()}"); //線程安全集合 ConcurrentBag的結果 Console.WriteLine($"ConcurrentBag count: {cb.Count()}"); cb.AsEnumerable().GroupBy(o => o).Where(g => g.Count() > 1).ToList().ForEach(d=>Console.WriteLine($"Deplicates CB:{d.Key}")); Console.WriteLine("End");
//結果：
//Num++: 187971 //List count: 187843 //ConcurrentBag count: 200000 //End转载地址：http://limdi.baihongyu.com/