關於Queue的相關問題

在多線程中使用Queue,發現老是有莫名的問題, 經摺騰很久以後發現是由於沒有加鎖!

如下測試代碼中, 若是不加鎖, 添加 100W對象, 可能只會成功50W, 而後並不會產生異常!

 

 1             var mQueues = new Queue<int>(1000000);//(若是初始數量設置過大會直接崩潰)
 2             System.Threading.WaitCallback callback = (o) =>
 3             {
 4                 for (int i = 0; i < 10000; i++)
 5                 {
 6                     lock (mQueues)//不加鎖添加失敗
 7                     {
 8                         mQueues.Enqueue(i);
 9                     }
10                 }
11             };
12 
13             for (int i = 0; i < 100; i++)
14             {
15                 System.Threading.ThreadPool.QueueUserWorkItem(callback, null);
16             }
17 
18             System.Threading.Thread.Sleep(3000);
19             Console.WriteLine(mQueues.Count);