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) 
    } 
} 

显然这种方法，如果你知道你可以事先有多少阅读程序在同一时间仅运行工作。无可否认，他们太多会使这个代码很丑陋。