.NET 消费者线程处理两个队列的算法（基于优先级）

发布于 2024-10-29 01:07:02 字数 471 浏览 5 评论 0原文

我有一个 C# 4.0 应用程序，其“高优先级”和“低优先级”队列的实现如下：

BlockingCollection highPriority = new BlockingCollection(1000); BlockingCollection lowPriority = new BlockingCollection(1000);

在 highPriority 中生成的任何数据都应在 lowPriority 中生成的任何数据之前被消耗。这里的不同之处在于，数据可以随时生成到两个队列中的任何一个。因此，在消耗完 highPriority 中的所有数据后，我将消耗可能处于 lowPriority 中的任何数据。如果当我在 lowPriority 中消费数据时，在 highPriority 中产生新数据，我想完成对 lowPriority 中当前项目的消费，然后切换回并处理 highPriority 中的数据。

谁能建议一种算法来帮助解决这个问题？伪代码没问题。非常感谢。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

方觉久 2024-11-05 01:07:02

这个怎么样：

while(true)
{
    workitem = highQueue.dequeue();

    if(workitem == null)
        workitem = lowQueueu.dequeue()

    process(workitem)
}

How about this:

while(true)
{
    workitem = highQueue.dequeue();

    if(workitem == null)
        workitem = lowQueueu.dequeue()

    process(workitem)
}

回复收藏 0 原文

最丧也最甜 2024-11-05 01:07:02

如果可以的话，您将希望将其包装到单个对象中，正如 @Kevin Brock 建议的那样，并让该对象实现 IProducerConsumerCollection。否则，调用 TryDequeue 的代码将执行繁忙的等待循环。也就是说，有两个队列，你必须这样写：

WorkItem item = null;
do
{
    if (!hpQueue.TryDequeue(out item))
    {
        lpQueue.TryDequeue(out item);
    }
while (item != null);

如果你使用自己的类，那么你可以使用事件（EventWaitHandle等）来防止忙等待。

事实上，使用优先级队列可能会更好。使优先级队列线程安全并实现 IProducerConsumerCollection 非常容易，然后您可以将其与 BlockingCollection 一起使用。 Julian Bucknall 的 C# 中的优先级队列是一个不错的起点。

You'll want to wrap this into a single object if you can, as @Kevin Brock suggested, and have that object implement IProducerConsumerCollection. Otherwise your code that calls TryDequeue will have do do a busy wait loop. That is, with two queues, you have to write something like:

WorkItem item = null;
do
{
    if (!hpQueue.TryDequeue(out item))
    {
        lpQueue.TryDequeue(out item);
    }
while (item != null);

If you use your own class, then you can use events (EventWaitHandle, etc.) to prevent the busy waiting.

In truth, you'd probably be better off using a priority queue. It would be pretty easy to make a priority queue thread-safe and implement IProducerConsumerCollection, and then you can use it with BlockingCollection. A good place to start would be Julian Bucknall's Priority Queue in C#.

回复收藏 0 原文

樱花坊 2024-11-05 01:07:02

我会用一个优先级队列来做到这一点。这将允许您稍后添加第三优先级，只需很少的代码更改。

我在使用 lockFree-SkipList 之前写过一个项目，但这里有一个使用普通跳过列表的项目（http://www.codeproject.com/KB/recipes/PriorityQueueSkipList.aspx）。我使用了跳跃列表，因为它们在并发下表现良好并且实现起来非常简单（减去无锁版本）。

我还在 CodePlex 上看到了一个使用红黑树的优先级队列，但我现在找不到它。
更新：我正在考虑的优先级队列实现是 NGenerics 项目的一部分：http://code.google .com/p/ngenerics/

回复收藏 0 原文

~没有更多了~