using System;

using System.Threading;

using System.Collections.Generic;

public class Program

{

    class ProducerConsumerQueue : IDisposable

    {

        private AutoResetEvent _queueEvent;

        private Thread _worker; 

        private object _queueSyncObject; 

        Queue<string> _taskQueue;

        public ProducerConsumerQueue ()

        {

            _worker = new Thread(DoWork);

            _taskQueue = new Queue<string>();

            _queueEvent = new AutoResetEvent(false);

            _queueSyncObject = new object();

            _worker.Start();

        }

        public void DoWork() 

        {

            while (true)

            {

                string task = null;

                lock (_queueSyncObject)

                    if (_taskQueue.Count > 0)

                {

                    task = _taskQueue.Dequeue();

                    if (task == null) return;

                }

                if (task != null)

                {

                    Console.WriteLine ("Performing task: " + task);

                    Thread.Sleep (10);  // simulate work...

                }

                else

                    _queueEvent.WaitOne();         // No more tasks - wait for a signal

            }

        }

        public void EnqueueTask(string work)

        {

            lock(_queueSyncObject)

            {

                _taskQueue.Enqueue(work);

            }

            _queueEvent.Set();

        }

        public void Dispose()

        {

            EnqueueTask("stop");

            _worker.Join();

            _queueEvent.Close();

        }

​

    }

    public static void Main()

    {

        using (ProducerConsumerQueue q = new ProducerConsumerQueue())

        {

            q.EnqueueTask ("Hello");

            for (int i = 0; i < 10; i++) q.EnqueueTask ("Say " + i);

            q.EnqueueTask ("Goodbye!");

        }   

    }

}