Boost.interprocess Vector 作为类成员



我想使用 Boost.Interprocess 将一个结构放在共享内存中。此结构将在两个进程之间共享,作为序列化数据的主要交换区域。我目前正在寻找简单性方面的最佳解决方案。

namespace bi = boost::interprocess;
typedef bi::allocator<SimpleData, bi::managed_shared_memory::segment_manager>   ShmemSimpleDataAllocator;
typedef bi::vector<SimpleData, ShmemSimpleDataAllocator>                        SimpleDataVector;
struct SimpleData
{
SimpleData() {}
SimpleData(char* ptr)
:data(ptr)
{}
/** Offset pointer to the data */
bi::offset_ptr<char> data;
};
// Main shared structure
struct SharedMainStruct // EDITED, thanks Sehe
{
SharedMainStruct(ShmemSimpleDataAllocator simple_allocator)
:m_inputs(simple_allocator),
m_outputs(simple_allocator)
{}
// Inputs, outputs and properties
SimpleDataVector    m_inputs;
SimpleDataVector    m_outputs;
bi::interprocess_mutex     m_mutex;
bi::interprocess_condition m_cond;
};
// Main code here
// Create managed shared memory
my_sho= new bi::managed_shared_memory (bi::create_only, "test_SO", 1000000);
// Build main structure in shared memory
ShmemSimpleDataAllocator data_allocator(my_sho->get_segment_manager());
m_main_struct = my_sho->construct<SharedMainStruct>("main")(data_allocator); // (1)

这个想法是将此SharedMainStruct放在共享内存中,以便两个进程都可以访问它。此代码行 (1( 是否正确?我猜我想我想念一些运行时代码,就像文档中一样吗?喜欢:

//Initialize shared memory STL-compatible allocator
const ShmemSimpleDataAllocatoralloc_inst (segment.get_segment_manager());
//Construct a vector named "MyVector" in shared memory with argument alloc_inst
SimpleDataVector* myvector = segment.construct<SimpleDataVector>("SimpleDataVector")(alloc_inst);

--更新--

是的,向量可以存储为成员变量。我们应该提供分配器作为构造函数的参数...

本质:

类在内存中连续布局,因此您不能选择地将类的某些部分存储在共享内存中。

出于同样的原因,将offset_ptr存储在共享内存之外是没有用的,您可以简单地用原始指针替换它。

进一步的头脑风暴

前两句话应该足以消除任何混淆。

当然,您/可以/将MainStruct存储在共享内存中。这可能有助于MainStruct中的所有数据都可以共享。

如果你需要这样分享MainStruct的那部分,那么明确这一点似乎很明显:

// Inputs, outputs and properties
struct SharedBuffers {
template <typename Alloc> 
SharedBuffers(Alloc alloc = {}) : m_inputs(alloc), m_outputs(alloc) {}
Shared::Vector<SimpleData> m_inputs;
Shared::Vector<SimpleData> m_outputs;
};
SharedBuffers* m_buffers; // bip::offset_ptr<> is overkill outside shared memory

温和的建议是用共享的字符向量替换"原始"offset_ptr"。

最新更新