/
etc/
lib/
src/Abilities/
src/Abilities/Skills/
src/Abilities/Spells/
src/Abilities/Spells/Enums/
src/Affects/
src/ArtheaConsole/
src/ArtheaConsole/Properties/
src/ArtheaGUI/Properties/
src/Clans/Enums/
src/Commands/Communication/
src/Commands/ItemCommands/
src/Connections/
src/Connections/Colors/
src/Connections/Enums/
src/Connections/Players/
src/Connections/Players/Enums/
src/Continents/
src/Continents/Areas/
src/Continents/Areas/Characters/
src/Continents/Areas/Characters/Enums/
src/Continents/Areas/Items/
src/Continents/Areas/Items/Enums/
src/Continents/Areas/Rooms/
src/Continents/Areas/Rooms/Enums/
src/Continents/Areas/Rooms/Exits/
src/Creation/
src/Creation/Attributes/
src/Creation/Interfaces/
src/Database/
src/Database/Interfaces/
src/Environment/
src/Properties/
src/Scripts/Enums/
src/Scripts/Interfaces/
#region Arthea License

/***********************************************************************
*  Arthea MUD by R. Jennings (2007)      http://arthea.googlecode.com/ *
*  By using this code you comply with the Artistic and GPLv2 Licenses. *
***********************************************************************/

#endregion

// Taken from Suroden (http://sourceforge.net/projects/suroden)
// - RJ, Aug'07

using System;

namespace Arthea.Updates
{
    /// <summary>
    /// Summary description for TimerRegister.
    /// </summary>
    public class TimerRegistry
    {
        #region [rgn] Fields (1)

        private readonly BinaryPriorityQueue<TimerAction> queue = new BinaryPriorityQueue<TimerAction>();

        #endregion [rgn]

        #region [rgn] Methods (2)

        // [rgn] Public Methods (2)

        /// <summary>
        /// Adds the timer action.
        /// </summary>
        /// <param name="a">A.</param>
        public void AddTimerAction(TimerAction a)
        {
            queue.Push(a);
        }

        /// <summary>
        /// Runs this instance.
        /// </summary>
        public void Run()
        {
            double now = DateTime.Now.TimeOfDay.TotalMilliseconds;

            while (queue.Count > 0 && queue.Peek().time <= now)
            {
                TimerAction a = queue.Pop();

                a.Execute();

                if (a.interval > 0)
                {
                    a.time = now + a.interval;
                    queue.Push(a);
                }
            }
        }

        #endregion [rgn]
    }
}