- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
常规 std::vector
有 emplace_back
避免不必要的复制。 spsc_queue
不支持这个有什么原因吗?是否由于某种原因无法使用无锁队列emplace
?
最佳答案
我既不是 boost 库的实现者也不是维护者,所以为什么不包含 emplace
背后的基本原理成员函数超出了我的知识范围,但如果您确实需要它,自己实现它并不太难。
spsc_queue
有一个基类 compile_time_sized_ringbuffer
或 runtime_sized_ringbuffer
取决于队列的大小在编译时是否已知。这两个类维护实际使用的缓冲区,动态缓冲区和编译时缓冲区之间存在明显差异,但在本例中委托(delegate)了它们的 push
。公共(public)基类的成员函数 - 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
调用的单一生产者)并获取适当的下一个索引,检查以确保一切都在边界内(使用加载获取以与线程适当同步调用 pop
) ,但我们感兴趣的主要语句是:
new (buffer + write_index) T(t); // copy-construct
在缓冲区中执行放置新副本构造。传递一些用于构造 T
的参数本身并没有什么线程不安全的。直接来自可行的构造函数参数。我编写了以下代码片段并在整个派生类中进行了必要的更改,以适本地将工作委托(delegate)给基类:
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...
中传递的参数实际上可以用来构造一个 T
,当然还有通过 std::forward
进行安置而不是复制构造。
关于boost - 为什么 boost::lockfree::spsc_queue 没有位置?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31418490/
我试了几个小时,这个问题几乎让我发疯。 我想创建一个 spsc_queue在共享内存上,队列中的每个元素都是一个 mq_item_t下面的结构。 typedef struct _mq_item_t{
我正在包装 boost::lockfree::spsc_queue queue进入一个 RingBuffer 类,并希望能够在我的项目中使用这个 RingBuffer。但是我很难通过类构造函数将容量大
我正在尝试实现单个生产者(主线程)和单个消费者(从主线程生成的子线程)问题,因此根据我的搜索,我得到了 spsc_queue 作为最好的无锁数据结构由 boost 库提供。现在从他们的示例代码中获取,
我想使用运行时指定的最大条目数在共享内存中创建一个无锁环形缓冲区。我的代码基于我在 GitHub 中找到的示例.我使用这段代码在共享内存中成功创建了一个无锁环形缓冲区。 在我的例子中,我需要指定环形缓
我正在尝试 spsc_queue.pop() 这个结构 enum action_type { SUBSCRIBE, UNSUBSCRIBE, MESSAGE }; struct
我需要缓冲一堆传入的 10GigE 数据,以便稍后将其写入磁盘。按顺序执行此操作是一个问题,因为如果我不能足够快地维护它,我正在读取的设备将会溢出。 在寻找解决方案时,我偶然发现了 boost::lo
我这样声明 spsc_queue: boost::lockfree::spsc_queue> futInfoUpdates; 我是这样处理的: fut_sess_contents entry_fsc;
常规 std::vector 有 emplace_back 避免不必要的复制。 spsc_queue 不支持这个有什么原因吗?是否由于某种原因无法使用无锁队列emplace? 最佳答案 我既不是 bo
我在看 Boost's lockfree queue . 当生产者线程将数据结构 T 插入缓冲区时,它会(通过复制构造函数)将数据复制到缓冲区中。 当消费者线程尝试调用consume_one() 来读
我有一个线程在 boost::lockfree::spsc_queue 上生成数据,以及一个线程消耗数据。我可以让第三个线程使用 read_available 监视队列吗?或 write_availa
我有这样的队列: boost::lockfree::spsc_queue> futOrdersUpdates; 我的问题是有时我会多次使用同一个项目。我添加了一些故障排除代码: while (
以下是我的问题的表述。 #include class test { struct complicated { int x; int y; }; std::alloca
所以我正在使用 boost::lockfree::spec_queue 通过两个运行我应用程序中两个对象的仿函数的 boost_threads 进行通信。 除了 spec_queue::pop() 方
我正在尝试在 CUDA 中编写一个程序,该程序将在主机端使用 Boost 的单一生产者/单一消费者队列,但我一包含 就遇到了编译器错误。 . 此时,我没有在设备上执行任何操作,也没有创建 spsc_
如果我正在运行一个带有线程池的 boost::asio::io_service 并使用 boost::asio::strand 包装一个特定的套接字接收模拟单线程操作,有谁知道 strand 是否满足
我想直接从 boost 接收到 boost::lockfree:spsc_queue(或者,boost::circular_buffer)::asio::async_read 调用。看起来我需要编写一
我比较了这三种情况使用的运行时间,它们是boost::lockfree::queue, boost::lockfree::spsc_queue 以及使用std::queue的生产者/消费者队列的串行代
我定义了一个变量如下: boost::lockfree::spsc_queue, boost::lockfree::capacity > myVariable; 在我的代码中,我试图休息它: myVa
我是一名优秀的程序员,十分优秀!