c＃inter process取得/解放リソース数

Question

潜在的に多くのプロセスで共有されるリソースがあり、使用しなくなったときにクリーンアップする必要があります。

プロセス間の使用回数を維持して、リソースが使用されなくなったときにクリーンアップできるようにする最も簡単な方法は何ですか？

（リソースを使用する最後のプロセスが終了した場合、使用する次のリソースが有効な使用回数を持つ限り、リソースは未処理のままにしておくことができます）。

Answer 1

私が使用したコード：

internal sealed class InterProcessResource { 
    private static readonly string MutexNameThisProcess = "IPR-" + Guid.NewGuid().ToString(); 
    private static readonly Mutex MutexThisProcess = new Mutex(true, MutexNameThisProcess); 

    private readonly MemoryMappedFile mmf; 
    private readonly string mutexName; 

    public InterProcessResource(string resourceName) { 
     this.mutexName = resourceName + "-mtx"; 
     this.mmf = MemoryMappedFile.CreateOrOpen(resourceName + "-mmf", 16 * 1024, MemoryMappedFileAccess.ReadWrite); 
    } 


    public void Acquire(Action initAction) { 
     using (new Mutex(true, this.mutexName)) { 
      var currentList = ReadStringList(mmf); 
      if (currentList.Count == 0) { 
       initAction(); 
      } 
      var newList = PruneMutexList(currentList); 
      newList.Add(MutexNameThisProcess); 
      WriteStringList(this.mmf, newList); 
     } 
    } 

    public void Release(Action freeAction) { 
     using (new Mutex(true, this.mutexName)) { 
      var currentList = ReadStringList(this.mmf); 
      var newList = PruneMutexList(currentList); 
      WriteStringList(this.mmf, newList); 
      if (newList.Count == 0) { 
       freeAction(); 
      } 
     } 
    } 

    private static List<string> ReadStringList(MemoryMappedFile mmf) { 
     var list = new List<string>(); 
     using (var stream = mmf.CreateViewStream()) { 
      var reader = new BinaryReader(stream); 
      int count = reader.ReadInt32(); 
      for (int i = 0; i < count; i++) { 
       list.Add(reader.ReadString()); 
      } 
     } 
     return list; 
    } 

    private static void WriteStringList(MemoryMappedFile mmf, List<string> newList) { 
     using (var stream = mmf.CreateViewStream()) { 
      var writer = new BinaryWriter(stream); 
      int count = newList.Count; 
      writer.Write(count); 
      for (int i = 0; i < count; i++) { 
       writer.Write(newList[i]); 
      } 
     } 
    } 

    // removes our mutex name AND any dead processes mutex names 
    private static List<string> PruneMutexList(List<string> list) { 
     var newList = new List<string>(); 
     foreach (var s in list) { 
      if (s != MutexNameThisProcess) { 
       Mutex m; 
       if (Mutex.TryOpenExisting(s, out m)) { 
        newList.Add(s); 
        m.Dispose(); 
       } 
      } 
     } 
     return newList; 
    } 
} 

Answer 2

すべてのプロセスが同じマシン上にある場合は、インスタンスカウントを含むファイルを作成します。リソースがプロセスによってプロビジョニングされると、ファイルは書き込み用に開かれ、ファイルを効果的にロックする必要があります。インスタンスカウントを読み込み、インクリメントしてから、ファイルに対して書き込みロックを解放する必要があります。

プロセスが終了する（またはリソースで完了した）場合、ファイルへの書き込みロックを取得し、リソース数を減らします。リソースカウントが減少後にゼロである場合は、クリーンアップ手順を開始します。

ファイルが既に別のプロセスによって書き込まれている間に、2番目のプロセスが共有ファイルの書き込みロックを取得しようとすると、再試行ロジックが必要になります。

重要な点は、OSが排他的な書き込みロックを提供できることです。これは事実上クリティカルセクションです。

Answer 3

リソースのコンシューマが異なるマシン上にある可能性がある.net remotingで実装されたパターンについて説明しています。これは、リースをリフレッシュしていない場合に消費者を自動的にタイムアウトするライフタイムリースでバックアップされた、オブジェクトを明示的にリリースするように強制します。

これがすべて.netフレームワークに既にあることを考えれば、私はあなたのフレームワークを生成するためにリモーティングを使うことをお勧めします。