유리상자 속 이야기

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace ThreadTdd
{
    public interface ICommand
    {
        void Execute();
    }
}
 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;


namespace ThreadTdd
{
    public class MessageQueue : IDisposable
    {
        private Queue<ICommand> CommandList = new Queue<ICommand>();
        private ManualResetEvent Controller = new ManualResetEvent(false);
        private Thread QueueThread = null;
        private Object QueueLockObj = new object();
        public bool IsAlive { get; private set; }

        //--------------------------------
        // 생성자
        //--------------------------------
        public MessageQueue() {
            this.QueueThread = new Thread(this.ExecuteMessage) {
                IsBackground = true, Name = "MessageQueue"
            };
            this.IsAlive = true;
            this.QueueThread.Start();
        }



        //--------------------------------
        // Command 를 메세지큐에 넣음
        //--------------------------------
        public void Enqueue(ICommand command) {
            // Queue 에 Command 를 Enqueue
            this.CommandList.Enqueue(command);

            // 대기상태에 빠져 있을지 모르니, Thread 를 동작하게 만듦
            this.Controller.Set();
        }



        //--------------------------------
        // Queue 에 쌓여있는 Command 를 수행
        //--------------------------------
        private void ExecuteMessage() {
            try {
                while (IsAlive) {
                    // Queue 에 있는 모든 Command 를 수행
                    while (this.CommandList.Count > 0) {
                        ICommand command = this.CommandList.Dequeue();
                        command.Execute();
                    }
                    // 다 수행하고 나면, 대기상태로 진입
                    this.Controller.Reset();
                    this.Controller.WaitOne(Timeout.Infinite);
                }
            } catch (ThreadAbortException) { }
        }



        //----------------------
        // 리소스 해제
        //----------------------
        public void Dispose() {
            this.IsAlive = false;
            this.Controller.Set();
            this.QueueThread.Abort();
        }
    }
}