ConcurrentDictionaryのエントリとC＃の辞書自体の階層的なロック戦略

Question

私のコードでは、 'key'はオブジェクトで、 'value'は一意の第三者のライブラリによって提供される前記オブジェクトへの接続パラメータを含む。サードパーティのライブラリを介してイベントがスローされたときにユニークキーがイベント引数の1つとなるように、接続パラメータが格納されます。これにより、さらにコードを処理する正しいオブジェクトを見つけることができます。次のように私が持っている

問題がある：時々

• 、同時辞書には、処理を必要とするオブジェクトのリフレッシュリストを更新する必要があります。

• 個々のオブジェクトは、処理中にロックを必要とします。スローされたイベントは、並列ではなく順次に実行する必要があるためです。 （私たちは、タスクは、時には異なるスレッド上で並列に処理され、データベースに保存するときにOptimisticConcurrencyExceptionを取得していることを見ているように、これは最近の要件となっています。）

  内の個々のオブジェクトにロックをかける

辞書は問題ではありませんが、リストをリフレッシュしながら現在ロックされているオブジェクトを辞書から削除しようとすると、新しい問題が発生します。

問題のある手順を順番に実行する小さなコンソールアプリケーションを作成しようとしましたが、 'Monitor.Exit（key）;' 'オブジェクト同期メソッドが非同期コードブロックから呼び出されました。'という例外がスローされます。

class Program 
{ 
    static ConcurrentDictionary<object, int> _handles = new ConcurrentDictionary<object, int>(); 

    static void Main(string[] args) 
    { 
     object lockableKey = 'key'; 

     _handles.AddOrUpdate(lockableKey, 10, (oldkey, oldvalue) => 10); 
     var key = _handles.Keys.FirstOrDefault(h => h == lockableKey); 

     Console.WriteLine("key found, beginning to lock"); 
     Monitor.Enter(key); 
     Console.WriteLine("key locked"); 

     ////Console.WriteLine("applying outer lock, hoping for code to stop executing"); 
     ////Monitor.Enter(_handles); 

     Console.WriteLine("Removing key from dictionary"); 
     int dummy; 
     _handles.TryRemove(lockableKey, out dummy); 

     Console.WriteLine("Removing lock from object removed from dictionary"); 
     Monitor.Exit(key); 
    } 

そこで質問は、辞書を更新し、続行する前に実行を完了するために、辞書内のオブジェクト上のすべての子ロックのマスターロックと待機のような役割を果たし、外側辞書にロックを適用するが方法です着信イベントを処理するには？

Answer 1

皆さん、助けてくれてありがとうございました。以前のコメントが削除されて私が答えを見つけるのを助けてくれたようです。

私は'ReaderWriterLockSlim' classを実装しました。これにより、複数のリーダースレッドが同時に処理できますが、1つのライタースレッドのみが処理されます。したがって、すべての処理スレッドはリーダーロックを取りますが、ディクショナリを更新するスレッドはライターロックを取り出します。ライター・ロックは、すべてのリーダー・ロックが完了するのを待っていますが、すべてのリーダー・ロックよりも優先されます。だから、ライターロックが要求されると、リーダロックはクリティカルセクションに入る前にライターが完了するまで待たなければなりません。

これに加えて、リーダースレッド内では、同じアイテムを同時に処理する2つのスレッドを防ぐために、Monitor.TryLockを辞書の実際のオブジェクトにも適用します。