用boost :: interprocess在共享内存中分配用户定义的结构体

我试图使用boost::interprocess在共享内存中分配一个非常简单的数据结构,但我不能完全弄清楚如何使用boost进程间分配器在我分配的共享内存段中执行内存分配/释放,如下所示

using namespace boost::interprocess;
shared_memory_object::remove("MySharedMem");
mSharedMemory = std::make_unique<managed_shared_memory>(
    open_or_create, "MySharedMem", 65536);

我以前问过类似的问题,但不幸的是我从来没有得到任何答案。 下面的MyStruct实际上是一个数组,其长度字段指示数组的大小。 现在我有一个简单的长度字段,但稍后我会添加一些其他构造函数参数(布尔和其他简单类型)。

为了在共享内存段中分配它,我知道我必须对分配器做些什么,但是我找不到类似的例子,其中我有一个包含数组/指针字段的用户定义类型。

    using MyType = struct MyType {
        explicit MyType(const size_t aSize)
            : mSize(aSize)
            , mpData(new char[aSize])
        {}

        ~MyType() {
            delete[]mpData;
        }
        size_t mSize;
        char * mpData;
    };

    using MyTypeAllocator = boost::interprocess::allocator<MyType,
        boost::interprocess::managed_shared_memory::segment_manager>;

    // Initialize the shared memory STL-compatible allocator
    MyTypeAllocator alloc(mSharedMemory->get_segment_manager());

只是不要手动分配。 如果你想连续分配一个类型为charaSize元素,那就是C ++的std::vector for。

最重要的是, std::vector已经知道如何使用另一个分配器,所以没有理由不使用它:

template <typename Alloc>
struct MyType {
    explicit MyType(size_t aSize, Alloc alloc = {}) : mData(aSize, alloc) {}

  private:
    std::vector<char, Alloc> mData;
};

现在,要使用标准库结构/作用域分配器,您可能需要定义allocator_type嵌套类型:

    using allocator_type = Alloc; // typename Alloc::template rebind<char>::other;

就这样。 只要将它用作具有分配器的任何标准库类型即可:

int main() {
    using namespace Shared;

    Shared::remove("MySharedMem");
    auto memory = Segment(create_only, "MySharedMem", 65536);

    using A = Alloc<char>;
    A alloc(memory.get_segment_manager());

    auto* data = memory.find_or_construct<MyType<A>>("data")(1024, memory.get_segment_manager());

    return data? 0 : 255;
}

为了可维护性,我在Shared命名空间中创建了一些便利的typedef。 这是完整的示例

完整样本

住在Coliru¹

#include <boost/interprocess/managed_shared_memory.hpp>
#include <vector>

template <typename Alloc>
struct MyType {
    using allocator_type = typename Alloc::template rebind<char>::other;

    explicit MyType(size_t aSize, Alloc alloc = {}) : mData(aSize, alloc) {}

  private:
    std::vector<char, Alloc> mData;
};

namespace Shared {
    namespace bip = boost::interprocess;

    using Segment = bip::managed_shared_memory;
    using Manager = Segment::segment_manager;
    template <typename T> 
        using Alloc = bip::allocator<T, Manager>;

    void remove(char const* name) { bip::shared_memory_object::remove(name); }

    using bip::create_only;
}

int main() {
    using namespace Shared;

    Shared::remove("MySharedMem");
    auto memory = Segment(create_only, "MySharedMem", 65536);

    using A = Alloc<char>;
    A alloc(memory.get_segment_manager());

    auto* data = memory.find_or_construct<MyType<A>>("data")(1024, memory.get_segment_manager());

    return data? 0 : 255;
}

¹对于Coliru使用托管映射文件是因为共享内存不受支持

链接地址: http://www.djcxy.com/p/50977.html

上一篇: Allocating a user defined struct in shared memory with boost::interprocess

下一篇: Removing RTTI from Boost::Interprocess