1つのスレッドだけがリソースから読み取ることを許可するロックを作成するにはどうすればよいですか？

Question

私は、整数のID値を保持するファイルを持っています。問題がGetId()後に後続のアクションが失敗するかもしれないということです

public int GetId() 
    { 
     _fileLock.EnterUpgradeableReadLock(); 
     int id = 0; 
     try { 
      if(!File.Exists(_filePath)) 
       CreateIdentityFile(); 

      FileStream readStream = new FileStream(_filePath, FileMode.Open, FileAccess.Read); 
      StreamReader sr = new StreamReader(readStream); 
      string line = sr.ReadLine(); 
      sr.Close(); 
      readStream.Close(); 
      id = int.Parse(line); 
      return int.Parse(line); 
     } 
     finally { 
      SaveNextId(id);  // increment the id 
      _fileLock.ExitUpgradeableReadLock(); 
     } 
    } 

：現在のファイルを読むことなどReaderWriterLockSlimで保護されています。あなたが見ることができるように、GetId()メソッドは毎回IDをインクリメントし、IDを発行した後に何が起こるかは無視します。発行されたIDはハングアップする可能性があります（例外が発生する可能性があります）。 IDがインクリメントされると、一部のIDは未使用のままになることがあります。

私はSaveNextId(id)を取り除くことを考えていましたが、それを削除してください（SaveNextId()は実際にはロックを使用しますが、それ以外はEnterWriteLockです）。そして、必要なすべてのメソッドが実行されたら、外部から手動で呼び出します。これにより、SaveNextId()が実行される前に複数のスレッドがGetId()メソッドに入り、すべて同じIDを受け取る可能性があるという別の問題が発生します。

私は操作後にIDを変更する必要はありません。何らかの方法でIDを変更する必要はありません。なぜなら、それはうまくいかず、より多くの問題につながる可能性があるからです。

私は何とかFileIdentityManager（これらのIDを処理するクラス）にコールバックでき、次のIDの保存を実行できることをマネージャに知らせるソリューションが必要です。 ID。

要点リレーショナルデータベースの自動インクリメントの動作を複製したい - 行挿入中に何か問題が生じた場合、そのIDは使用されず、引き続き使用できますが、同じIDが発行されることはありません。うまくいけば、問題は

UPDATE ..あなたは、いくつかのソリューションを提供するための十分な理解：私は私がしたい

Answer 1

Essentialyをしたい動作の詳細については答えにコメントを参照してください リレーショナルデータベースの自動インクリメント 行動を複製 - を何行挿入時に うまくいかない場合は、IDは、それはまだAVで、使用されていない です使用できません 同じIDが発行されることもありません。 うまくいけば、 質問が十分に理解できます。 あなたはいくつかの解決策を提供します。

一般的に言えば、私が観察した動作ではありません。トランザクション内にオートインクリメントを含むテーブルに行を挿入し、ロールバックするとIDが失われます。

私の意見では、これを実装した方法は正しい動作です。

アップデートは、あなたがいることを確実にすることができる唯一の方法「unsuccesfulファイルが保存されますでそれらを無駄にしたくないが、unsuccesfulタイプ等、キャスト」 新しいIDを要求してから保存が完了し、増分をIDにロールバックできなくなるまで、ブロッキングコードの範囲をブロックすることです。

これにより、達成できる並列処理のレベルが大幅に低下します。

並列性の可能性を高めたい場合は、IDをリクエストする前にできることをすべて確認する必要があります。タイプをチェックし、エラーをフォーマットします。

外部エラー（IO例外）のようなものは、明らかに何もできません。

Answer 2

private static readonly object _lock = new object(); 

    public int GetId() 
    { 
     lock(_lock) 
     { 
     //You code to get ID here 
     } 
    } 

Answer 3

ID生成と行挿入がアトミックなため、データベースに表示される動作は可能です。アプリケーションでこの動作をしたい場合は、データを格納する直前にIDを取得することをお勧めします。これにより、「トランザクションスコープ」が最小限のウィンドウに縮小され、例外からの干渉を防ぐことができます。

何か悪い理由でこれができない場合は、IDカウンターをキャッシュする「IDブローカー」を使用することもできます。ファイルから現在のカウンタを読み込み、何らかの数値（たとえば100）をインクリメントした後、連続したIDをシングルスレッド方式ですべての呼び出し元に渡します。 100をすべて渡したら、ファイルを再度更新します。シャットダウン時には、最後に渡された値を使用してファイルを最後に書き出します。唯一の問題は、システムがクラッシュしてIDの隙間を埋める場合ですが、それを補う方法があります。