[Src]ActionQueue

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using QueLib.QueueThreading;

namespace ConsoleApplication1
{
    public sealed class Player : ActionQueueObject
    {
        public Player(string Name)
            : base()
        {
            this.Name = Name;
            this._Event = new ActionQueueEvent(ActionQueueExecute);
        }

        public string Name;
        private ActionQueueEvent _Event;
        public override ActionQueueEvent Event
        {
            get
            {
                return _Event;
            }
        }
        public void ActionQueueExecute()
        {
            Console.WriteLine("Something to execute {0}", Name);
            FinishQueueState();
        }
    }
    public sealed class PlayerThread : ActionQueue
    {
        public PlayerThread(int Interval)
            : base(Interval)
        {
        }
        public Dictionary<uint, Player> Players = new Dictionary<uint, Player>();

        public override ActionQueueObject[] queueObjects
        {
            get
            {
                return Players.Values.ToArray();
            }
        }
    }
    
    class Program
    {
        static PlayerThread PlayerThread;

        static void Main(string[] args)
        {
            PlayerThread = new PlayerThread(5000);
            PlayerThread.Players.Add(0, new Player("LOL"));
            PlayerThread.Prepare();
            PlayerThread.Start();

            while (true)
                Console.Read();
        }
    }
}

    public sealed class ThreadedQueue
    {
        // Configuration:
        private readonly object _locker;
        private Thread[] _workers;
        private Queue<Action> _queue;

        public ThreadedQueue(int workerCount)
        {
            _locker = new object();
            _queue = new Queue<Action>();
            _workers = new Thread[workerCount];
            for (int i = 0; i < workerCount; i++)
                (_workers[i] = new Thread(Dequeue)).Start();
        }
        private void Dequeue()
        {
            while (true)
            {
                Action obj;
                lock (_locker)
                {
                    while (_queue.Count == 0) 
                        Monitor.Wait(_locker);
                    obj = _queue.Dequeue();
                }
                if (obj == null)
                    return;
                obj();
            }
        }
        public void Enqueue(Action method)
        {
            lock (_locker)
            {
                _queue.Enqueue(method);
                Monitor.Pulse(_locker);
            }
        }
        public void Shutdown(bool waitForWorkers)
        {
            foreach (Thread worker in _workers)
                Enqueue(null);
            if (waitForWorkers)
                foreach (Thread worker in _workers)
                    worker.Join();
            _workers = null;
            _queue = null;
        }
    }