【轉】委託的三種調用示例(同步調用 異步調用 異步回調)

本文將主要經過同步調用、異步調用、異步回調三個示例來說解在用委託執行同一個加法類的時候的的區別和利弊。異步

首先,經過代碼定義一個委託和下面三個示例將要調用的方法:函數

 1 public delegate int AddHandler(int a,int b);
 2     public class 加法類
 3     {
 4         public static int Add(int a, int b)
 5         {
 6             Console.WriteLine("開始計算:" + a + "+" + b);
 7             Thread.Sleep(3000); //模擬該方法運行三秒
 8             Console.WriteLine("計算完成!");
 9             return a + b;
10         }
11     }

1、同步調用spa

委託的Invoke方法用來進行同步調用。同步調用也能夠叫阻塞調用,它將阻塞當前線程,而後執行調用,調用完畢後再繼續向下進行。線程

public class 同步調用
{
        static void Main()
        {
            Console.WriteLine("===== 同步調用 SyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            int result = handler.Invoke(1, 2);
            Console.WriteLine("繼續作別的事情。。。");
            Console.WriteLine(result);
            Console.ReadKey();
        }      
}

同步調用會阻塞線程,若是是要調用一項繁重的工做(如大量IO操做),可能會讓程序停頓很長時間,形成糟糕的用戶體驗,這時候異步調用就頗有必要了。code

 

2、異步調用對象

異步調用不阻塞線程,而是把調用塞到線程池中,程序主線程或UI線程能夠繼續執行。委託的異步調用經過BeginInvoke和EndInvoke來實現。blog

public class 異步調用
{
        static void Main()
        {
            Console.WriteLine("===== 異步調用 AsyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            //IAsyncResult: 異步操做接口(interface)
            //BeginInvoke: 委託(delegate)的一個異步方法的開始
            IAsyncResult result = handler.BeginInvoke(1, 2, null, null);
            Console.WriteLine("繼續作別的事情。。。");
            //異步操做返回
            Console.WriteLine(handler.EndInvoke(result));
            Console.ReadKey();
        }
}

能夠看到,主線程並無等待,而是直接向下運行了。可是問題依然存在,當主線程運行到EndInvoke時,若是這時調用沒有結束(這種狀況極可能出現),這時爲了等待調用結果,線程依舊會被阻塞。接口

異步委託,也能夠參考以下寫法:內存

Action<object> action=(obj)=>method(obj);回調函數

action.BeginInvoke(obj,ar=>action.EndInvoke(ar),null);

簡簡單單兩句話就能夠完成一部操做。

 

3、異步回調

用回調函數,當調用結束時會自動調用回調函數,解決了爲等待調用結果,而讓線程依舊被阻塞的局面。

public class 異步回調
{
        static void Main()
        {
            Console.WriteLine("===== 異步回調 AsyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            //異步操做接口(注意BeginInvoke方法的不一樣!)
            IAsyncResult result = handler.BeginInvoke(1,2,new AsyncCallback(回調函數),"AsycState:OK");
            Console.WriteLine("繼續作別的事情。。。");
            Console.ReadKey();
        }
        static void 回調函數(IAsyncResult result)
        {     
             //result 是「加法類.Add()方法」的返回值
            //AsyncResult 是IAsyncResult接口的一個實現類,空間:System.Runtime.Remoting.Messaging
            //AsyncDelegate 屬性能夠強制轉換爲用戶定義的委託的實際類。
            AddHandler handler = (AddHandler)((AsyncResult)result).AsyncDelegate;
            Console.WriteLine(handler.EndInvoke(result));
            Console.WriteLine(result.AsyncState);
        }
}

我定義的委託的類型爲AddHandler,則爲了訪問 AddHandler.EndInvoke,必須將異步委託強制轉換爲 AddHandler。能夠在異步回調函數(類型爲 AsyncCallback)中調用 MAddHandler.EndInvoke,以獲取最初提交的 AddHandler.BeginInvoke 的結果。

 

4、問題

(1)int result = handler.Invoke(1,2);

爲何Invoke的參數和返回值和AddHandler委託是同樣的呢?

答:Invoke方法的參數很簡單,一個委託,一個參數表(可選),而Invoke方法的主要功能就是幫助你在UI線程上調用委託所指定的方法。Invoke方法首先檢查發出調用的線程(即當前線程)是否是UI線程,若是是,直接執行委託指向的方法,若是不是,它將切換到UI線程,而後執行委託指向的方法。無論當前線程是否是UI線程,Invoke都阻塞直到委託指向的方法執行完畢,而後切換回發出調用的線程(若是須要的話),返回。

因此Invoke方法的參數和返回值和調用他的委託應該是一致的。

(2)IAsyncResult result = handler.BeginInvoke(1,2,null,null);

BeginInvoke : 開始一個異步的請求,調用線程池中一個線程來執行,

返回IAsyncResult 對象(異步的核心). IAsyncResult 簡單的說,他存儲異步操做的狀態信息的一個接口,也能夠用他來結束當前異步。

注意: BeginInvoke和EndInvoke必須成對調用.即便不須要返回值,但EndInvoke仍是必須調用,不然可能會形成內存泄漏。

(3)IAsyncResult.AsyncState 屬性:

獲取用戶定義的對象,它限定或包含關於異步操做的信息。 例如:

static void AddComplete(IAsyncResult result)
{  
      AddHandler handler = (AddHandler)result.AsyncState;   
      Console.WriteLine(handler.EndInvoke(result));
}

完整代碼以下:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Runtime.Remoting.Messaging;
namespace ConsoleTest
{
    public delegate int AddHandler(int a,int b);
    public class 加法類
    {
        public static int Add(int a, int b)
        {
            Console.WriteLine("開始計算:" + a + "+" + b);
            Thread.Sleep(3000); //模擬該方法運行三秒
            Console.WriteLine("計算完成!");
            return a + b;
       }
    }

