C#實現(xiàn)異步編程的方法
最近在我參與的幾個.Net項目中都有用到異步編程,作為一名.Net小白,很有必要好好地學習一下C#異步編程。
什么是異步
異步指的就是不用阻塞當前線程來等待任務的完成,而是將任務扔到線程池中去執(zhí)行,當前線程可以繼續(xù)向下執(zhí)行,直至其它線程將任務完成,并回調通知當前線程。整個任務從開始到結束都是異步完成的,不會阻塞當前線程。因此,異步很重要的一點就是,不會阻塞當前線程。
實現(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> /// 結束執(zhí)行異步操作,并且返回異步操作結果. /// </summary> /// <param name="result"></param> /// <returns>委托方法的返回類型</returns> string EndInvoke(IAsyncResult result);
下面就通過一段代碼來具體實現(xiàn)異步編程
/// <summary> /// 定義一個委托類型 /// </summary> public delegate string Del(); /// <summary> /// 任務類 /// </summary> public class TaskClass { public static string SleepTask() { Console.WriteLine("異步線程(ThreadId = {0})開始執(zhí)行睡眠任務,睡眠3s.\n", Thread.CurrentThread.ManagedThreadId); Thread.Sleep(3000); Console.WriteLine("異步線程(ThreadId = {0})蘇醒,睡眠任務執(zhí)行結束.\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})調用BeginInvoke()方法執(zhí)行異步任務.\n", Thread.CurrentThread.ManagedThreadId); //開始執(zhí)行異步操作,TaskClass.SleepTask無參數(shù),Callback為定義的回調方法. del.BeginInvoke(Callback, null); Console.WriteLine("主線程(ThreadId = {0})繼續(xù)執(zhí)行.\n", Thread.CurrentThread.ManagedThreadId); Thread.Sleep(5000); //輸出異步任務返回的結果 Console.WriteLine(result); Console.WriteLine("主線程(ThreadId = {0})執(zhí)行結束.\n", Thread.CurrentThread.ManagedThreadId); } /// <summary> /// 回調方法 /// </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("回調方法中調用EndInvoke()方法,獲取異步任務結果.\n", Thread.CurrentThread.ManagedThreadId); //結束執(zhí)行異步操作,并返回異步任務結果. result = del.EndInvoke(ar); } }
運行結果:
從運行結果中,我們可以發(fā)現(xiàn)主線程在調用了BeginInvoke()方法后,沒有阻塞,而是繼續(xù)向下執(zhí)行,而且任務也確實由一個新的線程來執(zhí)行,任務執(zhí)行結束后,調用回調方法,在回調方法中調用EndInvoke()方法來獲取任務執(zhí)行結果。
總結
1. 在異步編程中,當前線程是不會被阻塞的。
2. C#的委托機制可以很方便地實現(xiàn)異步編程。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
C#在Windows窗體控件實現(xiàn)內容拖放(DragDrop)功能
這篇文章介紹了C#在Windows窗體控件實現(xiàn)內容拖放(DragDrop)的功能,文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-05-05