加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

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

发布时间:2020-12-15 07:48:52 所属栏目:百科 来源:网络整理
导读:嘿,我正在为异步服务器在C#中实现一个ConcurrentQueue.收到完整信息后,项目正在排队.要使消息出队,我正在进行少量线程来执行排队和服务请求的工作.这是不充分的,因为每个线程使用while循环,由于显而易见的原因,它消耗相当大量的处理器时间. 有人知道在需要时
嘿,我正在为异步服务器在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>是方便做正确的事情.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读