c# wait과 pulse를 활용한 스레드간 신호전달

=== 코드 ===

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
 
namespace ConsoleApp5
{
    class Program
    {
        static void Main(string[] args)
        {
            var monitorTest = new MonitorTest();
            Console.WriteLine("종료되었습니다.");
            return;
        }
 
    }
    class MonitorTest
    {
        private Queue<object> Q = new Queue<object>();
        private object lockObj = new object();
        private bool running = true;
 
        public MonitorTest()
        {
            Thread reader = new Thread(ReadQueue);
            reader.Start();
 
            List<Thread> thrds = new List<Thread>();
            for (int i = 0; i < 1000; i++)
            {
                var t = new Thread(new ParameterizedThreadStart(WriteQueue));
                t.Start(i);
                thrds.Add(t);
            }
            thrds.ForEach(p => p.Join());
            
            running = false;
            Console.WriteLine("모든 스레드 종료..");
 
        }
 
        private void WriteQueue(object val)
        {
            lock (lockObj)
            {
                Q.Enqueue(val);
                Console.WriteLine("W:{0}", val);
                Monitor.Pulse(lockObj);
            }
        }
        private void ReadQueue()
        {
            while (running)
            {
                lock (lockObj)
                {
                    while (Q.Count == 0)
                    {
                        Monitor.Wait(lockObj);
                    }
 
                    int qCount = Q.Count;
                    for (int i = 0; i < qCount; i++)
                    {
                        int val = (int)Q.Dequeue();
                        Console.WriteLine("R:{0}", val);
                    }
                }
 
            }
            if (!running)
            {
                return;
            }
        }
 
    }
}