在Boost托管共享内存中创建运行时指定大小的boost::spsc队列

错误原因分析 #

编译报错的核心是spsc_queue构造函数的参数顺序错误，同时需要确保分配器类型正确适配lockfree队列的要求。Boost.Lockfree的spsc_queue使用自定义分配器时，构造函数签名为：

spsc_queue(size_type capacity, const allocator_type& alloc = allocator_type());

你当前传递的参数顺序是(allocator, size)，与预期的(size, allocator)完全相反，导致编译器找不到匹配的构造函数。

修正后的代码实现 #

#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/allocators/allocator.hpp>
#include <boost/lockfree/spsc_queue.hpp>
#include <boost/interprocess/containers/string.hpp>

void create_shared_spsc_queue(size_t sz)
{
    namespace bip = boost::interprocess;

    // 定义共享内存兼容的字符分配器与字符串类型
    using char_alloc = bip::allocator<char, bip::managed_shared_memory::segment_manager>;
    using shared_string = bip::basic_string<char, std::char_traits<char>, char_alloc>;
    
    // 定义队列元素的分配器，适配lockfree队列的allocator包装器
    using string_alloc = bip::allocator<shared_string, bip::managed_shared_memory::segment_manager>;
    using ring_buffer_dynamic = boost::lockfree::spsc_queue<
        shared_string,
        boost::lockfree::allocator<string_alloc>
    >;

    const char* rbuff_name = "MySpscQueue";
    bip::managed_shared_memory segment(bip::open_only, "MySharedMemory");
    string_alloc alloc(segment.get_segment_manager());

    // 修正构造参数顺序：先队列容量，再分配器
    ring_buffer_dynamic* queue_dynamic = segment.construct<ring_buffer_dynamic>(rbuff_name)(sz, alloc);
}

额外注意事项 #

• 共享内存预初始化：必须确保MySharedMemory已通过create_only模式创建了足够大小的共享内存段，否则open_only会抛出异常。
• 元素类型兼容性：shared_string使用了interprocess分配器，天生兼容共享内存环境，可安全作为lockfree队列的元素类型。
• 命名一致性：rbuff_name的命名需在所有进程间保持一致，避免出现找不到队列对象的情况。

内容的提问来源于stack exchange，提问作者Akash