C#實現(xiàn)異步編程的方法

更新時間：2017年07月31日 15:16:44 作者：SmartMonkey

這篇文章主要為大家詳細(xì)介紹了C#實現(xiàn)異步編程的方法，什么是異步，如何實現(xiàn)異步編程，感興趣的小伙伴們可以參考一下

最近在我參與的幾個.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í)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: