1

我试图了解 boost 进程间库是如何工作的。我有一个设备类，它在向量容器中保存整数值。

在父父进程中；我在MySegmentObject段中构造了 Equipment 对象，并在该对象的构造函数中在MySegmentVector段中创建了向量。

使用子进程；我想访问创建的对象并获取向量的大小。我可以使用segment->find方法访问该对象，但是当我getSize()从访问的对象调用该方法时，它崩溃了！

我做错了什么，可能我错过了关于共享内存概念的东西。

我在 Visual Studio 2010 & boost 1.43.0 lib 上测试了代码

设备.h

#pragma once
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/containers/vector.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

using namespace boost::interprocess;

typedef boost::interprocess::allocator<int, managed_shared_memory::segment_manager>     ShmemAllocator; 
typedef boost::container::vector<int, ShmemAllocator> EqVector;

class Equipments { 
public:     
    Equipments(void);   
    ~Equipments(void);  
    void addEquipment(int n);   
    int getSize();  
    int getElement(int n);

private:
    const ShmemAllocator *alloc_inst;
    <offset_ptr>EqVector eqVector;
    managed_shared_memory *segment;
};

设备.cpp

#include "StdAfx.h"
#include "Equipments.h"
#include <iostream>

Equipments::Equipments(void)
{   
    shared_memory_object::remove("mySegmentVector"); 
    segment = new managed_shared_memory(create_only, "mySegmentObjectVector", 65536);
    alloc_inst = new ShmemAllocator(segment->get_segment_manager());
    eqVector = segment->construct<EqVector>("myVector")(*alloc_inst);
}


Equipments::~Equipments(void)
{
}

void Equipments::addEquipment(int n)
{
    eqVector->push_back(n);
}

int Equipments::getSize()
{
    return eqVector->size();
}

int Equipments::getElement(int n)
{
    return eqVector->at(n);
}

主文件

#include "stdafx.h"
#include "Equipments.h"
#include <iostream>
#include <string>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/containers/vector.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

using namespace boost::interprocess;

int main(int argc, char *argv[]) 
{
    if (argc == 1) 
    {
        std::cout << "parent process" << std::endl;
        shared_memory_object::remove("mySegmentObject"); 
        managed_shared_memory segment(create_only, "mySegmentObject", 65536);
        Equipments *eqPtr = segment.construct<Equipments>("EQ")();

        eqPtr->addEquipment(19);
        eqPtr->addEquipment(12);

        //Launch child process
        std::string s(argv[0]); s += " child ";
        if(0 != std::system(s.c_str()))
            return 1;        //Launch child process
    }
    else 
    {
        std::cout << "child process" << std::endl;
        managed_shared_memory *segment = new managed_shared_memory(open_only, "mySegmentObject");
        std::pair<Equipments*, std::size_t> p = segment->find<Equipments>("EQ");

        if (p.first) 
        {
            std::cout << "EQ found" << std::endl;       
       std::cout << p.first->getSize() << std::endl;       
        }
        else 
        {
            std::cout << "EQ not found" << std::endl;
        }
    }
}
4

1 回答 1

6

问题是您使用普通指针来存储您的 EqVector。当您映射共享内存段时，它可能会映射到进程地址空间中的任何位置。这意味着 eqVector 在内存中的存储位置在第一个进程的“内存空间”中与在第二个进程中的不同。您需要使用 boost::offset_ptr，它将地址存储为从共享内存段开始的偏移量，请参见此处： http: //www.boost.org/doc/libs/1_35_0/doc/html/interprocess/offset_ptr。 html

于 2010-10-27T17:14:53.777 回答