上一章中筆者對C#一些獨有的語法點進行講解,相信也可以看C#的一些神奇之處。那麼本章主要是放在多線程這方面的知識。不管是C#還是JAVA在開發過程或多或少都會用到關於多線程的編程。當然筆者不可能把多線程的知識點講的很全面。筆者這裡只是講一些筆者常用到的。如果有興趣的朋友,筆者希望主動性去查找一下資料。
Thread類對於Thread類相信JAVA的朋友一點也不陌生。在一點上C#到是跟JAVA很類似。只是在使用上有一定差別。首先要明白C#的多線程功能一般都是在命名空System.Threading下面。至於什麼是線程,進程又是什麼這樣子的問題。筆者就不多說了。相信大家都明白。筆者還是喜歡直接一點。讓我們看一下代碼進行學習吧。
C#:
1 class Program 2 { 3 static void Main(string[] args) 4 { 5 Thread myThread1 = new Thread(() => 6 { 7 Console.WriteLine("這是一個lambda表達式 創建線程"); 8 }); 9 10 Thread myThread2 = new Thread(ThreadStartImp); 11 12 Thread myThread3 = new Thread((object obj) => 13 { 14 Console.WriteLine("這是一個lambda表達式創建有參數的線程 參數:" + obj.ToString()); 15 }); 16 17 myThread1.Start(); 18 myThread2.Start(); 19 myThread3.Start("aomi"); 20 21 } 22 23 public static void ThreadStartImp() 24 { 25 Console.WriteLine("這是一個用方法創建線程"); 26 } 27 28 29 }
筆者在上面創建三個線程代碼。myThread1和myThread2是同一種線程。即是沒有參數的線程。myThread3是有參數的線程。不管是不是有參數。使用方式基本是一樣子的。有參數的話,就是調用Start方法的時候給他傳入一個參數即可。我們可以看到使用上跟JAVA有一個很大的差別。JAVA的Thread類構造函數的參數傳入Runnable接口。可惜C#不是。如下代碼。
C#:
public Thread(ParameterizedThreadStart start); public Thread(ThreadStart start); public Thread(ParameterizedThreadStart start, int maxStackSize); public Thread(ThreadStart start, int maxStackSize);
這段代碼是源碼裡面的。選中Thread類按F12就可以大概的查看Thread類的結構。我們看可以看到四個構造函數。我們常常用到只是倆個:Thread(ParameterizedThreadStart start)和Thread(ThreadStart start)。剛剛看到的時候我一直以為ThreadStart會跟JAVA的Runnable接口一樣子。只到按F12進入查看一下結構才明白大錯特錯。如下代碼
C#:
[ComVisible(true)] public delegate void ThreadStart();
C#:
[ComVisible(false)] public delegate void ParameterizedThreadStart(object obj);
我們可以清楚的看到一個關鍵字delegate。相信有看過上一章的朋友都知道他是跟事件有關系。沒有錯。就是定義一個委托類型。以便將來用於傳方法。所以我們可以明白這邊的Thread類的構造函數的參數只能傳入方法。那麼相信筆者上面的三個線程的定義的意義也很明顯了。
myThread1線程:筆者用的是lambda表達式來創建。lambda表達是什麼上一章也有簡單的講到。
myThread2線程:外面定義一個方法用於實現多線程。這方法可以是一個靜態方法也可以是一個對象的方法。關鍵字static的功能跟JAVA一樣子。
myThread3線程:實現有一個有參數的多線程。
上面只是講到關於Thread類的使用。對於Thread類對象裡面的一些方法的話,筆者就不多介紹了。大至跟JAVA的Thread類一樣子。如Interrupt方法。請讀者們自行查看。
ThreadPool類當我們談到多線程池的時候,相信大家都知道是什麼東西。C#用的是ThreadPool類。只是可惜筆者在JAVA這邊用到多線程池的機會不多。所以也不清楚JAVA中的ThreadPoolExecutor類和Executors類跟C#的ThreadPool類相差多少。不過有興趣的朋友可以看一下。筆者這裡還是講一下ThreadPool類的使用吧。ThreadPool類更多的時候有一點像工具類一樣子。如下面代碼。
C#:
class Program { static void Main(string[] args) { ThreadPool.QueueUserWorkItem((obj) => { Console.WriteLine("這是一個lambda表達式創建有參數的線程 參數:" + obj.ToString()); }); ThreadPool.QueueUserWorkItem(WaitCallbackImp); } public static void WaitCallbackImp(object obj) { Console.WriteLine("這是一個用方法創建線程"); } }
上面的代碼跟上面的Thread類有一點類似。可是本質上卻有很大的差別。這裡是用多線程池的。另外對於多線程池的設置。只要ThreadPool.XXXXX裡面有很多方法讓你去設置。
Task類如果你們有用上面的Thread類你就會發現,有時候當線程在運行中的時候很難停止。但是如果你用了Task類的話,你就會發現這個難點已經不存在了。我也不清楚C#為什麼會引入Task類。可能就是因為Thread類和ThreadPool類太難控制吧。那麼這不是筆者關注的問題。讓我們看一下Task類是如何使用的。Task類是中文常常叫做任務。所以就是有一種說法。是單任務還是多任務。為什麼筆者會這樣子講呢?如下。
1.單任務。即是一個Task類實例。這個時候就比較簡單。代碼如下
class Program { static void Main(string[] args) { CancellationTokenSource cts = new CancellationTokenSource();//用於中途取消 Task myTask = new Task((obj) => { Console.WriteLine("這是一個單任務"); }, cts); myTask.Start(); Console.ReadKey(); } }
這裡面筆者只用到了一個類CancellationTokenSource。這個類就是用於取消任務。還是讓筆者寫一個例子吧。
class Program { static void Main(string[] args) { CancellationTokenSource cts = new CancellationTokenSource();//用於中途取消 Task myTask = new Task((obj) => { Console.WriteLine("這是一個單任務"); Thread.Sleep(20000);//讓他睡一段時間 }, cts); myTask.Start(); if (cts.IsCancellationRequested)//判斷是否取消 { cts.Cancel(); } Console.ReadKey(); } }
2.多任務。就是多個Task類的實例進行配合。這個時候就有誰先做。誰後做的問題。
class Program { static void Main(string[] args) { CancellationTokenSource cts1 = new CancellationTokenSource();//用於中途取消 Task myTask1 = new Task((obj) => { Console.WriteLine("這是一個單任務"); //Thread.Sleep(20000);//讓他睡一段時間 }, cts1); CancellationTokenSource cts2 = new CancellationTokenSource();//用於中途取消 myTask1.ContinueWith((task) => { Console.WriteLine("myTask2任務"); }, cts2.Token); myTask1.Start(); //if (cts1.IsCancellationRequested)//判斷是否取消 //{ // cts1.Cancel(); //} Console.ReadKey(); } }
上面的ContinueWith方法就是表示:當myTask1結束之後,就可以繼續紅色的代碼。即是另一個Task任務。除了上面的實例之後,還有一種用法。代碼如下。
CancellationTokenSource cts3 = new CancellationTokenSource();//用於中途取消 Task.Factory.StartNew((obj) => { Console.WriteLine("這是一個用的Factory單任務"); }, cts3);
看樣了不用筆者多說了。有一點類似於多線程池的概念。只是注意Task.Factory裡面還有一些很好用的功能。ContinueWhenAll方法就是一個很好的體現。和上面的ContinueWith有一個像。即是所以的task結束之後才執行對應的最後一個task。請用Task.Factory.讓他提示進行學習。如果不提示的話,寫完上面的"ask.Factory."之後按Ctrl+J。裡面有各種方法讓你學習。
本章總結本章主要是對多線程常用的一些知識進行講解。筆者並沒有對他們進行詳細的說明。所以希望讀者們可以根據筆者所講的繼續深入下去。