[.Net線程處理系列]專題二：線程池中的工作者線程

目錄：

一、上節(jié)補充

二、CLR線程池基礎

三、通過線程池的工作者線程實現(xiàn)異步

四、使用委托實現(xiàn)異步

五、任務

六、小結

一、上節(jié)補充

對于Thread類還有幾個常用方法需要說明的。

1.1 Suspend和Resume方法

    這兩個方法在.net Framework 1.0 的時候就支持的方法，他們分別可以掛起線程和恢復掛起的線程。但在.net Framework 2.0以后的版本中這兩個方法都過時了，MSDN的解釋是這樣：

警告：

不要使用 Suspend 和 Resume 方法來同步線程的活動。您無法知道掛起線程時它正在執(zhí)行什么代碼。如果您在安全權限評估期間掛起持有鎖的線程，則 AppDomain中的其他線程可能被阻止。如果您在線程正在執(zhí)行類構造函數(shù)時掛起它，則 AppDomain中嘗試使用該類的其他線程將被阻止。這樣很容易發(fā)生死鎖。

對于這個解釋可能有點抽象吧，讓我們來看看一段代碼可能會清晰點：

class Program  
    {  
        static void Main(string[] args)  
        {  
            // 創(chuàng)建一個線程來測試  
            Thread thread1 = new Thread(TestMethod);        
            thread1.Name = "Thread1";     
            thread1.Start();      
            Thread.Sleep(2000);  
            Console.WriteLine("Main Thread is running");  
            ////int b = 0;  
            ////int a = 3 / b;  
            ////Console.WriteLine(a);  
            thread1.Resume();       
            Console.Read();  
        }  
 
        private static void TestMethod()  
        {       
            Console.WriteLine("Thread: {0} has been suspended!", Thread.CurrentThread.Name);  
        
            //將當前線程掛起  
            Thread.CurrentThread.Suspend();            
            Console.WriteLine("Thread: {0} has been resumed!", Thread.CurrentThread.Name);  
        }  
    } 

上面一段代碼還存在一個隱患，請看下面一小段代碼：

class Program  
    {  
        static void Main(string[] args)  
        {  
            // 創(chuàng)建一個線程來測試  
            Thread thread1 = new Thread(TestMethod);        
            thread1.Name = "Thread1";     
            thread1.Start();  
            Console.WriteLine("Main Thread is running");  
            thread1.Resume();       
            Console.Read();  
        }  
 
        private static void TestMethod()  
        {       
            Console.WriteLine("Thread: {0} has been suspended!", Thread.CurrentThread.Name);  
            Thread.Sleep(1000);  
 
            //將當前線程掛起  
            Thread.CurrentThread.Suspend();            
            Console.WriteLine("Thread: {0} has been resumed!", Thread.CurrentThread.Name);  
        }  
    } 

    當主線程跑（運行）的太快,做完自己的事情去喚醒thread1時，此時thread1還沒有掛起而起喚醒thread1,此時就會出現(xiàn)異常了。并且上面使用的Suspend和Resume方法，編譯器已經(jīng)出現(xiàn)警告了，提示這兩個方法已經(jīng)過時， 所以在我們平時使用中應該盡量避免。

1.2 Abort和 Interrupt方法

Abort方法和Interrupt都是用來終止線程的，但是兩者還是有區(qū)別的。

1、他們拋出的異常不一樣，Abort 方法拋出的異常是ThreadAbortException， Interrupt拋出的異常為ThreadInterruptedException

2、調(diào)用interrupt方法的線程之后可以被喚醒，然而調(diào)用Abort方法的線程就直接被終止不能被喚醒的。

下面一段代碼是演示Abort方法的使用

using System;  
using System.Threading;  
 
