当前位置：首页 > news >正文

C#Queue＜T＞队列出现弹出元素被最后一次压入得元素覆盖的问题

news 2025/7/13 14:05:41

问题代码：

//以下为现有代码的大概描述，只可意会，不可执行！！！Queue<Move> mQueue = new Queue<Move>();
//该接口为下面描述线程A、线程B调用的接口
private void ActionTrigger(Move move)//Move表示一个类，由外部传入
{lock(mlock){    this.DoMove1(move);//将move压入队列ThreadPool.QueueUserWorkItem(new WaitCallback(this.DoMove2());//启用多线程将move弹出，并执行相关动作。}
}private void DoMove1(Move move)
{lock(mlockEn){mQueue.Enqueue(move);}
}private void DoMove2(object obj)
{lock(mlockDe){while(mQueue.Count>0){Move mtmp = mQueue.Dequeue();//通过打印mtmp地址、mtmp中变量指向的地址发现，出现问题时，连续添加的Move均被最后一个元素覆盖。//根据mtmp执行相关耗时动作}}
}

问题背景：

1.一个线程A不间断向Queue压入元素，压入元素后，会启动多线程进行元素弹出，执行相关耗时动作。

2.启动另外一个线程B连续向Queue压入元素。

问题现象：

线程B连续压入的元素，弹出的元素值均为最后一次压入的元素值。

问题原因：

网上查找问题原因

1）C#中的Queue类是一个先进先出（FIFO）的数据结构，它使用一个数组来存储队列中的元素。当你向一个空的Queue中添加元素时，它会直接存储在数组的第一个位置上。

当你弹出一个元素后，Queue会将数组中的元素向前移动一个位置，填补被弹出的元素位置。这样，新添加的元素会被放置在队列的末尾。

所以，如果你在没有弹出队列中的所有元素之前再次添加一个元素，那么这个新添加的元素会被放置在队列的末尾。当你继续弹出元素时，它们将按照添加的顺序依次被弹出，而最后一个添加的元素将成为队列中的第一个元素，并且覆盖之前添加的元素。

如果你希望保留之前添加的元素并且不被覆盖，你可以在添加新元素之前先将队列中的所有元素弹出，然后再将它们添加回队列中。或者你可以考虑使用其他数据结构，比如List，根据需要进行操作。

2）网上查找给出一定思路，本身Queue不是线程安全的，那么采用线程安全的队列ConcurrentQueue()，但问题依然存在。