1

我有一个使用 fork() 的 C++ 程序,但我需要能够在父进程及其子进程之间共享一个可以读写的对象。从我的在线阅读来看,似乎 mmap 是这样做的方法。这是我所拥有的:

enum messageType {New = 0, Old = 1, No_Message = 2};

typedef struct {
    enum messageType type;
    unsigned int senderID;
    char message[100];
} StoredMessageData;

struct StoredMessage {
    unsigned int recipientID;
    vector<StoredMessageData> messages;

    StoredMessage(const unsigned int& intRecipient = 0, const vector<StoredMessageData>& data = vector<StoredMessageData>())
    : recipientID(intRecipient), messages(data)
    {
        messages.reserve(10);
    }

    bool operator<(const StoredMessage& compareTo) const
    {
        return recipientID < compareTo.recipientID;
    }

    bool operator==(const StoredMessage& compareTo) const
    {
        return recipientID == compareTo.recipientID;
    }
};

然后主要:

set<StoredMessage> * msgs;
msgs  = mmap(NULL, sizeof(set<StoredMessage>), PROT_READ | PROT_WRITE, MAP_SHARED | MAP_ANON, -1, 0);

后来我主要使用fork()。

我的问题有两部分:

1) 一个集合的大小是可变的,我已经知道在每个分叉的进程中,我希望能够添加一个 StoredMessage 并将一个 StoredMessageData 添加到 StoredMessage 中的向量。但是,我不确定 mmap 可以处理这个......它不只是为基础对象分配足够的空间吗?我可以让它分配足够的空间让我进行这些添加吗?

2)来自 main 的上述代码当前正在引发错误:

错误:从 âvoid*â 到 âstd::set、std::allocator >*â 的无效转换

有谁知道这意味着什么/如何解决它?

先感谢您!

4

1 回答 1

0

STL 类 std::vector<> 和 std::set<> 使用 operator new() 分配内存。运算符 new() 从进程堆中分配内存。堆不在共享内存中,因此一个进程分配的任何内容都不能被另一个进程访问。

你有几个选择。首先是创建一个从共享内存分配的 std::allocator<> 。

其次(也是我的偏好)是不要在共享内存中使用任何使用指针的对象。这几乎消除了 STL 中的任何内容。

您还需要一个互斥锁来控制对共享数据的访问,这样两个进程就不会破坏您的共享数据。

于 2012-12-01T05:31:02.253 回答