2

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 が接続されているにもかかわらず、共有メモリが削除されていることに気付きました。

4

2 に答える 2

9

shared_memory_object::removeプロセスがアタッチされている場合に失敗するドキュメントに言及があるとは思いません。

このセクションを参照してください:共有メモリの削除. 特に:

共有メモリ オブジェクトが存在しない場合、または別のプロセスによって開かれている場合、この関数は失敗する可能性があります。

これは、 への呼び出しがshared_memory_object::remove("foo")「foo」という名前の共有メモリを削除しようとすることを意味します。

その関数の実装 ( source here ) は、その動作を反映しています。

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. 別のセッションで r を使用して実行し、共有メモリを削除します
  4. o を付けて再度実行し、開こうとします。前の手順で共有メモリが (再び、ほぼ確実に) 削除されたため、これは (ほぼ確実に) 失敗することに注意してください。
  5. 2番目のステップからプロセスを自由に強制終了してください

上記の手順 2 で への呼び出し後も引き続きデータにアクセスできる理由については、「管理共有メモリの構築shared_memory_object::remove」を参照してください。具体的には:

管理された共有メモリを開くと

  • 共有メモリ オブジェクトが開かれます。
  • 共有メモリ オブジェクト全体がプロセスのアドレス空間にマップされます。

ほとんどの場合、共有メモリ オブジェクトはプロセスのアドレス空間にマップされるため、共有メモリ ファイル自体は直接必要ではなくなります。

これはかなり不自然な例だと思いますが、もっと具体的なものが役立つかもしれないと思いました.

#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;
}
于 2013-08-12T17:48:08.967 に答える
0

もう 1 つの興味深い点 - もう 1 つのケースを追加します。

case 'w':
  {
    managed_shared_memory segment(open_only, shm_name);
      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;
      }
      *data.first = 17;
      cout << "opened: " << shm_name << " (" << segment.get_segment_manager()->get_size()
           << " bytes)\nretrieved int \"" << data_name << "\": " << *data.first << endl;
  }
  break;

追加のオプション 'w' を指定すると、メモリが接続され、代わりに '17' (「最もランダムな乱数」) が書き込まれます。これにより、次のことができます。

コンソール 1: 'c' を実行してから 'a' を実行します。値 42 で作成されたメモリを報告します。

コンソール 2: 'w' を実行します。Console1 では、番号が変更されていることがわかります。

コンソール 2: 'r' を実行します。メモリは正常に取り外され、コンソール 1 にはまだ 17 が出力されます。

コンソール 2: Do 'c'. 値 42 で作成されたメモリが報告されます。

コンソール 2: 'a' を実行します。42 が表示されますが、コンソール 1 はまだ 17 を出力します。

これにより、すべてのプラットフォームで同じように動作するが、boost が動作すると宣言している限り、この方法を使用してあるプロセスから別のプロセスにメモリ ブロックを送信できることが確認されます。 「プロデューサー」がブロックを削除できるように、ブロックを取り付けました。コンシューマーは、次のブロックをアタッチする前に前のブロックをデタッチする必要もありません。

于 2013-12-16T11:55:01.810 に答える