namespace ProduceConsume
{
   class Program
   {
       static void Main(string[] args)
       {
           int result = 0;
           Product product = new Product();
 
           Producer producer = new Producer { Product = product, Looper = 10 };
           Consumer consumer = new Consumer { Product = product, Looper = 10 };
 
           Thread threadP = new Thread(new ThreadStart(producer.Process));
           Thread.Sleep(500);
           Thread threadC1 = new Thread(new ThreadStart(consumer.Process));
           Thread.Sleep(500);
           Thread threadC2 = new Thread(new ThreadStart(consumer.Process));
 
           try
           {
               threadP.Start();
               threadC1.Start();
               threadC2.Start();
 
               threadP.Join();
               threadC1.Join();
               threadC2.Join();
 
               Console.ReadLine();
           }
           catch (ThreadStateException ex)
           {
               Console.WriteLine("ThreadStateException: " + ex.Message);
               result = 1;
           }
           catch (ThreadInterruptedException ex)
           {
               Console.WriteLine("ThreadInterruptedException: " + ex.Message);
               result = 1;
           }
 
           Environment.ExitCode = result;
       }
   }
 
   class Product
   {
       bool consumeFlag = false;
       Queue<int> queue = new Queue<int>();
 
       public void Consume()
       {
           Monitor.Enter(this);
           if (!consumeFlag)
           {
               try
               {
                   Monitor.Wait(this);
               }
               catch (Exception ex)
               {
                   Console.WriteLine("Exception: " + ex.Message);
               }
           }
 
           if (queue.Count > 0)
           {
               Console.WriteLine("Consume --> Thread ID: {0}, Product Index: {1}, Product Left: {2}", Thread.CurrentThread.ManagedThreadId, queue.Dequeue(), queue.Count);
               consumeFlag = queue.Count > 0;
           }
 
           Monitor.Pulse(this);
           Monitor.Exit(this);
       }
 
       public void Produce()
       {
           Monitor.Enter(this);
           if (consumeFlag)
           {
               try
               {
                   Monitor.Wait(this);
               }
               catch (Exception ex)
               {
                   Console.WriteLine("Exception: " + ex.Message);
               }
           }
           if (queue.Count == 0)
           {
               Random random = new Random();
               int count = random.Next(10);
               for (int i = 1; i <= count; i++)
               {
                   queue.Enqueue(i);
               }
               Console.Write("Produce --> ");
               Console.WriteLine(count == 1 ? "{0} product is enqueued." : "{0} products are enqueued.", count);
           }
           consumeFlag = true;
           Monitor.Pulse(this);
           Monitor.Exit(this);
       }
   }
 
   class Producer
   {
       public Product Product { get; set; }
 
       public int Looper { get; set; }
 
       public void Process()
       {
           for (int i = 0; i < Looper; i++)
           {
               Product.Produce();
           }
       }
   }
 
   class Consumer
   {
       public Product Product { get; set; }
 
       public int Looper { get; set; }
 
       public void Process()
       {
           for (int i = 0; i < Looper; i++)
           {
               Product.Consume();
           }
       }
   }
}