C＃中的并发静态队列不保留我的数据

Question

因此，我有一个线程处理数据并放入队列，然后另一个线程将信息取出并对其执行一些操作。

这里是队列

public static class MyConcurrentQueue 
{ 
    public static ConcurrentQueue<cRule> _Queue; 

    public static void EnqueueRuleTrigger(cRule _Rule) 
    { 
     MyConcurrentQueue._Queue.Enqueue(_Rule); 
    } 
} 

上的Application_Start我有

MyConcurrentQueue._Queue = new ConcurrentQueue<cRule>(); 

如果我想排队的规则，我使用

MyConcurrentQueue.EnqueueRuleTrigger(_Rule); //We're done enqueue the rule 

出队我用

MyConcurrentQueue._Queue.TryDequeue(out _Rule) 

我注意到，如果在一个紧凑的循环排队2项，1后，其他由第一离队[单独的非同步线程]时，在日志文件中的数据没有了匹配排队

如果我在队列之间进行睡眠，那么日志会读取正确的值，可能是因为一个项目被放入，被取出，另一个项目被放入，被取出。

我想这是因为队列是静态的，它存储对_Rule的引用而不是其副本。关于如何解决这个问题的任何想法？我需要队列可以被多个线程访问，这就是为什么我首先使它成为静态的原因。

在此先感谢。

编辑

这是我入队和日志和出队和逻辑日志

while (x<=y) 
        { 

    MyConcurrentQueue.EnqueueRuleTrigger(_Rule); //We're done enqueue the string AllText = File.ReadAllText(@"C:\Default\New.txt"); 
File.WriteAllText(@"C:\Default\New.txt", AllText + "\r\nEnqueue Alert:" + 
_Rule.AlertID +":" + _Rule.TriggerStartTime + "-" + _Rule.TriggerEndTime); 

} 

这是一个单独的线程

if (MyConcurrentQueue._Queue.TryDequeue(out _Rule)) 
       { 
... some logic 
    File.WriteAllText(@"C:\Default\New.txt", AllText + "\r\nDequeue Alert:" + 
_Rule.AlertID + ":" + _Rule.TriggerStartTime + "-" + _Rule.TriggerEndTime); 
    } 

这是我的日志文件

Enqueue Alert：64c88289-58a1-499b-ade9-3 fa69a32cf47：2012/4/27 12:00:00 PM-4/27/2012 5:00:00 PM

Enqueue Alert：64c88289-58a1-499b-ade9-3fa69a32cf47：2012/4/28 2:00 ：00 PM-4/28/2012 9:00:00 PM

Dequeue Alert：64c88289-58a1-499b-ade9-3fa69a32cf47：2012/4/28 2:00:00 PM-4/28/2012 9 ：00：00 PM

出列提醒：64c88289-58a1-499b-ade9-3fa69a32cf47：2012年4月28日下午二点00分00秒-4 /二千○十二分之二十八下午9时00分○○秒

Answer 1

EDIT ：看起来是一个射入物体的问题，而不是改变同一物体并第二次射入物体。因为在出队期间它看起来像第二个对象覆盖第一个并被插入两次，实际上对同一个对象的引用被插入两次。

最可能的解决方案是在插入之前进行深度克隆。考虑让你的对象不可变，以简化代码的同步和可读性。

原文：

大多数likly原因是你的日志代码不正确同步。由于看起来你想要2动作自动发生（Enqueue + Log或Dequeue + Log），所以你必须在两个操作中添加适当的锁定，否则对Queue和Log的调用顺序可能是半随机的。还要确保你正确处理TryDequeue的结果（因为它可以返回false）。

static object logAndQueueLock = new object(); 
public static void EnqueueRuleTrigger(Rule rule) 
{ 
    lock(logAndQueueLock) 
    { 
     MyConcurrentQueue._Queue.Enqueue(rule); 
     Log.Message("Enqueued:"+ rule.ToString()); 
    } 
} 

public static Rule DequeueRuleTrigger() 
{ 
    lock(logAndQueueLock) 
    { 
     Rule rule = null; 
     if (MyConcurrentQueue._Queue.Enqueue(out rule)){ 
     Log.Message("Enqueued:"+ rule.ToString()); 
     } 
     return rule; 
    } 
}