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; 
    } 
}