从C#中的ConcurrentQueue中取出队列对象

嘿,我正在为异步服务器在C#中实现一个ConcurrentQueue.收到完整信息后,项目正在排队.要使消息出队,我正在进行少量线程来执行排队和服务请求的工作.这是不充分的,因为每个线程使用while循环,由于显而易见的原因,它消耗相当大量的处理器时间.

有人知道在需要时将消息排队的方法,但不消耗这么多处理时间.

{
    ...

    for (int i = 0; i < 3; i++)
    {
        Thread t = new Thread(new ThreadStart(startParsingMessages));
        t.Start();
    }

    ...
}

private void startParsingMessages()
{
    QueueContainer dequeued = null;
    Console.WriteLine("Trying");
    while (true)
    {
        if (queue.TryDequeue(out dequeued))
        {
            Console.WriteLine("processing queue");
            ProcessMessage(dequeued.socket,dequeued.message);
        }
    }
}

解决方法

而不是使用ConcurrentQueue< T>直接,你试过在 BlockingCollection<T>中包装吗？然后,您可以使用TryTake(out T,TimeSpan)等.我相信这是预期的用途：并发集合本身通常会在那里,以便您可以选择阻止集合的工作方式.

这当然不一定是这些集合的唯一用途,但是特别是对于ConcurrentQueue< T>,生产者/消费者队列场景是最常见的 – 在该点BlockingCollection< T>是方便做正确的事情.