Mercurial > pub > ImplabNet
view Implab/Parallels/Signal.cs @ 262:f1696cdc3d7a v3 v3.0.8
Added IInitializable.Initialize() overload
Added IRunnable.Start(), IRunnable.Start() overloads
Fixed cancellation of the current operation when Stop() is called
More tests
author | cin |
---|---|
date | Mon, 16 Apr 2018 02:12:39 +0300 |
parents | 471f596b2603 |
children |
line wrap: on
line source
using System; using System.Threading; namespace Implab.Parallels { /// <summary> /// Implements a simple signalling logic using <see cref="Monitor.PulseAll(object)"/>. /// </summary> public class Signal { readonly object m_lock = new object(); bool m_state; public void Set() { lock(m_lock) { m_state = true; Monitor.PulseAll(m_lock); } } public void Wait() { lock (m_lock) if (!m_state) Monitor.Wait(m_lock); } public bool Wait(int timeout) { lock (m_lock) return m_state || Monitor.Wait(m_lock, timeout); } } }