Переменные условий в C#

Question

Являются ли переменные состояния & мониторами, используемыми в C#?

Может ли кто-нибудь дать мне пример?

Answer 1

Эквивалент условной переменной, которая используется только для передачи сигналов в .NET является абстрактным классом WaitHandle. Практическими реализациями являются классы ManualResetEvent и AutoResetEvent.

Для переменной условия, которую вы используете в качестве монитора, требуется System.Threading.Monitor. Оператор C# lock делает его очень простым в использовании, он гарантирует, что монитор всегда выходит без явного программирования вызова Exit().

Answer 2

Вы можете использовать объект Lock, который действует как синтаксический сахар для класса Monitor.

lock(someObject) 
{ 
    // Thread safe code here. 
} 

http://msdn.microsoft.com/en-us/library/c5kehkcz%28VS.80%29.aspx

Answer 3

System.Threading.Monitor является одним из способов (например, в)

Answer 4

В качестве альтернативы ManualResetEvent и друзьям Windows теперь предоставляет native support для переменных условия. Я не тестировал его сам, но есть хорошие шансы, что ваша производительность улучшится при использовании собственного API.

Вот статья код проекта, который объясняет, как получить доступ к этому (относительно новый) строится из C#:

A .NET Wrapper for the Vista/Server 2008 Condition Variable

Answer 5

Эта версия атомарно разблокирует мьютекс или ReaderWriterLockSlim во время ожидания для сигнализации, и повторно устанавливается защита его перед возвращением - это путь posix.

using System.Collections.Concurrent; 

namespace System.Threading.More { 
    public class ConditionVariable { 
     private readonly ConcurrentQueue<ManualResetEventSlim> _waitingThreads = new ConcurrentQueue<ManualResetEventSlim>(); 

     /// <summary> 
     ///  Atomically unlocks and waits for a signal. 
     ///  Then relocks the mutex before returning 
     /// </summary> 
     /// <param name="mutex"></param> 
     public void Wait(Mutex mutex) { 
      if (mutex == null) { 
       throw new ArgumentNullException("mutex"); 
      } 
      var waitHandle = new ManualResetEventSlim(); 
      try { 
       _waitingThreads.Enqueue(waitHandle); 
       mutex.ReleaseMutex(); 
       waitHandle.Wait(); 
      } finally { 
       waitHandle.Dispose(); 
      } 
      mutex.WaitOne(); 
     } 

     public void WaitRead(ReaderWriterLockSlim readerWriterLock) { 
      if (readerWriterLock == null) { 
       throw new ArgumentNullException("readerWriterLock"); 
      } 
      var waitHandle = new ManualResetEventSlim(); 
      try { 
       _waitingThreads.Enqueue(waitHandle); 
       readerWriterLock.ExitReadLock(); 
       waitHandle.Wait(); 
      } finally { 
       waitHandle.Dispose(); 
      } 
      readerWriterLock.EnterReadLock(); 
     } 

     public void Signal() { 
      ManualResetEventSlim waitHandle; 
      if (_waitingThreads.TryDequeue(out waitHandle)) { 
       waitHandle.Set(); 
      } 
     } 

     public void Broadcast() { 
      ManualResetEventSlim waitHandle; 
      while (_waitingThreads.TryDequeue(out waitHandle)) { 
       waitHandle.Set(); 
      } 
     } 
    } 
}