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

在 C++ 中构建多线程工作队列（消费者/生产者）

发布于 2024-08-13 06:02:35 字数 245 浏览 5 评论 0原文

我有以下场景：我有一个线程应该填充带有整数对的容器（本质上是任务描述），我有一个很大的应从此容器中获取元素并执行操作的工作线程数 (8-16) 一些工作。

我认为这个问题可以通过阻塞队列轻松解决——例如，在项目删除时，线程同步对队列的访问，如果没有可用数据则休眠。

我（也许是错误的）认为类似的东西应该存在于 STL 或 boost 中，但我找不到任何东西。

我真的必须自己实现那件事吗？这似乎是一个很常见的场景......

原文

分享到QQ

分享到微博

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

发布评论

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

白色秋天 2024-08-20 06:02:35

如果您自己实现它，那么该实现应该是信号量、互斥体和队列对象的相当简单的组合。

这是一些伪代码：

Produce{
    pthread_mutex_lock(&mutex);
    queue.push_back(someObjectReference);
    pthread_mutex_unlock(&mutex);
    sem_post(&availabilitySem);
}

Consume{
    sem_wait(&availabilitySem);
    pthread_mutex_lock(&mutex);
    queue.pop_front(someObjectReference);
    pthread_mutext_unlock(&mutex);
}

If you do implement it yourself, the implementation should be a fairly straightforward combination of a semaphore, a mutex, and a queue object.

Here's some pseudo-code:

Produce{
    pthread_mutex_lock(&mutex);
    queue.push_back(someObjectReference);
    pthread_mutex_unlock(&mutex);
    sem_post(&availabilitySem);
}

Consume{
    sem_wait(&availabilitySem);
    pthread_mutex_lock(&mutex);
    queue.pop_front(someObjectReference);
    pthread_mutext_unlock(&mutex);
}

回复收藏 0 原文

阳光下的泡沫是彩色的 2024-08-20 06:02:35

如果您使用的是 Windows，请查看 VS2010 中的代理库，这是一个核心场景。

http://msdn.microsoft.com/en-us /library/dd492627(VS.100).aspx

即

//an unbounded_buffer is like a queue
unbounded_buffer<int> buf;

//you can send messages into it with send or asend
send(buf,1);

//receive will block and wait for data
int result = receive(buf)

您可以使用线程、“代理”或“任务”来获取数据...或者您可以将缓冲区链接在一起并转换您的阻塞语义生产者/消费者数据流网络的问题。

If you are on windows take a look at the agents library in VS2010 this is a core scenario.

http://msdn.microsoft.com/en-us/library/dd492627(VS.100).aspx

i.e.

//an unbounded_buffer is like a queue
unbounded_buffer<int> buf;

//you can send messages into it with send or asend
send(buf,1);

//receive will block and wait for data
int result = receive(buf)

you can use threads, 'agents' or 'tasks' to get the data out... or you can link buffers together and convert your blocking semantic producer / consumer problem to a data flow network.

回复收藏 0 原文