嘿,我正在为异步服务器在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>是方便做正确的事情.