namespace ConsoleApplication1  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            Thread abortThread = new Thread(AbortMethod);  
            abortThread.Name = "Abort Thread";  
            abortThread.Start();  
            Thread.Sleep(1000);  
            try 
            {  
                abortThread.Abort();       
            }  
            catch   
            {  
                Console.WriteLine("{0} Exception happen in Main Thread", Thread.CurrentThread.Name);  
                Console.WriteLine("{0} Status is:{1} In Main Thread ", Thread.CurrentThread.Name, Thread.CurrentThread.ThreadState);  
            }  
            finally 
            {  
                Console.WriteLine("{0} Status is:{1} In Main Thread ", abortThread.Name, abortThread.ThreadState);  
            }  
 
            abortThread.Join();  
            Console.WriteLine("{0} Status is:{1} ", abortThread.Name, abortThread.ThreadState);  
            Console.Read();  
             
        }  
 
        private static void AbortMethod()  
        {  
            try 
            {  
                Thread.Sleep(5000);  
            }  
            catch(Exception e)  
            {  
                Console.WriteLine(e.GetType().Name);  
                Console.WriteLine("{0} Exception happen In Abort Thread", Thread.CurrentThread.Name);  
                Console.WriteLine("{0} Status is:{1} In Abort Thread ", Thread.CurrentThread.Name, Thread.CurrentThread.ThreadState);  
            }  
            finally 
            {  
                Console.WriteLine("{0} Status is:{1} In Abort Thread", Thread.CurrentThread.Name, Thread.CurrentThread.ThreadState);  
            }  
        }  
    } 

運行結果：

    從運行結果可以看出，調(diào)用Abort方法的線程引發(fā)的異常類型為ThreadAbortException, 以及異常只會在 調(diào)用Abort方法的線程中發(fā)生，而不會在主線程中拋出，并且調(diào)用Abort方法后線程的狀態(tài)不是立即改變?yōu)锳borted狀態(tài)，而是從AbortRequested->Aborted。

Interrupt方法：

using System;  
using System.Threading;  
 
namespace ConsoleApplication1  
{  
    class Program  
    {  
        static void Main(string[] args)  
        { Thread interruptThread = new Thread(AbortMethod);  
            interruptThread.Name = "Interrupt Thread";  
            interruptThread.Start();    
            interruptThread.Interrupt();       
             
            interruptThread.Join();  
            Console.WriteLine("{0} Status is:{1} ", interruptThread.Name, interruptThread.ThreadState);  
            Console.Read();       
        }  
 
        private static void AbortMethod()  
        {  
            try 
            {  
                Thread.Sleep(5000);  
            }  
            catch(Exception e)  
            {  
                Console.WriteLine(e.GetType().Name);  
                Console.WriteLine("{0} Exception happen In Interrupt Thread", Thread.CurrentThread.Name);  
                Console.WriteLine("{0} Status is:{1} In Interrupt Thread ", Thread.CurrentThread.Name, Thread.CurrentThread.ThreadState);  
            }  
            finally 
            {  
                Console.WriteLine("{0} Status is:{1} In Interrupt Thread", Thread.CurrentThread.Name, Thread.CurrentThread.ThreadState);  
            }  
        }  
    }  
} 

 運行結果：

    從結果中可以得到，調(diào)用Interrupt方法拋出的異常為：ThreadInterruptException, 以及當調(diào)用Interrupt方法后線程的狀態(tài)應該是中斷的， 但是從運行結果看此時的線程因為了Join,Sleep方法而喚醒了線程，為了進一步解釋調(diào)用Interrupt方法的線程可以被喚醒， 我們可以在線程執(zhí)行的方法中運用循環(huán)，如果線程可以喚醒，則輸出結果中就一定會有循環(huán)的部分，然而調(diào)用Abort方法線程就直接終止，就不會有循環(huán)的部分，下面代碼相信大家看后肯定會更加理解兩個方法的區(qū)別的：

using System;  
using System.Threading;  
 
