用于免等待生产者和阻塞使用者的环形缓冲区

Ring buffer for a wait-free producer and a blocking consumer

本文关键字:使用者 缓冲区 等待 生产者 用于      更新时间:2023-10-16

我有一个生产者线程,它以可能(暂时(太快的速度生成对象,使用者线程无法使用。因此,我想要一个 FIFO 来缓冲剩余的工作。一旦FIFO已满,生产者应简单地停用或稍后重试。此外,我希望能够通知消费者不再需要做任何工作(无需将特殊对象排队进入 FIFO(。生产者不能放慢速度,消费者不能浪费CPU周期,所以我有以下要求:

  • 固定尺寸的圆形环形缓冲器。
  • 生产者永远不要等待:它需要能够尽快将元素排队。
  • 使用者应能够阻止:没有忙于等待可能缓慢的生产者。混合锁会很好。

我正在设想以下C++类:

template <typename T, std::size_t N>
class spsc_circular_half_blocking {
std::array<T, N> buffer;
// bookkeeping, atomics, mutexes etc. go here
public:
bool try_push(const T&); // returns whether object could be enqueued
void notify(); // notifies consumer
bool wait_pop(T&); // returns whether object was dequeued or notification was received
};

能够就地修改元素会很好。它还可以使用缓冲区的动态分配(例如,size 被传递给构造函数,缓冲区是一个unique_ptr(。

现在回答我的问题。这件事甚至可能吗(至少在 x86 上(?

  • 如果是,它将如何工作?我真的很想要一些实现,最好但不一定C++。
  • 如果没有,为什么不呢?

指向相关材料的指针,即使它不能完全满足我的需求,也将不胜感激。

一种解决方案是使用具有您自己的信令和阻塞的增强单生产者单消费者队列。

谷歌发现了这个,不知道它,但也许值得研究:

免等待多生产者多使用者环形缓冲区:

https://www.osti.gov/servlets/purl/1531271