c#使用多線程的幾種方式示例詳解
(1)不需要傳遞參數(shù),也不需要返回參數(shù)
ThreadStart是一個委托，這個委托的定義為void ThreadStart()，沒有參數(shù)與返回值。
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;//得到當(dāng)前時間
Random ra = new Random();//隨機數(shù)對象
Thread.Sleep(ra.Next(10,100));//隨機休眠一段時間
Console.WriteLine(time.Minute + ":" + time.Millisecond);
}
}
(2)需要傳遞單個參數(shù)
ParameterThreadStart委托定義為void ParameterizedThreadStart(object state)，有一個參數(shù)但是沒有返回值。
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);//傳遞參數(shù)
}
Thread.Sleep(2000);
Console.Read();
}
public static void Calculate(object arg)
{
Random ra = new Random();//隨機數(shù)對象
Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間
Console.WriteLine(arg);
}
}
(3)使用專門的線程類(常用)
使用線程類可以有多個參數(shù)與多個返回值，十分靈活！
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();
//等待線程結(jié)束
while (thread.ThreadState != ThreadState.Stopped)
{
Thread.Sleep(10);
}
Console.WriteLine(mt.Result);//打印返回值
Console.Read();
}
}
public class MyThread//線程類
{
public int Parame { set; get; }//參數(shù)
public int Result { set; get; }//返回值
//構(gòu)造函數(shù)
public MyThread(int parame)
{
this.Parame = parame;
}
//線程執(zhí)行方法
public void Calculate()
{
Random ra = new Random();//隨機數(shù)對象
Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間
Console.WriteLine(this.Parame);
this.Result = this.Parame * ra.Next(10, 100);
}
}
(4)使用匿名方法(常用)
使用匿名方法啟動線程可以有多個參數(shù)和返回值，而且使用非常方便！
class Program
{
static void Main(string[] args)
{
int Parame = 100;//當(dāng)做參數(shù)
int Result = 0;//當(dāng)做返回值
//匿名方法
ThreadStart threadStart = new ThreadStart(delegate()
{
Random ra = new Random();//隨機數(shù)對象
Thread.Sleep(ra.Next(10, 100));//隨機休眠一段時間
Console.WriteLine(Parame);//輸出參數(shù)
Result = Parame * ra.Next(10, 100);//計算返回值
});
Thread thread = new Thread(threadStart);
thread.Start();//多線程啟動匿名方法
//等待線程結(jié)束
while (thread.ThreadState != ThreadState.Stopped)
{
Thread.Sleep(10);
}
Console.WriteLine(Result);//打印返回值
Console.Read();
}
}
(5)使用委托開啟多線程(多線程深入)
1、用委托(Delegate)的BeginInvoke和EndInvoke方法操作線程
BeginInvoke方法可以使用線程異步地執(zhí)行委托所指向的方法。然后通過EndInvoke方法獲得方法的返回值（EndInvoke方法的返回值就是被調(diào)用方法的返回值），或是確定方法已經(jīng)被成功調(diào)用。
class Program
{
private delegate int NewTaskDelegate(int ms);
private static int newTask(int ms)
{
Console.WriteLine("任務(wù)開始");
Thread.Sleep(ms);
Random random = new Random();
int n = random.Next(10000);
Console.WriteLine("任務(wù)完成");
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屬性來判斷異步調(diào)用是否完成
class Program
{
private delegate int NewTaskDelegate(int ms);
private static int newTask(int ms)
{
Console.WriteLine("任務(wù)開始");
Thread.Sleep(ms);
Random random = new Random();
int n = random.Next(10000);
Console.WriteLine("任務(wù)完成");
return n;
}
static void Main(string[] args)
{
NewTaskDelegate task = newTask;
IAsyncResult asyncResult = task.BeginInvoke(2000, null, null);
//等待異步執(zhí)行完成
while (!asyncResult.IsCompleted)
{
Console.Write("*");
Thread.Sleep(100);
}
// 由于異步調(diào)用已經(jīng)完成，因此， EndInvoke會立刻返回結(jié)果
int result = task.EndInvoke(asyncResult);
Console.WriteLine(result);
Console.Read();
}
}
3、使用WaitOne方法等待異步方法執(zhí)行完成
WaitOne的第一個參數(shù)表示要等待的毫秒數(shù)，在指定時間之內(nèi)，WaitOne方法將一直等待，直到異步調(diào)用完成，并發(fā)出通知，WaitOne方法才返回true。當(dāng)?shù)却付〞r間之后，異步調(diào)用仍未完成，WaitOne方法返回false，如果指定時間為0，表示不等待，如果為-1，表示永遠(yuǎn)等待，直到異步調(diào)用完成。
class Program
{
private delegate int NewTaskDelegate(int ms);
private static int newTask(int ms)
{
Console.WriteLine("任務(wù)開始");
Thread.Sleep(ms);
Random random = new Random();
int n = random.Next(10000);
Console.WriteLine("任務(wù)完成");
return n;
}
static void Main(string[] args)
{
NewTaskDelegate task = newTask;
IAsyncResult asyncResult = task.BeginInvoke(2000, null, null);
//等待異步執(zhí)行完成
while (!asyncResult.AsyncWaitHandle.WaitOne(100, false))
{
Console.Write("*");
}
int result = task.EndInvoke(asyncResult);
Console.WriteLine(result);
Console.Read();
}
}
4、使用回調(diào)方式返回結(jié)果
要注意的是“my.BeginInvoke(3,300, MethodCompleted, my)”，BeginInvoke方法的參數(shù)傳遞方式：
前面一部分(3,300)是其委托本身的參數(shù)。
倒數(shù)第二個參數(shù)(MethodCompleted)是回調(diào)方法委托類型，他是回調(diào)方法的委托，此委托沒有返回值，有一個IAsyncResult類型的參數(shù)，當(dāng)method方法執(zhí)行完后，系統(tǒng)會自動調(diào)用MethodCompleted方法。
最后一個參數(shù)(my)需要向MethodCompleted方法中傳遞一些值，一般可以傳遞被調(diào)用方法的委托，這個值可以使用IAsyncResult.AsyncState屬性獲得。
class Program
{
private delegate int MyMethod(int second, int millisecond);
//線程執(zhí)行方法
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);
}
//回調(diào)方法
private static void MethodCompleted(IAsyncResult asyncResult)
{
if (asyncResult == null || asyncResult.AsyncState == null)
{
Console.WriteLine("回調(diào)失?。。?！");
return;
}
int result = (asyncResult.AsyncState as MyMethod).EndInvoke(asyncResult);
Console.WriteLine("任務(wù)完成，結(jié)果：" + result);
}
static void Main(string[] args)
{
MyMethod my = method;
IAsyncResult asyncResult = my.BeginInvoke(3,300, MethodCompleted, my);
Console.WriteLine("任務(wù)開始");
Console.Read();
}
}
5、其他組件的BeginXXX和EndXXX方法
在其他的.net組件中也有類似BeginInvoke和EndInvoke的方法，如System.Net.HttpWebRequest類的BeginGetResponse和EndGetResponse方法。其使用方法類似于委托類型的BeginInvoke和EndInvoke方法，例如：
class Program
{
//回調(diào)函數(shù)
private static void requestCompleted(IAsyncResult asyncResult)
{
if (asyncResult == null || asyncResult.AsyncState==null)
{
Console.WriteLine("回調(diào)失敗");
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("任務(wù)開始");
Console.Read();
}
}
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了如何基于WPF制作一個可編程畫板，文中的示例代碼講解詳細(xì)，對我們學(xué)習(xí)或工作有一定幫助，感興趣的小伙伴可以了解一下2023-05-05
C# 委托中 Invoke/BeginInvoke/EndInvoke和DynamicInvoke&
在C#中,委托（Delegate）提供了多種調(diào)用方式,包括 Invoke、BeginInvoke、EndInvoke 和 DynamicInvoke,每種調(diào)用方式都有其特定的用途和適用場景,下面將詳細(xì)介紹這些方法的區(qū)別與聯(lián)系,感興趣的朋友一起看看吧2025-03-03
這篇文章主要介紹了設(shè)計模式編程中C#對于組合模式的運用,理論上來說組合模式包含抽象構(gòu)件、樹葉構(gòu)件和樹枝構(gòu)件三個角色,需要的朋友可以參考下2016-02-02
刪除文件夾，參數(shù)文件夾路徑2009-07-07
C#中的GetField是一個反射方法,用于獲取指定類型的字段信息,它可以通過字段名稱來獲取字段對象,并且可以在運行時動態(tài)地訪問和操作這些字段,本文給大家介紹了C# GetField方法的應(yīng)用,需要的朋友可以參考下2024-04-04
這篇文章主要介紹了C#中Socket通信用法,以實例形式較為詳細(xì)的分析了UDP及TCP兩種通信方式的具體實現(xiàn)技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-09-09
首先用c#創(chuàng)建一個web service，主要是利用其WSDL的功能，當(dāng)然也可以利用php創(chuàng)建一個，道理都是一樣的2008-12-12
在解析xml時，經(jīng)常因為文件中含特殊字符而解析失敗。原因有兩個：一是內(nèi)容中含有XML預(yù)定義好的實體，二是內(nèi)容中含有低位非打印字符2014-08-08
這篇文章主要為大家詳細(xì)介紹了C#實現(xiàn)控制臺飛行棋小游戲，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下的相關(guān)資料2021-07-07
這篇文章介紹了C#內(nèi)置泛型委托之Func委托的用法，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03