当前位置：文江博客话题详情

多个生产者，单个消费者

发布于 2024-10-19 04:36:56 字数 224 浏览 2 评论 0原文

我必须开发一个多线程应用程序，其中会有多个线程，每个线程都会生成需要保存在队列中的自定义事件日志（不是 Microsoft MSMQ）。

将会有另一个线程从队列中读取日志数据并对其进行操作，并使用某些信息将日志信息保存到文件中。基本上，我们在这里实现多生产者，单消费者范例。

任何人都可以提供有关如何在 C++ 或 C# 中实现此功能的建议吗？

谢谢，

原文

分享到QQ

分享到微博

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

发布评论

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

贱贱哒 2024-10-26 04:36:56

使用可以很容易地完成这种事情BlockingCollection在 System.Collections.Concurrent 中定义。

基本上，您创建队列，以便所有线程都可以访问它：

BlockingCollection<LogRecord> LogQueue = new BlockingCollection<LogRecord>();

每个生产者都将项目添加到队列中：

while (!Shutdown)
{
    LogRecord rec = CreateLogRecord(); // however that's done
    LogQueue.Add(rec);
}

消费者执行类似的操作：

while (!Shutdown)
{
    LogRecord rec = LogQueue.Take();
    // process the record
}

默认情况下，BlockingCollection使用ConcurrentQueue作为后备存储。 ConcurrentQueue 负责线程同步，并且 BlockingCollection 在尝试获取项目时执行非繁忙等待。也就是说，如果消费者在队列中没有项目时调用 Take，它将执行非繁忙等待（不休眠/旋转），直到有项目可用。

This kind of thing is very easy to do using the BlockingCollection<T> defined in System.Collections.Concurrent.

Basically, you create your queue so that all threads can access it:

BlockingCollection<LogRecord> LogQueue = new BlockingCollection<LogRecord>();

Each producer adds items to the queue:

while (!Shutdown)
{
    LogRecord rec = CreateLogRecord(); // however that's done
    LogQueue.Add(rec);
}

And the consumer does something similar:

while (!Shutdown)
{
    LogRecord rec = LogQueue.Take();
    // process the record
}

By default, BlockingCollection uses a ConcurrentQueue<T> as the backing store. The ConcurrentQueue takes care of thread synchronization and, and the BlockingCollection does a non-busy wait when trying to take an item. That is, if the consumer calls Take when there are no items in the queue, it does a non-busy wait (no sleeping/spinning) until an item is available.

回复收藏 0 原文