c# - ConcurrentQueue 中的所有项目都是相同的

Question

我有一个 NetworkStream 用于从另一个程序获取数据。数据以 Byte[64] 的形式到达，然后我将其排队到 ConcurrentQueue，以便另一个线程可以出队以供稍后分析。队列被实例化:

ConcurrentQueue<byte[]> fifo = new ConcurrentQueue<byte[]>();

然后我将所有发送的数据加入队列:

Byte[] bytesIn = new Byte[64];
int i;
while ((i = stream.Read(bytesIn, 0, bytesIn.Length)) != 0)
{
    fifo.Enqueue(bytesIn);
}

如果我随后查看(在调试期间)fifo 中的数据，就会发现其中包含的每个字节 [64] 都与最新的 bytesIn 相同。如何确保我添加到 fifo 的数组是值而不是指针(如果这是正确的术语)？

Answer 1

将数组的副本加入队列。您可以使用 ToArray为此的扩展。

while ((i = stream.Read(bytesIn, 0, bytesIn.Length)) != 0)
{
    var received = bytesIn.Take(i).ToArray();
    fifo.Enqueue(received);
}

我还使用了 Take修剪缓冲区，并仅复制接收到的字节。

或者，正如@hvd 在评论中所建议的那样，使用Array.Copy 会更快

while ((i = stream.Read(bytesIn, 0, bytesIn.Length)) != 0)
{
    var received = new byte[i];
    Array.Copy(bytesIn, 0, received, 0, i);

    fifo.Enqueue(received);
}