mod 線程池 sharp ise except mar 函數 rac 試圖

介紹

在上一篇c#自己實現線程池功能(一)中，我們基本實現了一個能夠執行的程序。而不能真正的稱作線程池。因為是上篇中的代碼有個致命的bug那就是沒有任務是並非等待，而是瘋狂的進行while循環，並試圖lock任務鏈表，這樣帶來的問題的就是性能相當低下，程序反映速度非常慢（當增加一個新任務後，要過非常久這個job才開始執行）造成的原因就是剛才所說的。

為了解決問題我們就須要使用某種方法使得程序可以讓進程同步。

方法一

使用信號量

我們為了降低對task任務的加鎖操作，僅僅有當task不為空時才進行試探。

我們的信號量就代表的是任務表裏面的數量。當s.WaitOne();成功後我們才開始加鎖，並取出任務

while (flag && TaskQueue != null)
            {
                //等待任務
                ThreadPoolManager.s.WaitOne();
                //獲取任務
                lock (TaskQueue)
                {
                    try
                    {
                        if (TaskQueue.Count > 0)
                            task = TaskQueue.Dequeue();
                        else
                            task = null;
                    }
                    catch (Exception)
                    {
                        task = null;
                    }
                    if (task == null)
                        continue;
                }

在ThreadPoolManager類中增加兩個變量

//因為採用信號量須要定義一個
        public int MaxJobNum = 1000;
        public static Semaphore s;

並在初始化這個類時 初始化信號量 s = new Semaphore(0, MaxJobNum);

這樣就行實現同步

以下給出一個測試類

 static void Main(string[] args)
        {
            ThreadPoolManager tpm = new ThreadPoolManager(2);

            TestTask t1 = new TestTask("task1");
            TestTask t2 = new TestTask("task2");
            TestTask t3 = new TestTask("task3");
            TestTask t4 = new TestTask("task4");
            TestTask t5 = new TestTask("task5");
            TestTask t6 = new TestTask("task6");
            TestTask t7 = new TestTask("task7");
            TestTask t8 = new TestTask("task8");
            TestTask t9 = new TestTask("task9");

            tpm.AddTask(t1);
            tpm.AddTask(t2);
            tpm.AddTask(t3);
            tpm.AddTask(t4);
            tpm.AddTask(t5);
            tpm.AddTask(t6);
            tpm.AddTask(t7);
            tpm.AddTask(t8);
            tpm.AddTask(t9);
        }

方法二

我們不是用信號量。我們使用AutoResetEvent來實現同步
第一步。在ThreadPoolManager初始化時候創建一個 locks = new AutoResetEvent(false); 當AddTask的時候locks.Set();通知等待的操作。

然後我們對WorkThread的run函數做一個小小的改動

 public void run()
        {
            while (flag && TaskQueue != null)
            {
                //等待任務
                //ThreadPoolManager.sep.WaitOne();

                //等待任務
                while (TaskQueue.Count == 0 && flag)
                {
                    try
                    {
                        ThreadPoolManager.locks.WaitOne();
                    }
                    catch (Exception)
                    {
                    }
                }
                //獲取任務
                lock (TaskQueue)
                {
                    try
                    {
                        task = TaskQueue.Dequeue();
                    }
                    catch (Exception)
                    {
                        task = null;
                    }
                    if (task == null)
                        continue;
                }
                try
                {
                    task.SetEnd(false);
                    task.StartTask();
                }
                catch (Exception)
                {
                }
                try
                {
                    if (!task.IsEnd())
                    {
                        task.SetEnd(false);
                        task.EndTask();
                    }
                }
                catch (Exception)
                {
                }

            }//end of while
        }

僅僅有當task列表的數量為0時我們才堵塞，直到AddTask的時候才繼續下去

c#自己實現線程池功能(二)