namespace ConsoleApplication2  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            Thread thread1 = new Thread(TestMethod);  
            thread1.Start();  
            Thread.Sleep(100);  
 
            thread1.Interrupt();  
            Thread.Sleep(3000);  
            Console.WriteLine("after finnally block, the Thread1 status is:{0}", thread1.ThreadState);  
            Console.Read();  
        }  
        private static void TestMethod()  
        {  
              
            for (int i = 0; i < 4; i++)  
            {  
                try 
                {  
                    Thread.Sleep(2000);  
                    Console.WriteLine("Thread is Running");  
                }  
                catch (Exception e)  
                {  
                    if (e != null)  
                    {  
                        Console.WriteLine("Exception {0} throw ", e.GetType().Name);  
                    }  
                }  
                finally 
                {  
                    Console.WriteLine("Current Thread status is:{0} ", Thread.CurrentThread.ThreadState);  
                }  
            }  
        }  
    }  
} 

運行結果為：

如果把上面的 thread1.Interrupt();改為 thread1.Abort(); 運行結果為：

 二、線程池基礎

    首先，創(chuàng)建和銷毀線程是一個要耗費大量時間的過程，另外，太多的線程也會浪費內(nèi)存資源，所以通過Thread類來創(chuàng)建過多的線程反而有損于性能，為了改善這樣的問題 ，.net中就引入了線程池。

    線程池形象的表示就是存放應用程序中使用的線程的一個集合（就是放線程的地方，這樣線程都放在一個地方就好管理了）。CLR初始化時，線程池中是沒有線程的，在內(nèi)部， 線程池維護了一個操作請求隊列，當應用程序想執(zhí)行一個異步操作時，就調(diào)用一個方法，就將一個任務放到線程池的隊列中，線程池中代碼從隊列中提取任務，將這個任務委派給一個線程池線程去執(zhí)行，當線程池線程完成任務時，線程不會被銷毀，而是返回到線程池中，等待響應另一個請求。由于線程不被銷毀， 這樣就可以避免因為創(chuàng)建線程所產(chǎn)生的性能損失。

注意：通過線程池創(chuàng)建的線程默認為后臺線程，優(yōu)先級默認為Normal.

三、通過線程池的工作者線程實現(xiàn)異步

3.1 創(chuàng)建工作者線程的方法

public static bool QueueUserWorkItem (WaitCallback callBack);

public static bool QueueUserWorkItem(WaitCallback callback, Object state);

這兩個方法向線程池的隊列添加一個工作項（work item）以及一個可選的狀態(tài)數(shù)據(jù)。然后，這兩個方法就會立即返回。

工作項其實就是由callback參數(shù)標識的一個方法，該方法將由線程池線程執(zhí)行。同時寫的回調(diào)方法必須匹配System.Threading.WaitCallback委托類型，定義為：

public delegate void WaitCallback(Object state);

下面演示如何通過線程池線程來實現(xiàn)異步調(diào)用：

using System;  
using System.Threading;  
 
namespace ThreadPoolUse  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            // 設置線程池中處于活動的線程的最大數(shù)目  
            // 設置線程池中工作者線程數(shù)量為1000，I/O線程數(shù)量為1000  
            ThreadPool.SetMaxThreads(1000, 1000);  
            Console.WriteLine("Main Thread: queue an asynchronous method");  
            PrintMessage("Main Thread Start");  
 
            // 把工作項添加到隊列中，此時線程池會用工作者線程去執(zhí)行回調(diào)方法  
            ThreadPool.QueueUserWorkItem(asyncMethod);  
            Console.Read();  
        }  
 
        // 方法必須匹配WaitCallback委托  
        private static void asyncMethod(object state)  
        {  
            Thread.Sleep(1000);  
            PrintMessage("Asynchoronous Method");  
            Console.WriteLine("Asynchoronous thread has worked ");  
        }  
 
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,   
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：   

從結果中可以看出，線程池中的可用的工作者線程少了一個，用去執(zhí)行回調(diào)方法了。

ThreadPool.QueueUserWorkItem(WaitCallback callback,Object state) 方法可以把object對象作為參數(shù)傳送到回調(diào)函數(shù)中,使用和ThreadPool.QueueUserWorkItem(WaitCallback callback)的使用和類似，這里就不列出了。

3.2 協(xié)作式取消

    .net Framework提供了取消操作的模式， 這個模式是協(xié)作式的。為了取消一個操作，首先必須創(chuàng)建一個System.Threading.CancellationTokenSource對象。

