最近在我參與的幾個.Net項目中都有用到異步編程,作為一名.Net小白,很有必要好好地學(xué)習(xí)一下C#異步編程。
什么是異步
異步指的就是不用阻塞當(dāng)前線程來等待任務(wù)的完成,而是將任務(wù)扔到線程池中去執(zhí)行,當(dāng)前線程可以繼續(xù)向下執(zhí)行,直至其它線程將任務(wù)完成,并回調(diào)通知當(dāng)前線程。整個任務(wù)從開始到結(jié)束都是異步完成的,不會阻塞當(dāng)前線程。因此,異步很重要的一點就是,不會阻塞當(dāng)前線程。
實現(xiàn)異步編程
在C#語言中,主要是通過委托來實現(xiàn)異步編程的,在委托類型中定義了兩個方法BeginInvoke()和EndInvoke()。
/// <summary>/// 開始執(zhí)行異步操作./// </summary>/// <param name="param">委托方法的參數(shù)</param>/// <param name="callback"></param>/// <param name="object"></param>/// <returns></returns>IAsyncResult BeginInvoke(int param, AsyncCallback callback, Object @object);/// <summary>/// 結(jié)束執(zhí)行異步操作,并且返回異步操作結(jié)果./// </summary>/// <param name="result"></param>/// <returns>委托方法的返回類型</returns>string EndInvoke(IAsyncResult result);
下面就通過一段代碼來具體實現(xiàn)異步編程
/// <summary>/// 定義一個委托類型/// </summary>public delegate string Del();/// <summary>/// 任務(wù)類/// </summary>public class TaskClass{  public static string SleepTask()  {    Console.WriteLine("異步線程(ThreadId = {0})開始執(zhí)行睡眠任務(wù),睡眠3s./n", Thread.CurrentThread.ManagedThreadId);    Thread.Sleep(3000);    Console.WriteLine("異步線程(ThreadId = {0})蘇醒,睡眠任務(wù)執(zhí)行結(jié)束./n", Thread.CurrentThread.ManagedThreadId);    return "異步線程執(zhí)行成功./n";  }}  /// <summary>/// 異步編程實現(xiàn)類(主線程不會阻塞)/// </summary>public class AsynCallbackClass{  public static string result;  public static void Main(string[] args)  {    Console.WriteLine("主線程(ThreadId = {0})開始執(zhí)行./n", Thread.CurrentThread.ManagedThreadId);    Del del = new Del(TaskClass.SleepTask);    Console.WriteLine("主線程(ThreadId = {0})調(diào)用BeginInvoke()方法執(zhí)行異步任務(wù)./n", Thread.CurrentThread.ManagedThreadId);    //開始執(zhí)行異步操作,TaskClass.SleepTask無參數(shù),Callback為定義的回調(diào)方法.    del.BeginInvoke(Callback, null);    Console.WriteLine("主線程(ThreadId = {0})繼續(xù)執(zhí)行./n", Thread.CurrentThread.ManagedThreadId);    Thread.Sleep(5000);    //輸出異步任務(wù)返回的結(jié)果    Console.WriteLine(result);    Console.WriteLine("主線程(ThreadId = {0})執(zhí)行結(jié)束./n", Thread.CurrentThread.ManagedThreadId);  }  /// <summary>  /// 回調(diào)方法  /// </summary>  /// <param name="ar"></param>  public static void Callback(IAsyncResult ar)  {    AsyncResult asyncResult = ar as AsyncResult;    if (asyncResult == null) { return; }    Del del = asyncResult.AsyncDelegate as Del;    if (del == null) { return; }    Console.WriteLine("回調(diào)方法中調(diào)用EndInvoke()方法,獲取異步任務(wù)結(jié)果./n", Thread.CurrentThread.ManagedThreadId);        //結(jié)束執(zhí)行異步操作,并返回異步任務(wù)結(jié)果.    result = del.EndInvoke(ar);  }}運行結(jié)果:

從運行結(jié)果中,我們可以發(fā)現(xiàn)主線程在調(diào)用了BeginInvoke()方法后,沒有阻塞,而是繼續(xù)向下執(zhí)行,而且任務(wù)也確實由一個新的線程來執(zhí)行,任務(wù)執(zhí)行結(jié)束后,調(diào)用回調(diào)方法,在回調(diào)方法中調(diào)用EndInvoke()方法來獲取任務(wù)執(zhí)行結(jié)果。
總結(jié)
1. 在異步編程中,當(dāng)前線程是不會被阻塞的。
2. C#的委托機制可以很方便地實現(xiàn)異步編程。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持武林網(wǎng)。
新聞熱點
疑難解答
圖片精選