2

常规std::vector具有emplace_back避免不必要的副本。有理由spsc_queue不支持吗？emplace由于某种原因，是否不可能使用无锁队列？

4

1 回答 1

5

我不是 boost 库的实现者也不是维护者，所以为什么不包含emplace成员函数的理由超出了我的知识范围，但是如果你真的需要它自己实现它并不太难。

有spsc_queue一个基类，compile_time_sized_ringbuffer或者runtime_sized_ringbuffer取决于在编译时队列的大小是否已知。这两个类维护使​​用的实际缓冲区，动态缓冲区和编译时缓冲区之间存在明显差异，但在这种情况下，它们的push成员函数委托给一个公共基类 - ringbuffer_base。

该ringbuffer_base::push功能比较容易掌握：

bool push(T const & t, T * buffer, size_t max_size)
{
    const size_t write_index = write_index_.load(memory_order_relaxed);  // only written from push thread
    const size_t next = next_index(write_index, max_size);

    if (next == read_index_.load(memory_order_acquire))
        return false; /* ringbuffer is full */

    new (buffer + write_index) T(t); // copy-construct

    write_index_.store(next, memory_order_release);

    return true;
}

relaxed通过加载（这是安全的，因为此类的预期用途是调用的单个生产者）到应该存储下一项的位置的push索引，并获取适当的下一个索引，检查以确保一切都在- bounds （通过 load-acquire 与调用的线程进行适当的同步pop），但我们感兴趣的主要语句是：

new (buffer + write_index) T(t); // copy-construct

它执行将新副本构造放置到缓冲区中。传递一些参数以T直接从可行的构造函数参数构造 a 本身并没有什么线程不安全的。我编写了以下代码片段，并在派生类中进行了必要的更改，以适当地将工作委托给基类：

template<typename ... Args>
std::enable_if_t<std::is_constructible<T,Args...>::value,bool>
emplace( T * buffer, size_t max_size,Args&&... args)
{
    const size_t write_index = write_index_.load(memory_order_relaxed);  // only written from push thread
    const size_t next = next_index(write_index, max_size);

    if (next == read_index_.load(memory_order_acquire))
        return false; /* ringbuffer is full */

    new (buffer + write_index) T(std::forward<Args>(args)...); // emplace

    write_index_.store(next, memory_order_release);

    return true;
}

也许唯一的区别是确保传入的参数Args...实际上可以用于构造 a T，并且当然可以通过std::forward而不是复制构造来进行放置。

于 2015-07-15T01:06:59.210 回答