下面代碼演示了協(xié)作式取消的使用，主要實現(xiàn)當用戶在控制臺敲下回車鍵后就停止數(shù)數(shù)方法。

using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.Threading;  
 
namespace ConsoleApplication3  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            ThreadPool.SetMaxThreads(1000, 1000);  
            Console.WriteLine("Main thread run");      
            PrintMessage("Start");  
            Run();  
            Console.ReadKey();  
        }  
 
        private static void Run()  
        {  
            CancellationTokenSource cts = new CancellationTokenSource();  
 
            // 這里用Lambda表達式的方式和使用委托的效果一樣的，只是用了Lambda后可以少定義一個方法。  
            // 這在這里就是讓大家明白怎么lambda表達式如何由委托轉變的  
            ////ThreadPool.QueueUserWorkItem(o => Count(cts.Token, 1000));  
 
            ThreadPool.QueueUserWorkItem(callback, cts.Token);  
 
            Console.WriteLine("Press Enter key to cancel the operation\n");  
            Console.ReadLine();  
 
            // 傳達取消請求  
            cts.Cancel();  
        }  
          
        private static void callback(object state)  
        {  
            Thread.Sleep(1000);  
            PrintMessage("Asynchoronous Method Start");  
            CancellationToken token =(CancellationToken)state;      
            Count(token, 1000);  
        }  
 
        // 執(zhí)行的操作，當受到取消請求時停止數(shù)數(shù)  
        private static void Count(CancellationToken token,int countto)  
        {  
            for (int i = 0; i < countto; i++)  
            {  
                if (token.IsCancellationRequested)  
                {  
                    Console.WriteLine("Count is canceled");  
                    break;  
                }  
 
                Console.WriteLine(i);  
                Thread.Sleep(300);  
            }  
              
            Console.WriteLine("Cout has done");         
        }  
 
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,  
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：

 四、使用委托實現(xiàn)異步

    通過調(diào)用ThreadPool的QueueUserWorkItem方法來來啟動工作者線程非常方便，但委托WaitCallback指向的是帶有一個參數(shù)的無返回值的方法，如果我們實際操作中需要有返回值，或者需要帶有多個參數(shù)， 這時通過這樣的方式就難以實現(xiàn)， 為了解決這樣的問題，我們可以通過委托來建立工作這線程，

下面代碼演示了使用委托如何實現(xiàn)異步：

using System;  
using System.Threading;  
 
namespace Delegate  
{  
    class Program  
    {  
        // 使用委托的實現(xiàn)的方式是使用了異步變成模型APM（Asynchronous Programming Model）  
        // 自定義委托  
        private delegate string MyTestdelegate();  
 
        static void Main(string[] args)  
        {  
            ThreadPool.SetMaxThreads(1000, 1000);  
            PrintMessage("Main Thread Start");  
 
            //實例化委托  
            MyTestdelegate testdelegate = new MyTestdelegate(asyncMethod);  
 
            // 異步調(diào)用委托  
            IAsyncResult result = testdelegate.BeginInvoke(null, null);  
 
            // 獲取結果并打印出來  
            string returndata = testdelegate.EndInvoke(result);  
            Console.WriteLine(returndata);  
 
            Console.ReadLine();  
        }  
        private static string asyncMethod()  
        {  
            Thread.Sleep(1000);  
            PrintMessage("Asynchoronous Method");  
            return "Method has completed";  
        }  
 
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,  
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：

 五、任務

同樣 任務的引入也是為了解決通過ThreadPool.QueueUserWorkItem中限制的問題，

下面代碼演示通過任務來實現(xiàn)異步：

5.1 使用任務來實現(xiàn)異步

using System;  
using System.Threading;  
using System.Threading.Tasks;  
 
namespace TaskUse  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            ThreadPool.SetMaxThreads(1000, 1000);  
            PrintMessage("Main Thread Start");  
            // 調(diào)用構造函數(shù)創(chuàng)建Task對象,  
            Task<int> task = new Task<int>(n => asyncMethod((int)n), 10);  
 
