带有“阻塞”弹出的单生产者单消费者队列

Question

我正在寻找具有“阻塞”弹出的单生产者单消费者队列。 Boost spsc_queue 几乎没问题，除了一种方法：

bool pop(T & ret);
Pops one object from ringbuffer.

此方法是“非阻塞”的，如果没有数据则立即返回。 我希望这种方法“阻塞”并等到一些数据到达。

我应该使用哪些集合？

upd 至少有人可以建议任何具有阻塞弹出的 c++ 队列吗？

Answer 1

并发队列很少提供弹出阻塞接口：在许多情况下，用户需要执行阻塞逻辑，避免队列实现的不必要开销。

也就是说，您可以在 queue::pop 周围添加一个包装器来执行以下操作：

bool blocking_pop(T & t) {
  while(!queue.empty())
    wait();
  return queue.pop(t);
}

英特尔 TBB 具有 tbb::concurrent_bounded_queue，它可能也适合您的需求。