/// <summary> /// 總結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 /// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void btnParallel_Click(object sender, EventArgs e){//測試// Console.WriteLine("Begin");int num = 0;List<int> list = new List<int>();List<int> listParallel = new List<int>();for (int i = 1; i < 200001; i++){list.Add(i);}ConcurrentBag<int> cb = new ConcurrentBag<int>();//線程安全集合//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