ConcurrentQueue 保存对象的引用或值？ “内存不足”异常

排队到 ConcurrentQueue 的对象是被复制到队列还是仅复制到它们的引用？

我不明白任何场景。

解释：

我这样定义了一个 ConcurrentQueue：

// BufferElement is a class I created
private ConcurrentQueue<BufferElement> _bufferQueue;

我有一个被调用很多次的函数，其目的是将一个元素加入队列：

private void EnqueueElementToBuffer(string data, int moreData)
{
    // the bufferElement constructor is setting data and moreData to it's fields.
    BufferElement bufferElement = new BufferElement(data, moreData);
    bufferQueue.Enqueue(bufferElement);
}

当我运行这个时，一段时间后我会出现内存不足异常。我想这可能是因为垃圾收集器没有收集bufferElement因为它仍然在bufferQueue，所以我将函数更改为：

private void EnqueueElementToBuffer(string data, int moreData)
{
    // _bufferElement is now a filed of the class
    _bufferElement.Data = data;
    _bufferElement.MoreData = moreData;
    bufferQueue.Enqueue(_bufferElement);
}

我没有得到异常，而且根据 Windows 任务管理器中的内存判断，我也不打算得到异常。

现在我认为问题已经解决了，因为当我将对象排队到队列中时，只有对对象的引用被cpoied到队列中，但我担心队列中的所有元素都引用同一个对象，所以我检查了另一个我在另一个线程中有一个函数，它的作用是：

    // while bufferQueue is not empty do the following
    BufferElement bufferElement = null;
    bufferQueue.TryDequeue(out bufferElement);

我检查了几个元素的内容，发现它们的内容不同！那么，如果排队到队列中的对象是按值复制的，为什么我一开始会遇到内存不足异常？

你打电话时Enqueue仅引用的副本存储在ConcurrentQueue<T>。但是这个引用是强保留的，这意味着它确实将实际引用的对象保留在内存中。在从引用中删除该元素之前，该元素将不符合收集条件ConcurrentQueue<T>

您没有看到的原因OutOfMemoryException当您切换到使用字段时是因为您从根本上改变了语义

• 原始代码：将对 N 个元素的 N 个引用推送到队列中，因此它在内存中保存了 N 个元素
• 更改的代码：将对 1 个元素的 N 个引用推送到队列中，因此它在内存中保存 1 个元素

这显着减少了内存量ConcurrentQueue<T>对象图保存在内存中并防止了异常。

这里的问题似乎是您对元素进行排队的速度比处理它们的速度快得多。只要这种情况成立，您最终将耗尽应用程序中的内存。您的代码需要进行调整，以免遇到这种情况。

注意：这个答案是假设BufferElement is a class而不是一个struct.

注2：正如 Servy 在评论中指出的那样，您可能需要考虑切换到BlockingCollection<T>因为它具有一些可能对您有所帮助的节流功能。

• http://msdn.microsoft.com/en-us/library/dd267312.aspx http://msdn.microsoft.com/en-us/library/dd267312.aspx