view Implab/Parallels/Signal.cs @ 205:8200ab154c8a v2

Added ResetState to RunnableComponent to reset in case of failure Added StateChanged event to IRunnable Renamed Promise.SUCCESS -> Promise.Success Added Promise.FromException Renamed Bundle -> PromiseAll in PromiseExtensions
author cin
date Tue, 25 Oct 2016 17:40:33 +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);
        }
    }
}