在对象的构造函数中打开Boost Interprocess段
问题描述 投票：0回答：1
我在一个进程的 Boost Interprocess
map<int, vector<int>>managed_shared_memoryCommunicationaddData(int _data)示例：
// Typedefs for shared data structures
using boost::interprocess;
using std::pair;
using std::scoped_allocator_adaptor;
typedef managed_shared_memory::segment_manager man;
typedef allocator <int , man> Int_Allocator;
typedef vector <int, Int_Allocator> Int_Vector;
typedef pair <const int, Int_Vector> Int_Vector_Map_Type;
typedef scoped_allocator_adaptor <allocator<Int_Vector_Map_Type, man>> Int_Vector_Map_Type_Allocator;
typedef map <int, Int_Vector, std::less<int>, Int_Vector_Map_Type_Allocator> Int_Vector_Map;
// Let's call this process 'parent'
managed_shared_memory segment(create_only, "Shared");
Int_Vector_Map_Type_Allocator alloc = segment.get_segment_manager();
segment.construct<Int_Vector_Map>("Map")(std::less<int>(), alloc);
// 'child' process
class Communciation{
Int_Vector_Map* map;
public:
Communication{
managed_shared_memory segment(open_only, "Shared");
map = segment.find<Int_Vector_Map>("Map").first;
}
void addData(int _key, int _value){
if(map->size() == 0 || map->find(_key) == map->end(){
managed_shared_memory segment(open_only, "Shared");
Int_Allocator alloc = segment.get_segment_manager();
map->insert(Int_Vector_Map_Type(_key, Int_Vector(alloc)));
} // create the vector and its allocator, otherwise runtime error
map->at(_key).push_back(_value);
}
}
这是我正在查看的内容的分解示例，但我没有看到立即错误。 当尝试运行此代码时，我收到运行时错误“未处理的异常：EXCEPTION_ACCESS_VIOLATION读取地址（...）”。 将
addData(...)void addData(int _key, int _value){
managed_shared_memory segment(open_only, "Shared");
map = segment.find<Int_Vector_Map>("Map").first;
if(map->size() == 0 || map->find(_key) == map->end(){
Int_Allocator alloc = segment.get_segment_manager();
map->insert(Int_Vector_Map_Type(_key, Int_Vector(alloc)));
} // create the vector and its allocator, otherwise runtime error
map->at(_key).push_back(_value);
}
即每次调用打开地图都会修复此问题，但不适用于我的情况，因为我希望能够每帧多次调用此方法，而不会对 fps 产生太大影响。
这个问题的原因是什么？是否可以按照描述使用 boost 的进程间？
1个回答
0
投票
投票
答案有很多组成部分：
- 使用简化类型别名
- 该段必须保持映射，因此您必须将其作为类中的成员（或具有更长的生命周期）
- 分配器构造仅在一致使用作用域分配器并且插入使用分配器构造时才会发生（例如
方法）emplace
我在使用 Boost Container 的实现方面拥有良好的经验，所以让我们展示一下。
简化的类型别名
// Typedefs for shared data structures
namespace bip = boost::interprocess;
namespace Shared {
namespace bc = boost::container;
using Segment = bip::managed_shared_memory;
using Mgr = Segment::segment_manager;
template <typename T> using Alloc = bc::scoped_allocator_adaptor<bip::allocator<T, Mgr>>;
template <typename T> using Vector = bc::vector<T, Alloc<T>>;
template <typename K, typename V, typename Cmp = std::less<K>, typename P = std::pair<K const, V>>
using Map = bc::map<K, V, Cmp, Alloc<P>>;
} // namespace Shared
现在您可以简单地说：
using IVMap = Shared::Map<int, Shared::Vector<int>>; // Int_Vector_Map
它将扩展到正确的比较器、分配器等集合。
终生
要从构造函数构造段，您将需要使用初始值设定项列表。例如：
class Communication {
public:
Communication() //
: segment_{bip::open_only, "Shared"}
, map_(*segment_.find<IVMap>("Map").first) {}
void addData(int key, int value);
private:
Shared::Segment segment_;
IVMap& map_;
};
安放
要插入新元素，请实现
addDatavoid addData(int key, int value) {
auto it = map_.find(key);
if (it == map_.end())
it = map_.emplace(key).first;
it->second.push_back(value);
}
请注意，该段只是存在。请注意，由于作用域分配器适配器与
emplace编辑 遗憾的是我无法编译 emplace。我确信我错过了一些琐碎的事情，但我已经解决了这个问题，例如：
if (it == map_.end()) {
IVMap::mapped_type v(map_.get_allocator());
it = map_.emplace(key, std::move(v)).first;
}
现场演示
#include <boost/container/scoped_allocator.hpp>
#include <boost/interprocess/allocators/allocator.hpp>
#include <boost/interprocess/containers/map.hpp>
#include <boost/interprocess/containers/vector.hpp>
#include <boost/interprocess/managed_mapped_file.hpp>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <set>
// Typedefs for shared data structures
namespace bip = boost::interprocess;
namespace Shared {
namespace bc = boost::container;
#ifdef COLIRU // online compiler
using Segment = bip::managed_mapped_file;
#else
using Segment = bip::managed_shared_memory;
#endif
using Mgr = Segment::segment_manager;
template <typename T> using Alloc = bc::scoped_allocator_adaptor<bip::allocator<T, Mgr>>;
template <typename T> using Vector = bc::vector<T, Alloc<T>>;
template <typename K, typename V, typename Cmp = std::less<K>, typename P = std::pair<K const, V>>
using Map = bc::map<K, V, Cmp, Alloc<P>>;
} // namespace Shared
using IVMap = Shared::Map<int, Shared::Vector<int>>; // Int_Vector_Map
class Communication {
public:
Communication() //
: segment_{bip::open_only, "Shared"}
, map_(*segment_.find<IVMap>("Map").first) {}
void addData(int key, int value) {
auto it = map_.find(key);
if (it == map_.end()) {
IVMap::mapped_type v(map_.get_allocator());
it = map_.emplace(key, std::move(v)).first;
}
it->second.push_back(value);
}
auto const& get() const { return map_; }
private:
Shared::Segment segment_;
IVMap& map_;
};
#include <fmt/ranges.h>
#include <functional>
#include <random>
static auto vals = bind(std::uniform_int_distribution(100, 999), std::mt19937{std::random_device{}()});
int main(int argc, char** argv) {
auto const args = std::set<std::string_view>(argv + 1, argv + argc);
if (args.contains("parent")) {
Shared::Segment seg{bip::open_or_create, "Shared", 10 << 10};
seg.find_or_construct<IVMap>("Map")(seg.get_segment_manager());
}
if (args.contains("child")) {
Communication comm;
for (unsigned n = 10; n--;) {
auto v = vals();
comm.addData(v / 100, v);
}
fmt::print("After insertion:\n - {}\n", fmt::join(comm.get(), "\n - "));
}
}
印刷
+ ./a.out parent
+ ./a.out child
After insertion:
- (1, [155, 170])
- (2, [248])
- (4, [418])
- (5, [542, 562])
- (6, [642, 674, 659])
- (7, [783])
+ ./a.out child
After insertion:
- (1, [155, 170, 143, 130])
- (2, [248, 222])
- (3, [325])
- (4, [418, 428])
- (5, [542, 562, 556])
- (6, [642, 674, 659, 671])
- (7, [783, 793, 733, 745])
+ ./a.out child
After insertion:
- (1, [155, 170, 143, 130])
- (2, [248, 222])
- (3, [325, 320, 362])
- (4, [418, 428, 486, 437])
- (5, [542, 562, 556])
- (6, [642, 674, 659, 671, 695, 609])
- (7, [783, 793, 733, 745, 786, 777, 793])
- (9, [995])
本地现场演示：
最新问题
- @font-face 不适用于 Wordpress 中的子主题
- Bootstrap Toast 不显示
- Mongoose - 有条件地更新更新查询中的字段
- ASP Core 将 JSON 反序列化为派生类
- 从文件中读取嵌套的 xml 并使用类来存储信息
- npm 错误！可以在以下位置找到此运行的完整日志：目录
- 2 个相机姿势的相对球面角度
- Powershell 正则表达式仅替换并返回字符串中的值
- 在 Selenium 中初始化 Webdriver 时出错。试图找到最便宜的门票。怎么办？
- 在react.js中处理未定义的props的最佳方法是什么？
- 创建基于对象的状态导致 useEffect 在挂载时触发
- 带有格式化和日志旋转的日志设置
- 尝试使用 openpyxl 在合并单元格中换行文本
- 对数组 Vbscript 中的值求和
- 使用 Github Actions 进行文件参考
- 将 A 列中的每个唯一值与重复值合并到一个新工作表中
- 正则表达式不区分大小写的搜索，但输出与正则表达式中的大小写匹配
- 在python3中，如何显式访问块作用域外但不在外部函数作用域内的变量？
- Docker：将react应用程序的源代码从主机共享到容器内的项目目录给我一个错误sh：1：react-scripts：找不到
- 将数据从组件传递到对话框，但不进行 2 路模型绑定
© www.soinside.com 2019 - 2024. All rights reserved.