Der*_*ick 27 .net c# multithreading thread-safety
我有一种情况,很少有对象的队列出列空.对Enqueue的唯一调用是在类本身内:
m_DeltaQueue.Enqueue(this);
Run Code Online (Sandbox Code Playgroud)
很少,null在以下代码中从此队列中出列(静态方法):
while (m_DeltaQueue.Count > 0 && index++ < count)
if ((m = m_DeltaQueue.Dequeue()) != null)
m.ProcessDelta();
else if (nullcount++ < 10)
{
Core.InvokeBroadcastEvent(AccessLevel.GameMaster, "A Rougue null exception was caught, m_DeltaQueue.Dequeue of a null occurred. Please inform an developer.");
Console.WriteLine("m_DeltaQueue.Dequeue of a null occurred: m_DeltaQueue is not null. m_DeltaQueue.count:{0}", m_DeltaQueue.Count);
}
Run Code Online (Sandbox Code Playgroud)
这是生成的错误报告:
[Jan 23 01:53:13]:m_DeltaQueue.发生null的取消:m_DeltaQueue不为null.m_DeltaQueue.count:345
关于如何在此队列中出现空值,我感到非常困惑.
在我写这篇文章时,我想知道这是否可能是线程同步的失败; 这是一个多线程应用程序,可能在另一个线程中同时发生入队或出队.
目前这是在.Net 4.0下,但它以前发生在3.5/2.0
更新:
这是我(希望是正确的)解决问题的方法,尽管下面的重要答案是同步问题,但这个解决方案已经明确了.
private static object _lock = new object();
private static Queue<Mobile> m_DeltaQueue = new Queue<Mobile>();
Run Code Online (Sandbox Code Playgroud)
排队:
lock (_lock)
m_DeltaQueue.Enqueue(this);
Run Code Online (Sandbox Code Playgroud)
出列:
int count = m_DeltaQueue.Count;
int index = 0;
if (m_DeltaQueue.Count > 0 && index < count)
lock (_lock)
while (m_DeltaQueue.Count > 0 && index++ < count)
m_DeltaQueue.Dequeue().ProcessDelta();
Run Code Online (Sandbox Code Playgroud)
我仍然试图找到适当的同步,所以任何关于正确性的评论都将非常感激.我最初选择使用队列本身作为同步对象,因为它是私有的,并且对已经非常大的类引入了更少的混乱.基于John的建议,我将其更改为锁定一个新的私有静态对象_lock.
SLa*_*aks 30
this除非使用call手写IL中的指令调用该方法,否则永远不能为null .
但是,如果同时Queue在多个线程上使用相同的实例,则队列将损坏并丢失数据.
例如,如果将两个项目同时添加到近容量队列,则第二个项目可能会在第二个线程调整大小后将其添加到数组中,这将最终复制null到调整大小的数组并将第一个项目添加到旧的阵列.
您应该使用锁保护您的队列或使用.Net 4 ConcurrentQueue<T>.
| 归档时间: |
|
| 查看次数: |
3702 次 |
| 最近记录: |