Mercurial > pub > ImplabNet
view Implab/Parallels/Signal.cs @ 207:558f34b2fb50 v2
added Safe.DispatchEvent() a legacy equivalent for '?.Invoke()'
added Safe.Dispose(IEnumerable)
added PromiseExtensions.CancellationPoint to add a cancellation point to the chain of promises
added IPromise<T> PromiseExtensions.Then<T>(this IPromise<T> that, Action<T> success) overloads
added PromiseExtensions.Error() overloads to handle a error or(and) a cancellation
author | cin |
---|---|
date | Wed, 09 Nov 2016 12:03:22 +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); } } }