gpt4 book ai didi

c++ - 附加进程时 boost 删除 managed_shared_memory

转载 作者:太空宇宙 更新时间:2023-11-03 10:30:24 26 4
gpt4 key购买 nike

我有 2 个进程,进程 1 创建一个 boost managed_shared_memory 段,进程 2 打开这个段。然后重新启动进程 1,进程 1 的开始有以下内容,

struct vshm_remove
{
vshm_remove()
{
boost::interprocess::shared_memory_object::remove("VMySharedMemory");
}
~vshm_remove()
{
boost::interprocess::shared_memory_object::remove("VMySharedMemory");
}
} vremover;

我知道当进程 1 启动或结束时,将在我的共享内存上调用 remove 方法,但它不应该仅在进程 2 未附加到它时才将其删除吗?我使用以下方法附加到进程 2 中的共享内存,

boost::interprocess::managed_shared_memory *vfsegment;
vfsegment = new boost::interprocess::managed_shared_memory(boost::interprocess::open_only, "VMySharedMemory");

我注意到无论进程 2 是否连接,共享内存都会被删除。

最佳答案

我认为文档中没有提到 shared_memory_object::remove 如果附加进程会失败。

请参阅此部分以供引用:Removing shared memory .特别是:

This function can fail if the shared memory objects does not exist or it's opened by another process.

这意味着调用 shared_memory_object::remove("foo") 无论如何都会尝试删除名为“foo”的共享内存。

该函数的实现(source here)反射(reflect)了该行为:

inline bool shared_memory_object::remove(const char *filename)
{
try{
//Make sure a temporary path is created for shared memory
std::string shmfile;
ipcdetail::tmp_filename(filename, shmfile);
return ipcdetail::delete_file(shmfile.c_str());
}
catch(...){
return false;
}
}

根据我发布的生产代码的经验,我已经成功地调用shared_memory_object::remove,直到我不再需要访问共享内存。

我写了一个非常简单的示例主程序,您可能会觉得有用。它会根据您的运行方式附加、创建或删除共享内存。编译后,尝试以下步骤:

  1. 用c运行创建共享内存(默认1.0K)并插入虚拟数据
  2. 使用 o 运行以打开(“附加到”)共享内存并读取虚拟数据(默认情况下每 10 秒循环读取一次)
  3. 在单独的 session 中,使用 r 运行以删除共享内存
  4. 再次运行 o 以尝试打开。请注意,这将(几乎肯定)失败,因为共享内存在上一步中(再次,几乎肯定)被删除
  5. 随意终止第二步的进程

至于为什么在调用shared_memory_object::remove后上面的第2步继续能够访问数据,请参见Constructing Managed Shared Memory .具体来说:

When we open a managed shared memory

  • A shared memory object is opened.
  • The whole shared memory object is mapped in the process' address space.

最有可能的是,因为共享内存对象被映射到进程的地址空间,所以不再直接需要共享内存文件本身。

我意识到这是一个相当人为的例子,但我认为更具体的例子可能会有所帮助。

#include <cctype>   // tolower()
#include <iostream>
#include <string>
#include <unistd.h> // sleep()
#include <boost/interprocess/shared_memory_object.hpp>
#include <boost/interprocess/managed_shared_memory.hpp>

int main(int argc, char *argv[])
{
using std::cerr; using std::cout; using std::endl;
using namespace boost::interprocess;

if (argc == 1) {
cout << "usage: " << argv[0] << " <command>\n 'c' create\n 'r' remove\n 'a' attach" << endl;
return 0;
}

const char * shm_name = "shared_memory_segment";
const char * data_name = "the_answer_to_everything";

switch (tolower(argv[1][0])) {
case 'c':
if (shared_memory_object::remove(shm_name)) { cout << "removed: " << shm_name << endl; }
managed_shared_memory(create_only, shm_name, 1024).construct<int>(data_name)(42);
cout << "created: " << shm_name << "\nadded int \"" << data_name << "\": " << 42 << endl;
break;
case 'r':
cout << (shared_memory_object::remove(shm_name) ? "removed: " : "failed to remove: " ) << shm_name << endl;
break;
case 'a':
{
managed_shared_memory segment(open_only, shm_name);
while (true) {
std::pair<int *, std::size_t> data = segment.find<int>( data_name );
if (!data.first || data.second == 0) {
cerr << "Allocation " << data_name << " either not found or empty" << endl;
break;
}
cout << "opened: " << shm_name << " (" << segment.get_segment_manager()->get_size()
<< " bytes)\nretrieved int \"" << data_name << "\": " << *data.first << endl;
sleep(10);
}
}
break;
default:
cerr << "unknown command" << endl;
break;
}
return 0;
}

关于c++ - 附加进程时 boost 删除 managed_shared_memory,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18130781/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com