ReaderWriterLockSlim和異步\ await

Question

我有一些問題ReaderWriterLockSlim。我無法理解它是如何運作的。

我的代碼：

private async Task LoadIndex() 
    { 
     if (!File.Exists(FileName + ".index.txt")) 
     { 
      return; 
     } 
     _indexLock.EnterWriteLock();// <1> 
     _index.Clear(); 
     using (TextReader index = File.OpenText(FileName + ".index.txt")) 
     { 
      string s; 
      while (null != (s = await index.ReadLineAsync())) 
      { 
       var ss = s.Split(':'); 
       _index.Add(ss[0], Convert.ToInt64(ss[1])); 
      } 
     } 
     _indexLock.ExitWriteLock();<2> 
    } 

當我在< 1>進入寫鎖定，在調試器我可以看到_indexLock.IsWriteLockHeld是true，但是當執行步驟< 2>我看到_indexLock.IsWriteLockHeld是false 和_indexLock.ExitWriteLock拋出一個異常SynchronizationLockException帶有消息「寫入鎖正在釋放而未被佔用」。我做錯了什麼？

Answer 1

ReaderWriterLockSlim是一個線程仿射鎖定類型，所以它通常不能與async和await一起使用。

您應該使用SemaphoreSlim與WaitAsync，或者（如果你真的需要讀取/寫入器鎖），用我的AsyncReaderWriterLock from AsyncEx或Stephen Toub's AsyncReaderWriterLock。

Answer 2

您可以安全地使用可靠和輕量級的SemaphoreSlim模擬讀寫器鎖定機制，並保持async/await的優勢。創建SemaphoreSlim，給它可用的鎖的數量等於將鎖定資源以供同時讀取的例程數。每個人都會照常請求一個鎖。對於你的寫作例程，確保它在做它的事情之前請求所有可用的鎖。

這樣，您的寫作例程將始終獨立運行，而您的閱讀例程可能僅在他們自己之間共享資源。

例如，假設您有2個閱讀程序和1個寫程序。

SemaphoreSlim semaphore = new SemaphoreSlim(2); 

async void Reader1() 
{ 
    await semaphore.WaitAsync(); 
    try 
    { 
     // ... reading stuff ... 
    } 
    finally 
    { 
     semaphore.Release(); 
    } 
} 

async void Reader2() 
{ 
    await semaphore.WaitAsync(); 
    try 
    { 
     // ... reading other stuff ... 
    } 
    finally 
    { 
     semaphore.Release(); 
    } 
} 

async void ExclusiveWriter() 
{ 
    // the exclusive writer must request all locks 
    // to make sure the readers don't have any of them 
    // (I wish we could specify the number of locks 
    // instead of spamming multiple calls!) 
    await semaphore.WaitAsync(); 
    await semaphore.WaitAsync(); 
    try 
    { 
     // ... writing stuff ... 
    } 
    finally 
    { 
     // release all locks here 
     semaphore.Release(2); 
     // (oh here we don't need multiple calls, how about that) 
    } 
} 

顯然這種方法，如果你知道你可以事先有多少閱讀程序在同一時間僅運行工作。無可否認，他們太多會使這個代碼很醜陋。