[.NET] Thread Separate Event

撰寫多線程對象時，執行速度是一項很重要的設計考慮。通常為了加快執行速度，會將執行運作邏輯的主線程，跟發出事件的事件線程做隔離設計。這樣的隔離設計可以不讓主線程，因為外部事件處理而停頓。而這樣的設計下，為了簡化線程管理，可以采用ThreadPool來完成事件線程的工作。簡單的程序范例如下：

 

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            var obj = new ClassA();
            obj.NotifyArrived += new Action<int>(obj_NotifyArrived);
            obj.Start();
            Console.ReadLine();
            obj.Stop();
        }

        static void obj_NotifyArrived(int data)
        {
            Console.WriteLine(data);
        }
    }

    public class ClassA
    {
        // Fields
        private bool _isRunning = true;


        // Methods    
        public void Start()
        {
            Thread thread = new Thread(this.Run);
            thread.Start();
        }

        public void Stop()
        {
            _isRunning = false;
        }

        private void Run()
        {
            int i = 0;
            while (_isRunning == true)
            {
                Thread.Sleep(100);
                this.OnNotifyArrived(i++);
            }
        }


        // Events
        public event System.Action<int> NotifyArrived;
        private void OnNotifyArrived(int data)
        {
            WaitCallback handlerDelegate = delegate(object state)
            {
                var handler = this.NotifyArrived;
                if (handler != null)
                {
                    handler(data);
                }
            };
            ThreadPool.QueueUserWorkItem(handlerDelegate);
        }
    }
}

 

但是這樣的隔離設計，卻無法滿足「必須按照先來后到去處理事件」這樣的行為要求。因為ThreadPool只是單純的為每一個WaitCallback委派，分派一條線程去做處理，而每條線程之間並沒有設定執行先后順序的能力。

 

這個問題困擾了我幾天，后來想到一個解法。在主線程跟事件線程之間，墊一層Queue做隔離，將要執行的WaitCallback委派都存放進這個Queue。並且通過Lock的機制，強迫一次只能有一個線程去處理Queue里面的WaitCallback委派。透過這樣的設計，就可以完成將執行運作邏輯的主線程，跟發出事件的事件線程做隔離設計的工作。范例程序代碼如下：

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            var obj = new ClassB();
            obj.NotifyArrived += new Action<int>(obj_NotifyArrived);
            obj.Start();
            Console.ReadLine();
            obj.Stop();
        }

        static void obj_NotifyArrived(int data)
        {
            Console.WriteLine(data);
        }
    }

    public class ClassB
    {
        // Fields
        private bool _isRunning = true;

        private readonly object _eventSyncRoot = new object();

        private readonly Queue<WaitCallback> _eventDelegateQueue = new Queue<WaitCallback>();


        // Methods    
        public void Start()
        {
            Thread thread = new Thread(this.Run);
            thread.Start();
        }

        public void Stop()
        {
            _isRunning = false;
        }

        private void Run()
        {
            int i = 0;
            while (_isRunning == true)
            {
                Thread.Sleep(100);
                this.OnNotifyArrived(i++);
            }
        }


        // Events
        public event System.Action<int> NotifyArrived;
        private void OnNotifyArrived(int data)
        {
            // Queue EventDelegate
            WaitCallback eventDelegate = delegate(object state)
            {
                var handler = this.NotifyArrived;
                if (handler != null)
                {
                    handler(data);
                }
            };

            lock (_eventDelegateQueue)
            {
                _eventDelegateQueue.Enqueue(eventDelegate);
            }

            // Run EventDelegate
            WaitCallback handlerDelegate = delegate(object state)
            {
                lock (_eventSyncRoot)
                {
                    WaitCallback runEventDelegate = null;
                    lock (_eventDelegateQueue)
                    {
                        if (_eventDelegateQueue.Count > 0)
                        {
                            runEventDelegate = _eventDelegateQueue.Dequeue();
                        }
                    }

                    if (runEventDelegate != null)
                    {
                        runEventDelegate(null);
                    }
                }
            };
            ThreadPool.QueueUserWorkItem(handlerDelegate);
        }
    }
}

 

最后說一下，要完成這樣的隔離設計。不使用ThreadPool，而改用一個獨立Thread去處理WaitCallback委派，也是可行的設計。只不過獨立一個線程去處理，就需要額外增加管理這個獨立線程的工作，這就看每個人的選擇跟考慮了。