如何实现BlockingCollection来修复此生产者/消费者问题？

Question

我目前有一个应用程序正在从套接字接收数据包,处理它们并将它们添加到ConcurrentQueue.然后我有一个处理这些项目的单独线程.

我遇到的问题是生产者/消费者问题,即使没有任何项目,消费者也试图获取物品,从而导致显着的CPU使用率.

ProcessPackets在自己的线程上运行:

    private ConcurrentQueue<PrimaryPacket> Waiting = new ConcurrentQueue<PrimaryPacket>();

    private void ProcessPackets()
    {
        PrimaryPacket e;

        while (true)
        {
            if (Waiting.TryDequeue(out e))
            {
                Packets.TryAdd(((ulong)e.IPAddress << 32 | e.RequestID), e);
            }
        }
    }

    public void AddPacket(PrimaryPacket e)
    {
        Waiting.Enqueue(e);
    }

实现BlockingCollection(T)来处理这个问题的最佳方法是什么？或另一种解决方案

另外值得注意的是,每秒大约有30,000个项目被添加到队列中.

Answer 1

你不必实现BlockingCollection<T>,你可以使用它.正如文档所说,它只是一个包装器IProducerConsumerCollection<T>,例如ConcurrentQueue<T>(这是默认的).

private BlockingCollection<PrimaryPacket> Waiting =
    new BlockingCollection<PrimaryPacket>();

private void ProcessPackets()
{
    while (true)
    {
        PrimaryPacket e = Waiting.Take();
        Packets.TryAdd(((ulong)e.IPAddress << 32 | e.RequestID), e);
    }
}

public void AddPacket(PrimaryPacket e)
{
    Waiting.Add(e);
}

Take()如果队列为空则阻塞,因此不会不必要地烧掉CPU.你应该考虑在处理完成后该怎么做.