            // 啟動任務   
            task.Start();  
            // 等待任務完成  
            task.Wait();  
            Console.WriteLine("The Method result is: "+task.Result);  
 
            Console.ReadLine();  
        }  
 
        private static int asyncMethod(int n)  
        {  
            Thread.Sleep(1000);  
            PrintMessage("Asynchoronous Method");  
 
            int sum = 0;  
            for (int i = 1; i < n; i++)  
            {  
                // 如果n太大，使用checked使下面代碼拋出異常  
                checked 
                {  
                    sum += i;  
                }  
            }  
 
            return sum;  
        }  
 
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,  
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：

5.2 取消任務

如果要取消任務， 同樣可以使用一個CancellationTokenSource對象來取消一個Task.

下面代碼演示了如何來取消一個任務：

using System;  
using System.Threading;  
using System.Threading.Tasks;  
 
namespace TaskUse  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            ThreadPool.SetMaxThreads(1000, 1000);  
            PrintMessage("Main Thread Start");  
            CancellationTokenSource cts = new CancellationTokenSource();  
 
            // 調(diào)用構造函數(shù)創(chuàng)建Task對象,將一個CancellationToken傳給Task構造器從而使Task和CancellationToken關聯(lián)起來  
            Task<int> task = new Task<int>(n => asyncMethod(cts.Token, (int)n), 10);  
 
            // 啟動任務   
            task.Start();  
 
            // 延遲取消任務  
            Thread.Sleep(3000);  
 
            // 取消任務  
            cts.Cancel();  
            Console.WriteLine("The Method result is: " + task.Result);  
            Console.ReadLine();  
        }  
 
        private static int asyncMethod(CancellationToken ct, int n)  
        {  
            Thread.Sleep(1000);  
            PrintMessage("Asynchoronous Method");  
 
            int sum = 0;  
            try 
            {  
                for (int i = 1; i < n; i++)  
                {  
                    // 當CancellationTokenSource對象調(diào)用Cancel方法時，  
                    // 就會引起OperationCanceledException異常  
                    // 通過調(diào)用CancellationToken的ThrowIfCancellationRequested方法來定時檢查操作是否已經(jīng)取消，  
                    // 這個方法和CancellationToken的IsCancellationRequested屬性類似  
                    ct.ThrowIfCancellationRequested();  
                    Thread.Sleep(500);  
                    // 如果n太大，使用checked使下面代碼拋出異常  
                    checked 
                    {  
                        sum += i;  
                    }  
                }  
            }  
            catch (Exception e)  
            {  
                Console.WriteLine("Exception is:" + e.GetType().Name);  
                Console.WriteLine("Operation is Canceled");  
            }  
 
            return sum;  
        }  
 
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,  
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：

 5.3 任務工廠

同樣可以通過任務工廠TaskFactory類型來實現(xiàn)異步操作。

using System;  
using System.Threading;  
using System.Threading.Tasks;  
 
namespace TaskFactory  
{  
    class Program  
    {  
        static void Main(string[] args)  
        {  
            ThreadPool.SetMaxThreads(1000, 1000);  
            Task.Factory.StartNew(() => PrintMessage("Main Thread"));   
            Console.Read();  
        }  
        // 打印線程池信息  
        private static void PrintMessage(String data)  
        {  
            int workthreadnumber;  
            int iothreadnumber;  
 
            // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量  
            // 獲得的可用I/O線程數(shù)量給iothreadnumber變量  
            ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);  
 
            Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",  
                data,  
                Thread.CurrentThread.ManagedThreadId,  
                Thread.CurrentThread.IsBackground.ToString(),  
                workthreadnumber.ToString(),  
                iothreadnumber.ToString());  
        }  
    }  
} 

運行結果：

 六、小結

    講到這里CLR的工作者線程大致講完了，希望也篇文章可以讓大家對線程又有進一步的理解。在后面的一篇線程系列將談談CLR線程池的I/O線程。