    public class 同步調用
    {
       static void Main()
        {
            Console.WriteLine("===== 同步調用 SyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            int result = handler.Invoke(1, 2);

            Console.WriteLine("繼續作別的事情。。。");
            Console.WriteLine(result);
            Console.ReadKey();
        }
    } 
    public class 異步調用
    {
        static void Main()
        {
            Console.WriteLine("===== 異步調用 AsyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            //IAsyncResult: 異步操做接口(interface)
            //BeginInvoke: 委託(delegate)的一個異步方法的開始
            IAsyncResult result = handler.BeginInvoke(1, 2, null, null);
            Console.WriteLine("繼續作別的事情。。。");
            //異步操做返回
            Console.WriteLine(handler.EndInvoke(result));
            Console.ReadKey();
        }
    }
    public class 異步回調
    {
        static void Main()
        {
            Console.WriteLine("===== 異步回調 AsyncInvokeTest =====");
            AddHandler handler = new AddHandler(加法類.Add);
            //異步操做接口(注意BeginInvoke方法的不一樣!)
            IAsyncResult result = handler.BeginInvoke(1,2,new AsyncCallback(回調函數),"AsycState:OK");
            Console.WriteLine("繼續作別的事情。。。");
            Console.ReadKey();
        } 
        static void 回調函數(IAsyncResult result)
        {     
             //result 是「加法類.Add()方法」的返回值
            //AsyncResult 是IAsyncResult接口的一個實現類,引用空間:System.Runtime.Remoting.Messaging
            //AsyncDelegate 屬性能夠強制轉換爲用戶定義的委託的實際類。
            AddHandler handler = (AddHandler)((AsyncResult)result).AsyncDelegate;
            Console.WriteLine(handler.EndInvoke(result));
            Console.WriteLine(result.AsyncState);
        }
    }
}
相關文章
相關標籤/搜索