using System;
using System.Collections;
using System.Threading;

namespace Decimation
{
	/// <summary>
	/// Creates a multithreaded queue to run asynchronous operations on.
	/// </summary>
	public class MultithreadedQueue
	{
		private class NotificationQueue : Queue 
		{
			public event MultithreadedQueue.QueueFunctionHandler Queued;
			public override void Enqueue(object obj)
			{
				base.Enqueue (obj);
				Queued();
			}
		}

		private Thread _TheThread;
		private Queue _Handlers;
		public delegate void QueueFunctionHandler();
		private event QueueFunctionHandler _HandlerBinder;
		private bool _Enabled = false;
		private bool _Asleep = false;

		public MultithreadedQueue() 
		{
			NotificationQueue nQueue = new NotificationQueue();
			_TheThread = new Thread(new ThreadStart(ProcessQueue));
			nQueue.Queued += new QueueFunctionHandler(Handlers_Queued);
			_Handlers = Queue.Synchronized(nQueue);
		}

		public MultithreadedQueue(ThreadPriority priority) 
		{
			NotificationQueue nQueue = new NotificationQueue();
			_TheThread = new Thread(new ThreadStart(ProcessQueue));
			_TheThread.Priority = priority;
			nQueue.Queued += new QueueFunctionHandler(Handlers_Queued);
			_Handlers = Queue.Synchronized(nQueue);
		}

		~MultithreadedQueue() 
		{
			Stop();
		}

		// Begins execution
		public void Start() 
		{
			_Enabled = true;
			_TheThread.Start();
		}

		// Puts the thread to sleep and sets the asleep member
		private void Suspend() 
		{
			_TheThread.Suspend();
		}

		// Wakes the thread
		private void Resume() 
		{
			_TheThread.Resume();
		}

		// Stops the execution until start is called.
		public void Stop() 
		{
			_Enabled = false;
			if (IsSleeping)
				Resume();
		}

		// The queue's thread does runs through this loop
		private void ProcessQueue()
		{
			while (_Enabled) 
			{
				while (_Handlers.Count > 0) 
				{
					QueueFunctionHandler dh = _Handlers.Dequeue() as QueueFunctionHandler;
					_HandlerBinder += dh;
					_HandlerBinder();
					_HandlerBinder -= dh;
				}
				if (_Enabled)
					Suspend();
			}
		}

		// Returns the queue for addition or removal of functions
		public Queue Queue 
		{
			get 
			{
				return _Handlers;
			}
		}

		// Allows outside code to see if the execution thread is sleeping
		public bool IsSleeping 
		{
			get 
			{
				return _TheThread.ThreadState == ThreadState.Suspended;
			}
		}

		// This awakes the execution thread whenever the queue is no longer empty
		private void Handlers_Queued() 
		{
			if (_Asleep)
				Resume();
		}

		// This function will not return until the queue is cleared.
		public void Finish() 
		{
			if (IsSleeping) 
			{
				Queue.Enqueue(new QueueFunctionHandler(Thread.CurrentThread.Resume));
				Thread.CurrentThread.Suspend();
			}
		}
	}
}

using System;using System.Collections;using System.Threading;namespace Decimation{	/// <summary>	/// Creates a multithreaded queue to run asynchronous operations on.	/// </summary>	public sealed class MultithreadedQueue	{		private class NotificationQueue : Queue 		{			public event MultithreadedQueue.QueueFunctionHandler Queued;			public override void Enqueue(object obj)			{				base.Enqueue (obj);				Queued();			}		}		private Thread _TheThread;		private Queue _Handlers;		public delegate void QueueFunctionHandler();		private event QueueFunctionHandler _HandlerBinder;		private bool _Enabled = false;		private Queue _WaitThreads = new Queue();		public MultithreadedQueue() 		{			NotificationQueue nQueue = new NotificationQueue();			_TheThread = new Thread(new ThreadStart(ProcessQueue));			nQueue.Queued += new QueueFunctionHandler(Handlers_Queued);			_Handlers = Queue.Synchronized(nQueue);		}		public MultithreadedQueue(ThreadPriority priority) 		{			NotificationQueue nQueue = new NotificationQueue();			_TheThread = new Thread(new ThreadStart(ProcessQueue));			_TheThread.Priority = priority;			nQueue.Queued += new QueueFunctionHandler(Handlers_Queued);			_Handlers = Queue.Synchronized(nQueue);		}		~MultithreadedQueue() 		{			Stop();		}		// Begins execution		public void Start() 		{			_Enabled = true;			_TheThread.Start();		}		// Puts the thread to sleep and sets the asleep member		private void Suspend() 		{			_TheThread.Suspend();		}		// Wakes the thread		private void Resume() 		{			_TheThread.Resume();		}		// Stops the execution until start is called.		public void Stop() 		{			_Enabled = false;			if (IsSleeping)				Resume();		}		// The queue's thread does runs through this loop		private void ProcessQueue()		{			while (_Enabled) 			{				while (_Handlers.Count > 0) 				{					QueueFunctionHandler dh = _Handlers.Dequeue() as QueueFunctionHandler;					_HandlerBinder += dh;					_HandlerBinder();					_HandlerBinder -= dh;				}				if (_Enabled)					Suspend();			}		}		// Returns the queue for addition or removal of functions		public Queue Queue 		{			get 			{				return _Handlers;			}		}		// Allows outside code to see if the execution thread is sleeping		public bool IsSleeping 		{			get 			{				return _TheThread.ThreadState == ThreadState.Suspended || _TheThread.ThreadState == ThreadState.SuspendRequested;			}		}		// This awakes the execution thread whenever the queue is no longer empty		private void Handlers_Queued() 		{			if (IsSleeping)				Resume();		}		// This function will not return until the queue is cleared.		public void Finish() 		{			while (!IsSleeping)				Thread.SpinWait(1);		}	}}