在队列上存在多个线程操作的情况下访问 ConcurrentQueue 的最新元素

Question

我们有一个 ConcurrentQueue，用于在 3 个线程之间共享数据。线程 A 不断向队列填充数据。线程 B 旨在将此数据记录到文件中。线程 C 应该检索队列中最新的条目（或尽可能接近最新的条目），对其执行一些操作并将结果显示在屏幕上。

线程B为了及时对文件写操作进行集群，会做这样的事情：

if (cq.Count > 100)
{
    while (cq.Count > 1)
    {
        qElement = PopFromCq(cq); // PopFromCq uses cq.TryDequeue()
        bw.Write(qElement.data); // bw is a binary writer
    }
}
else
{
    System.Threading.Thread.Sleep(10);
}

即等待至少100个元素排队，然后将它们写入磁盘。但它始终在队列中维护至少一项，原因是我们希望线程 C 始终能够访问至少一项。

线程 C 中的循环如下所示：

while (threadsRunning) 
{
    System.Threading.Thread.Sleep(500); // Update twice per second
    ProcessDataAndUpdateScreen(cq.ElementAt(cq.Count - 1)); // our terrible attempt at looking at the latest (or close to latest) entry in the queue
}

在此循环中，由于将数据写入磁盘的线程与 cq.ElementAt(cq.Count-1) 调用之间的竞争，我们有时会遇到异常。我相信发生的事情如下：

1. cq.Count 计算为 90。
2. 那时，线程 B 已经开始循环，并且正在将数据从队列中取出以写入磁盘
3. 。 ) 被调用时，线程 B 消耗了许多项目，使得 (cq.Count - 1) 不再指向队列中的有效条目。

关于在队列上运行多个线程的情况下访问队列中最新条目的好方法是什么？

问候，

Answer 1

AB通信和AC通信是否都需要经过队列？如果您让线程 A 将每个条目写入队列（供 B 读取和记录），并保存该条目，它只是在某处的易失性属性中排队。每次C想要获取最年轻的元素时，它都可以直接从该属性中读取。

编辑：您实际上应该使用 Interlocked.CompareExchange(T, T) 来设置和读取“最新条目”属性，而不是仅仅依赖于易失性属性。