ReaderWriterLockSlim 및 async \ await

Question

ReaderWriterLockSlim에 몇 가지 문제가 있습니다. 나는 그것이 어떻게 작동 하는지를 이해할 수 없다.

내 코드 : 나는 < 1>에 쓰기 잠금을 입력하면

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

는, 디버거에서 나는 _indexLock.IsWriteLockHeld이 true 것을 볼 수 있지만, 실행 단계에 < 2> 내가 _indexLock.IsWriteLockHeld이 false 및 _indexLock.ExitWriteLock입니다 참조 SynchronizationLockException에 "쓰기 잠금이 해제되지 않고 해제 중입니다."라는 메시지와 함께 예외가 발생합니다. 내가 뭘 잘못 했니?

Answer 1

ReaderWriterLockSlim은 thread-affine 잠금 유형이므로 일반적으로 async 및 await과 함께 사용할 수 없습니다.

당신은 WaitAsync와 SemaphoreSlim를 사용하거나 (당신이 정말는 리더/라이터 잠금을 필요로하는 경우)를 사용한다 중 내 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) 
    } 
} 

분명히이 방법은 동시에 실행할 수있는 읽기 루틴을 미리 알고있는 경우에만 작동합니다. 틀림없이이 코드를 너무 많이 작성하면 은 매우 ugly입니다.