并发收集优先

Question

我有一些它检索服务器列表数据的线程。服务器列表每5分钟从服务器解析器下载。我的线程处理数据应该只使用响应时间最短的服务器。每个服务器的响应时间可能与请求请求的显着不同。因此，在更新服务器列表之间的时间范围内，我应该验证每个服务器的响应时间。

我最初的做法是创建两个额外的线程：首先更新服务器列表，第二次从每个服务器验证的响应时间和排序根据它们的响应时间服务器的列表。

我试图使用BlockingCollection，它被设计为连接生产者和消费者，但在我的任务中，我有两个并发使用者，并且BlockingCollection也没有本地能力插入项目以创建服务器的优先级列表。

ConcurrentStack或ConcurrentQueue也不能按原样使用，因为它们像BlockingCollection一样是非阻塞的，它们需要额外的机制来阻塞需要来自队列的线程的线程。

请帮我解决这个任务

感谢

Answer 1

不幸的是，这是不是内置的，您可能需要实现自己的。为了帮助您开始使用，已经在msdn示例中实现了此功能，可以使用BlockingCollection。

http://blogs.msdn.com/pfxteam/archive/2010/04/04/9990342.aspx

为了更高效地实现你需要将它基于堆数据结构。这里是一个很好的文章虽然类不实现IProducerConsumerCollection：

http://www.codeproject.com/Articles/126751/Priority-queue-in-C-with-the-help-of-heap-data-str

Answer 2

考虑使用两个或两个以上BlockingCollection S和使用TakeFromAny听所有队列。该方法（虽然我没有看到它在文档中提到）更喜欢从它正在监听的队列数组中的第一个队列获取元素。