CSharp 使用委托實現的同步調用,異步調用,異步回調


CSharp 使用委托實現的同步調用,異步調用,異步回調


下面我們將通過代碼的例子來描述,同步調用,異步調用,異步回調的應用場景.

public delegate int AddHandler(int a,int b) public class AddClass {

	public ststic int AddFanc(int a,int b) {
		Console.WriteLine($"開始計算:{a}+{b}");
		Thread.Sleep(3000);  //假定此方法是一個耗時方法
		Console.WriteLine("計算完成");
	}
}

同步調用

解釋:
委托的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();
 	}
}

我們可以觀察到主線程被阻塞了3秒,如果我們要進行一項繁重的操作,使用同步調用的方式,來調用耗時方法,將會造成很嚴重的性能問題,比如頁面卡死等,這個時候就有必要使用到異步調用的概念了.

異步調用

異步調用不會阻塞線程,而是把調用塞到線程池中,程序主線程或UI線程可以繼續向下執行,
委托的異步調用是通過BeginInvoke和EndInvoke來實現的.

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)=>
{ 
   //耗時方法體
   Thread.Sleep(3000);
   return true;
};

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

異步回調

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

示例代碼如下:

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);
	 }
 
}

異步回調總結

  • int result = handler.Invoke(1,2);為什么Invoke的參數和返回值和AddHandler委托是一樣的呢?

答:Invoke方法的參數很簡單,一個委托,一個參數表(可選),而Invoke方法的主要功能就是幫助你在UI線程上調用委托所指定的方法。Invoke方法首先檢查發出調用的線程(即當前線 程)是不是UI線程,如果是,直接執行委托指向的方法,如果不是,它將切換到UI線程,然 后執行委托指向的方法。不管當前線程是不是UI線程,Invoke都阻塞直到委托指向的方法執行完畢,然后切換回發出調用的線程(如果需要的話),返回。所以Invoke方法的參數和返回值和調用他的委托應該是一致的。

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

答:BeginInvoke : 開始一個異步的請求,調用線程池中一個線程來執行,返回IAsyncResult 對象(異步的核心). IAsyncResult 簡單的說,他存儲異步操作的狀態信息的一個接口,也可以用他來結束當前異步。注意: BeginInvoke和EndInvoke必須成對調用.即使不需要返回值,但EndInvoke還是必須調用,否則可能會造成內存泄漏。

  • IAsyncResult.AsyncState 屬性:
    獲取用戶定義的對象,它限定或包含關於異步操作的信息,例如:
static void AddComplete(IAsyncResult result) { 
	AddHandler handler = (AddHandler)result.AsyncState; 
	Console.WriteLine(handler.EndInvoke(result)); 
}

如果需要更進一步的了解,可參考:
C#基礎:線程之前的異步調用(委托方式)
使用回調從一個線程中檢索數據


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM