关于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);