c#使用多線程的幾種方式示例詳解

本文轉載自：http://www.jb51.net/article/46234.htm

本文章主要介紹了c#使用多線程的幾種方式,通過示例學習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();

}

}