Как сделать слегка измененный класс AutoResetEvent?

Question

мне нужен класс синхронизации, который ведет себя так же, как класса AutoResetEvent, но с одним небольшим исключением:

Вызов метода Set() должен освободить все ожидания темы, а не только один.

Как я могу построить такой класс? Я просто из идей?

• Martin.

Answer 1

Огромное спасибо всем вашим тысячам и входам, которые я прочитал с большим интересом. Я сделал еще несколько поисков здесь, на Stackoverflow, и неожиданно обнаружил this, который оказался именно тем, что я искал. Разрезав его вниз только двумя способами, мне нужно, я закончил с этой небольшой класс:

public sealed class Signaller 
{ 
    public void PulseAll() 
    { 
     lock (_lock) 
     { 
      Monitor.PulseAll(_lock); 
     } 
    } 

    public bool Wait(TimeSpan maxWaitTime) 
    { 
     lock (_lock) 
     { 
      return Monitor.Wait(_lock, maxWaitTime); 
     } 
    } 

    private readonly object _lock = new object(); 
} 

и это делает excactly то, что надо! Я поражен тем, что решение может быть таким простым, и я люблю такую ​​простоту. Оно прекрасно. Спасибо, Мэтью Уотсон!

• Martin.

Answer 2

Итак, у вас есть несколько потоков, выполняющих .WaitOne(), и вы хотите их освободить?

Используйте класс ManualResetEvent и все ожидающие потоки должны освободить ...

Answer 3

Две вещи, которые вы могли бы попробовать.

Использование объекта «Барьер» добавляет условное добавление потоков тоже и сигнализирует об этом.

Другой может быть использование настройки подписчика издателя, как в RX. Каждый поток ожидает объект, который он передает в коллекцию. Когда вы хотите вызвать цикл «set» над моментальным снимком его вызова, установленного для каждого члена.

Или вы можете попробовать медведи.

Answer 4

Если событие ссылается на все потоки в общем поле или свойстве, вы можете заменить общее поле или свойство новым несигнальным событием, а затем передать старый. У него есть некоторые затраты на него, поскольку вы будете регулярно создавать новые объекты синхронизации, но это сработает. Вот пример того, как я хотел бы сделать это:

public static class Example 
{ 
    private static volatile bool stopRunning; 
    private static ReleasingAutoResetEvent myEvent; 

    public static void RunExample() 
    { 
     using (Example.myEvent = new ReleasingAutoResetEvent()) 
     { 
      WaitCallback work = new WaitCallback(WaitThread); 

      for (int i = 0; i < 5; ++i) 
      { 
       ThreadPool.QueueUserWorkItem(work, i.ToString()); 
      } 

      Thread.Sleep(500); 

      for (int i = 0; i < 3; ++i) 
      { 
       Example.myEvent.Set(); 
       Thread.Sleep(5000); 
      } 

      Example.stopRunning = true; 
      Example.myEvent.Set(); 
     } 
    } 

    private static void WaitThread(object state) 
    { 
     while (!Example.stopRunning) 
     { 
      Example.myEvent.WaitOne(); 
      Console.WriteLine("Thread {0} is released!", state); 
     } 
    } 
} 

public sealed class ReleasingAutoResetEvent : IDisposable 
{ 
    private volatile ManualResetEvent manualResetEvent = new ManualResetEvent(false); 

    public void Set() 
    { 
     ManualResetEvent eventToSet = this.manualResetEvent; 
     this.manualResetEvent = new ManualResetEvent(false); 
     eventToSet.Set(); 
     eventToSet.Dispose(); 
    } 

    public bool WaitOne() 
    { 
     return this.manualResetEvent.WaitOne(); 
    } 

    public bool WaitOne(int millisecondsTimeout) 
    { 
     return this.manualResetEvent.WaitOne(millisecondsTimeout); 
    } 

    public bool WaitOne(TimeSpan timeout) 
    { 
     return this.manualResetEvent.WaitOne(timeout); 
    } 

    public void Dispose() 
    { 
     this.manualResetEvent.Dispose(); 
    } 
} 

Answer 5

Еще более легкое решение, вы можете попробовать, который использует класс Monitor для блокировки и разблокировки объектов ниже. Тем не менее, я не так доволен рассказом об очистке этой версии ReleaseasingAutoResetEvent, так как на мониторе может содержаться ссылка на нее и поддерживать ее на неопределенное время, если она не настроена должным образом.

Есть несколько ограничений/gotchas с этой реализацией. Во-первых, поток, который создает этот объект, будет единственным, который сможет сигнализировать об этом вызовом Set; другие потоки, которые пытаются сделать то же самое, получат исключение SynchronizationLockException. Во-вторых, поток, создавший его, никогда не сможет ждать его успешно, так как он уже владеет блокировкой. Это будет эффективным решением, если у вас есть только один управляющий поток и несколько других ожидающих потоков.

public static class Example 
{ 
    private static volatile bool stopRunning; 
    private static ReleasingAutoResetEvent myEvent; 

    public static void RunExample() 
    { 
     using (Example.myEvent = new ReleasingAutoResetEvent()) 
     { 
      WaitCallback work = new WaitCallback(WaitThread); 

      for (int i = 0; i < 5; ++i) 
      { 
       ThreadPool.QueueUserWorkItem(work, i.ToString()); 
      } 

      Thread.Sleep(500); 

      for (int i = 0; i < 3; ++i) 
      { 
       Example.myEvent.Set(); 
       Thread.Sleep(5000); 
      } 

      Example.stopRunning = true; 
      Example.myEvent.Set(); 
     } 
    } 

    private static void WaitThread(object state) 
    { 
     while (!Example.stopRunning) 
     { 
      Example.myEvent.WaitOne(); 
      Console.WriteLine("Thread {0} is released!", state); 
     } 
    } 
} 

public sealed class ReleasingAutoResetEvent : IDisposable 
{ 
    private volatile object lockObject = new object(); 

    public ReleasingAutoResetEvent() 
    { 
     Monitor.Enter(this.lockObject); 
    } 

    public void Set() 
    { 
     object objectToSignal = this.lockObject; 
     object objectToLock = new object(); 

     Monitor.Enter(objectToLock); 
     this.lockObject = objectToLock; 
     Monitor.Exit(objectToSignal); 
    } 

    public void WaitOne() 
    { 
     object objectToMonitor = this.lockObject; 
     Monitor.Enter(objectToMonitor); 
     Monitor.Exit(objectToMonitor); 
    } 

    public bool WaitOne(int millisecondsTimeout) 
    { 
     object objectToMonitor = this.lockObject; 
     bool succeeded = Monitor.TryEnter(objectToMonitor, millisecondsTimeout); 

     if (succeeded) 
     { 
      Monitor.Exit(objectToMonitor); 
     } 

     return succeeded; 
    } 

    public bool WaitOne(TimeSpan timeout) 
    { 
     object objectToMonitor = this.lockObject; 
     bool succeeded = Monitor.TryEnter(objectToMonitor, timeout); 

     if (succeeded) 
     { 
      Monitor.Exit(objectToMonitor); 
     } 

     return succeeded; 
    } 

    public void Dispose() 
    { 
     Monitor.Exit(this.lockObject); 
    } 
}