c#自己實作執行緒池功能(二)

介紹

在上一篇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);
       }

下面給一個測試類別
/ware/vc/" target="_blank" class="keylink">vcD4KPGgxPre9t6i2/jwvaDE+Cs7Sw8eyu8rH08PQxbrFwb+jrM7Sw8fKudPDQXV0b1Jlc2V0RXZlbnTAtM7Sw8fKudPDQXV0b1Jlc2V0RXZlbnTAtM7Sw YWRQb29sTWFuYWdlcrP1yry7r8qxuvK0tL2o0ru49iAgbG9ja3MgPSBuZXcgQXV0b1Jlc2V0RXZlbnQoZmFsc2UpOwq1sUFkZFRhcgQXV0b1Jlc2V0RXZlbnQoZmFsc2UpOwq1sUFkZFRhc2u1xMqNuvJnjg;bx254520200 7uvPO0sPHttRXb3JrVGhyZWFktcRydW66r8r91/bSu7j20KHQobXE0N64xAo8cHJlIGNsYXNzPQ=="brush:java;"> public void run() { while (flag && TaskQuue ue! 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#自己實現線程池功能(二)的內容，更多相關內容請關注PHP中文網（www .php.cn）！