嘿,我正在为异步服务器在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); } } }@H_301_6@
解决方法
而不是使用ConcurrentQueue< T>直接,你试过在
BlockingCollection<T>
中包装吗?然后,您可以使用TryTake(out T,TimeSpan)等.我相信这是预期的用途:并发集合本身通常会在那里,以便您可以选择阻止集合的工作方式.
这当然不一定是这些集合的唯一用途,但是特别是对于ConcurrentQueue< T>,生产者/消费者队列场景是最常见的 – 在该点BlockingCollection< T>是方便做正确的事情.
@H_301_6@ @H_301_6@