关于Queue的相关问题

时间 2019-11-11

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