Общие объекты STL с использованием библиотеки Boost во время fork () - PullRequest
Новая
       81

Общие объекты STL с использованием библиотеки Boost во время fork ()

0 голосов
/ 20 января 2020

Я попытался поделиться объектами STL (например, неупорядоченной картой).

Я прочитал, что мы можем использовать Boost Library для этого процесса, легко используя общую память между процессами. Я использовал приведенные коды здесь .

Код писателя такой: 

#include <bits/stdc++.h>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

#include <boost/unordered_map.hpp>     //boost::unordered_map
#include <functional>                  //std::equal_to
#include <boost/functional/hash.hpp>   //boost::hash

int main ()
{
   using namespace boost::interprocess;
   //Remove shared memory on construction and destruction
   struct shm_remove
   {
      shm_remove() { shared_memory_object::remove("MySharedMemory"); }
      ~shm_remove(){ shared_memory_object::remove("MySharedMemory"); }
   } remover;

   //Create shared memory
   managed_shared_memory segment(create_only, "MySharedMemory", 65536);

   //Note that unordered_map<Key, MappedType>'s value_type is std::pair<const Key, MappedType>,
   //so the allocator must allocate that pair.
   typedef int    KeyType;
   typedef float  MappedType;
   typedef std::pair<const int, float> ValueType;

   //Typedef the allocator
   typedef allocator<ValueType, managed_shared_memory::segment_manager> ShmemAllocator;

   //Alias an unordered_map of ints that uses the previous STL-like allocator.
   typedef boost::unordered_map
      < KeyType               , MappedType
      , boost::hash<KeyType>  ,std::equal_to<KeyType>
      , ShmemAllocator>
   MyHashMap;

   //Construct a shared memory hash map.
   //Note that the first parameter is the initial bucket count and
   //after that, the hash function, the equality function and the allocator
   MyHashMap *myhashmap = segment.construct<MyHashMap>("MyHashMap")  //object name
      ( 3, boost::hash<int>(), std::equal_to<int>()                  //
      , segment.get_allocator<ValueType>());                         //allocator instance

   //Insert data in the hash map
   for(int i = 0; i < 100; ++i){
      myhashmap->insert(ValueType(i, (float)i*23.5));
   }

   MyHashMap :: iterator iter;
   iter = myhashmap->begin();

   std::cout << "Hoooo.... i am in the server!!\n";

   for (; iter != myhashmap->end(); iter++) {
      std::cout << iter->first << " " << iter->second << "\n";
   }


   return 0;
}

А код считывателя такой: 

#include <bits/stdc++.h>
#include <boost/interprocess/managed_shared_memory.hpp>
#include <boost/interprocess/allocators/allocator.hpp>

#include <boost/unordered_map.hpp>     //boost::unordered_map
#include <functional>                  //std::equal_to
#include <boost/functional/hash.hpp>   //boost::hash

int main ()
{
   using namespace boost::interprocess;
   //Remove shared memory on construction and destruction
   // struct shm_remove
   // {
   //    shm_remove() { shared_memory_object::remove("MySharedMemory"); }
   //    ~shm_remove(){ shared_memory_object::remove("MySharedMemory"); }
   // } remover;

   //Create shared memory
   managed_shared_memory segment(open_only, "MySharedMemory");

   //Note that unordered_map<Key, MappedType>'s value_type is std::pair<const Key, MappedType>,
   //so the allocator must allocate that pair.
   typedef int    KeyType;
   typedef float  MappedType;
   typedef std::pair<const int, float> ValueType;

   //Typedef the allocator
   typedef allocator<ValueType, managed_shared_memory::segment_manager> ShmemAllocator;

   //Alias an unordered_map of ints that uses the previous STL-like allocator.
   typedef boost::unordered_map
      < KeyType               , MappedType
      , boost::hash<KeyType>  ,std::equal_to<KeyType>
      , ShmemAllocator>
   MyHashMap;

   //Construct a shared memory hash map.
   //Note that the first parameter is the initial bucket count and
   //after that, the hash function, the equality function and the allocator
   MyHashMap *myhashmap = segment.find<MyHashMap>("MyHashMap").first;  //object name
      // ( 3, boost::hash<int>(), std::equal_to<int>()                  //
      // , segment.get_allocator<ValueType>());                         //allocator instance


   MyHashMap :: iterator iter;
   std::cout << "in client e\n";
   iter = myhashmap->begin();

   std::cout << "Hoooo.... i am in the client!!\n";

   for (; iter != myhashmap->end(); iter++) {
      std::cout << iter->first << " " << iter->second << "\n";
   }

   segment.destroy<MyHashMap>("MyHashMap");


   return 0;
}

Я проверил, что данные добавляются в общую карту, напечатав ее в части записи.

Но когда я запускаю код считывателя, я получаю следующую ошибку: 

terminate called after throwing an instance of 'boost::interprocess::interprocess_exception'
  what():  No such file or directory
Aborted (core dumped)

Я не понимаю ошибку, которую я делаю, потому что я совершенно новичок в библиотеке Boost и столкнулся с ней для одного из моих проектов.

Я также хотел знать, могу ли я включить часть считывателя в один из процессов, созданных с использованием fork() (как я пытался сделать то же самое ранее и получал ту же ошибку).

...