[Src]ActionQueue

[I don't have a username]

A really simple multithread wrapper with a queue of objects to execute.

Features:

-Multithreading
-Execute a queue of objects
-Never a duplicate execution
-Simple and fast

Download:


Example use: (Also included in the download.)

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();
        }
    }
}

Good luck.

Note:
FinishQueueState(); has to be called in the end of the execution no matter what. It will reset the queuestate, so it will be executed by the thread next time.

[blaсkNull]

I think you stole this from Fang.

[Korvacs]

Why not just use Tasks?

[I don't have a username]

Originally Posted by Korvacs

Why not just use Tasks?

Tasks? Could you be more specific?

[nTL3fTy]

Originally Posted by I don't have a username

Tasks? Could you be more specific?

[I don't have a username]

Originally Posted by nTL3fTy

Didn't know about that ;o Will look up on it. Thanks.

[Korvacs]

Why does no one know about modern programming methods o.O

[I don't have a username]

Originally Posted by Korvacs

Why does no one know about modern programming methods o.O

I never really look up much on things, unless is something I really need or want to learn about.

[Korvacs]

Originally Posted by I don't have a username

I never really look up much on things, unless is something I really need or want to learn about.

^

The problem with this generation of developers.

[I don't have a username]

Originally Posted by Korvacs

^

The problem with this generation of developers.

I don't have a lot free time on my hands, so can't use my time researching every single way to do things best :P

[Korvacs]

Originally Posted by I don't have a username

I don't have a lot free time on my hands, so can't use my time researching every single way to do things best :P

Thats fine, but you could spend 5 minutes reading the release notes for the .net framework updates so that you know that this **** exists and then save yourself the time of trying to find something, or writing something that already exists.

[12k]

Originally Posted by Korvacs

Thats fine, but you could spend 5 minutes reading the release notes for the .net framework updates so that you know that this **** exists and then save yourself the time of trying to find something, or writing something that already exists.

Some people do it as a hobby, not as a living. Might be part of the reason they don't keep up with every little thing with it.

[Korvacs]

Originally Posted by 12k

Some people do it as a hobby, not as a living. Might be part of the reason they don't keep up with every little thing with it.

I do it as a hobby

[12k]

Originally Posted by Korvacs

I do it as a hobby

a very obsessive hobby

[Spirited]

Originally Posted by blaсkNull

I think you stole this from Fang.

Nah. This is mine:

    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;
        }
    }