c#使用多線程的幾種方式示例詳解
(1)不需要傳遞參數,也不需要返回參數
ThreadStart是一個委托,這個委托的定義為void ThreadStart(),沒有參數與返回值。
class Program { static void Main(string[] args) { for (int i = 0; i < 30; i++) { ThreadStart threadStart = new ThreadStart(Calculate); Thread thread = new Thread(threadStart); thread.Start(); } Thread.Sleep(2000); Console.Read(); }public static void Calculate() { DateTime time = DateTime.Now;//得到當前時間 Random ra = new Random();//隨機數對象 Thread.Sleep(ra.Next(10,100));//隨機休眠一段時間 Console.WriteLine(time.Minute + ":" + time.Millisecond); } }
(2)需要傳遞單個參數
ParameterThreadStart委托定義為void ParameterizedThreadStart(object state),有一個參數但是沒有返回值。
class Program {static void Main(string[] args) { for (int i = 0; i < 30; i++) { ParameterizedThreadStart tStart = new ParameterizedThreadStart(Calculate); Thread thread = new Thread(tStart); thread.Start(i*10+10);//傳遞參數 } Thread.Sleep(2000); Console.Read(); } public static void Calculate(object arg) { Random ra = new Random();//隨機數對象 Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間 Console.WriteLine(arg); } }
(3)使用專門的線程類(常用)
使用線程類可以有多個參數與多個返回值,十分靈活!
class Program { static void Main(string[] args) { MyThread mt = new MyThread(100); ThreadStart threadStart = new ThreadStart(mt.Calculate); Thread thread = new Thread(threadStart); thread.Start(); //等待線程結束 while (thread.ThreadState != ThreadState.Stopped) { Thread.Sleep(10); } Console.WriteLine(mt.Result);//打印返回值 Console.Read(); } } public class MyThread//線程類 { public int Parame { set; get; }//參數 public int Result { set; get; }//返回值 //構造函數 public MyThread(int parame) { this.Parame = parame; } //線程執行方法 public void Calculate() { Random ra = new Random();//隨機數對象 Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間 Console.WriteLine(this.Parame); this.Result = this.Parame * ra.Next(10, 100); } }
(4)使用匿名方法(常用)
使用匿名方法啟動線程可以有多個參數和返回值,而且使用非常方便!
class Program { static void Main(string[] args) { int Parame = 100;//當做參數 int Result = 0;//當做返回值 //匿名方法 ThreadStart threadStart = new ThreadStart(delegate() { Random ra = new Random();//隨機數對象 Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間 Console.WriteLine(Parame);//輸出參數 Result = Parame * ra.Next(10, 100);//計算返回值 }); Thread thread = new Thread(threadStart); thread.Start();//多線程啟動匿名方法 //等待線程結束 while (thread.ThreadState != ThreadState.Stopped) { Thread.Sleep(10); } Console.WriteLine(Result);//打印返回值 Console.Read(); } }
(5)使用委托開啟多線程(多線程深入)
1、用委托(Delegate)的BeginInvoke和EndInvoke方法操作線程
BeginInvoke方法可以使用線程異步地執行委托所指向的方法。然後通過EndInvoke方法獲得方法的返回值(EndInvoke方法的返回值就是被調用方法的返回值),或是確定方法已經被成功調用。
class Program { private delegate int NewTaskDelegate(int ms); private static int newTask(int ms) { Console.WriteLine("任務開始"); Thread.Sleep(ms); Random random = new Random(); int n = random.Next(10000); Console.WriteLine("任務完成"); return n; } static void Main(string[] args) { NewTaskDelegate task = newTask; IAsyncResult asyncResult = task.BeginInvoke(2000, null, null); //EndInvoke方法將被阻塞2秒 int result = task.EndInvoke(asyncResult); Console.WriteLine(result); Console.Read(); } }
2、使用IAsyncResult.IsCompleted屬性來判斷異步調用是否完成
class Program { private delegate int NewTaskDelegate(int ms); private static int newTask(int ms) { Console.WriteLine("任務開始"); Thread.Sleep(ms); Random random = new Random(); int n = random.Next(10000); Console.WriteLine("任務完成"); return n; } static void Main(string[] args) { NewTaskDelegate task = newTask; IAsyncResult asyncResult = task.BeginInvoke(2000, null, null); //等待異步執行完成 while (!asyncResult.IsCompleted) { Console.Write("*"); Thread.Sleep(100); } // 由於異步調用已經完成,因此, EndInvoke會立刻返回結果 int result = task.EndInvoke(asyncResult); Console.WriteLine(result); Console.Read(); } }
3、使用WaitOne方法等待異步方法執行完成
WaitOne的第一個參數表示要等待的毫秒數,在指定時間之內,WaitOne方法將一直等待,直到異步調用完成,並發出通知,WaitOne方法才返回true。當等待指定時間之後,異步調用仍未完成,WaitOne方法返回false,如果指定時間為0,表示不等待,如果為-1,表示永遠等待,直到異步調用完成。
class Program { private delegate int NewTaskDelegate(int ms); private static int newTask(int ms) { Console.WriteLine("任務開始"); Thread.Sleep(ms); Random random = new Random(); int n = random.Next(10000); Console.WriteLine("任務完成"); return n; } static void Main(string[] args) { NewTaskDelegate task = newTask; IAsyncResult asyncResult = task.BeginInvoke(2000, null, null); //等待異步執行完成 while (!asyncResult.AsyncWaitHandle.WaitOne(100, false)) { Console.Write("*"); } int result = task.EndInvoke(asyncResult); Console.WriteLine(result); Console.Read(); } }
4、使用回調方式返回結果
要註意的是“my.BeginInvoke(3,300, MethodCompleted, my)”,BeginInvoke方法的參數傳遞方式:
前面一部分(3,300)是其委托本身的參數。
倒數第二個參數(MethodCompleted)是回調方法委托類型,他是回調方法的委托,此委托沒有返回值,有一個IAsyncResult類型的參數,當method方法執行完後,系統會自動調用MethodCompleted方法。
最後一個參數(my)需要向MethodCompleted方法中傳遞一些值,一般可以傳遞被調用方法的委托,這個值可以使用IAsyncResult.AsyncState屬性獲得。
class Program { private delegate int MyMethod(int second, int millisecond); //線程執行方法 private static int method(int second, int millisecond) { Console.WriteLine("線程休眠" + (second * 1000 + millisecond) + "毫秒"); Thread.Sleep(second * 1000 + millisecond); Random random = new Random(); return random.Next(10000); } //回調方法 private static void MethodCompleted(IAsyncResult asyncResult) { if (asyncResult == null || asyncResult.AsyncState == null) { Console.WriteLine("回調失敗!!!"); return; } int result = (asyncResult.AsyncState as MyMethod).EndInvoke(asyncResult); Console.WriteLine("任務完成,結果:" + result); } static void Main(string[] args) { MyMethod my = method; IAsyncResult asyncResult = my.BeginInvoke(3,300, MethodCompleted, my); Console.WriteLine("任務開始"); Console.Read(); } }
5、其他組件的BeginXXX和EndXXX方法
在其他的.net組件中也有類似BeginInvoke和EndInvoke的方法,如System.Net.HttpWebRequest類的BeginGetResponse和EndGetResponse方法。其使用方法類似於委托類型的BeginInvoke和EndInvoke方法,例如:
class Program { //回調函數 private static void requestCompleted(IAsyncResult asyncResult) { if (asyncResult == null || asyncResult.AsyncState==null) { Console.WriteLine("回調失敗"); return; } HttpWebRequest hwr = asyncResult.AsyncState as HttpWebRequest; HttpWebResponse response = (HttpWebResponse)hwr.EndGetResponse(asyncResult); StreamReader sr = new StreamReader(response.GetResponseStream()); string str = sr.ReadToEnd(); Console.WriteLine("返回流長度:"+str.Length); } static void Main(string[] args) { HttpWebRequest request = (HttpWebRequest)WebRequest.Create("http://www.baidu.com"); //異步請求 IAsyncResult asyncResult = request.BeginGetResponse(requestCompleted, request); Console.WriteLine("任務開始"); Console.Read(); } }
c#使用多線程的幾種方式示例詳解