[转载]C#异步委托的用法 .
??????? BeginInvoke方法，調(diào)用后立即返回，不等待調(diào)用結(jié)果。EndInvoke方法，用于檢索調(diào)用結(jié)果。調(diào)用BeginInvoke后可隨時(shí)調(diào)用 EndInvoke 方法；如果異步調(diào)用未完成，EndInvoke 將一直阻塞到異步調(diào)用完成。EndInvoke 的參數(shù)包括您需要異步執(zhí)行的方法的 out 和 ref 參數(shù)（在 Visual Basic 中為 <Out> ByRef 和 ByRef）以及由 BeginInvoke 返回的 IAsyncResult
??????? BeginInvoke 異步方法簽名的規(guī)則是：
- 包括所有 IN 參數(shù)。
- 包括所有 OUT 參數(shù)。
- 包括所有 IN/OUT 參數(shù)。
- 包括所有 ByRef 參數(shù)。
- 將 AsyncCallback 和 AsyncState（可通過 IAsyncResult 接口的 AsyncState 屬性獲得）作為最后兩個(gè)參數(shù)。
- 返回 IAsyncResult。
??????? EndInvoke 異步方法簽名的規(guī)則是：
- 包括所有 IN/OUT 參數(shù)。
- 包括所有 OUT 參數(shù)。
- 包括所有 ByRef 參數(shù)。
- 將 IAsyncResult 作為最后一個(gè)參數(shù)。
- 從原始方法簽名返回原始返回類型。
??????? 結(jié)果對(duì)象 (IAsyncResult) 是從開始操作返回的，并且可用于獲取有關(guān)異步開始操作是否已完成的狀態(tài)。結(jié)果對(duì)象被傳遞到結(jié)束操作，該操作返回調(diào)用的最終返回值。在開始操作中可以提供可選的回調(diào)。如果提供回調(diào)，在調(diào)用結(jié)束后，將調(diào)用該回調(diào)；并且回調(diào)中的代碼可以調(diào)用結(jié)束操作。
AsyncCallback 委托
??????? AsyncCallback 委托用于指定在開始操作完成后應(yīng)被調(diào)用的方法。下面是該委托的簽名，AsyncCallback 委托被作為開始操作上的第二個(gè)到最后一個(gè)參數(shù)傳遞：
??????? public delegate void AsyncCallback(IAsyncResult ar);IAsyncResult 接口??????? IAsyncResult 接口用于監(jiān)視和管理異步操作。該接口是從開始操作返回的并被傳遞到結(jié)束操作，以將開始操作和結(jié)束操作相關(guān)聯(lián)。如果回調(diào)被指定為開始操作的一部分，則 AsyncResult 被傳遞到回調(diào)。以下代碼闡釋有關(guān) IAsyncResult 接口的屬性，該接口可用于監(jiān)視異步操作的狀態(tài)并獲取還可被傳遞到開始操作中的異步狀態(tài)對(duì)象：
public interface IAsyncResult
{
? Object AsyncState { get; }?????????????????????? //該屬性為BeginInvoke參數(shù)中的最后一個(gè)參數(shù)對(duì)象
? WaitHandle AsyncWaitHandle { get; }
? bool CompletedSynchronously { get; }
? bool IsCompleted { get; }???????????????????????? //該屬性判斷異步調(diào)用是否結(jié)束
}
- AsyncState
??????? 返回在開始操作方法調(diào)用中作為最后一個(gè)參數(shù)提供的對(duì)象。
- AsyncWaitHandle
??????? AsyncWaitHandle 屬性返回 WaitHandle，后者可用于執(zhí)行 WaitHandle.WaitOne、WaitAny 或 WaitAll。
??????? 注意???直到 AsyncWaitHandle 屬性被讀取時(shí)，實(shí)現(xiàn) IAsyncResult 的對(duì)象才需要?jiǎng)?chuàng)建 WaitHandle；執(zhí)行時(shí)間由實(shí)施者決定。如果實(shí)施者創(chuàng)建了 WaitHandle，則實(shí)施者需要負(fù)責(zé)在適當(dāng)?shù)臅r(shí)候發(fā)出 WaitHandle 信號(hào)終止等待。例如，當(dāng)異步調(diào)用的方法返回時(shí)，AsyncResult 將代表調(diào)用方終止等待。創(chuàng)建后，WaitHandle 應(yīng)保持活動(dòng)狀態(tài)，直到用戶調(diào)用結(jié)束異步操作的方法。此時(shí)，可以丟棄 AsyncWaitHandle 后的對(duì)象。
- CompletedSynchronously
??????? 如果開始操作調(diào)用已同步完成，則 CompletedSynchronously 屬性將被設(shè)置為 true。
- IsCompleted
??????? 在服務(wù)器已處理完調(diào)用后，IsCompleted 屬性將被設(shè)置為 true。
??????? 調(diào)用了 BeginInvoke 后，可以：
- 進(jìn)行某些操作，然后調(diào)用 EndInvoke 一直阻塞到調(diào)用完成。
- 使用 IAsyncResult.AsyncWaitHandle 獲取 WaitHandle，使用它的 WaitOne 方法將執(zhí)行一直阻塞到發(fā)出 WaitHandle 信號(hào)，然后調(diào)用 EndInvoke。
- 輪詢由 BeginInvoke 返回的 IAsyncResult，確定異步調(diào)用何時(shí)完成，然后調(diào)用 EndInvoke。
- 將用于回調(diào)方法的委托傳遞給 BeginInvoke。該方法在異步調(diào)用完成后在 ThreadPool 線程上執(zhí)行，它可以調(diào)用 EndInvoke。
??????? 注：?始終在異步調(diào)用完成后調(diào)用 EndInvoke。
??????? 以下是關(guān)于異步委托的測(cè)試代碼：
using System;
using System.Threading;
?
public class AsyncDemo {
??? // The method to be executed asynchronously.
??? //
??? public string TestMethod(int callDuration, out int threadId) {
??????? Console.WriteLine("Test method begins.");
??????? Thread.Sleep(callDuration);
??????? threadId = AppDomain.GetCurrentThreadId();
??????? return "MyCallTime was " + callDuration.ToString();
??? }
}
?
// The delegate must have the same signature as the method
// you want to call asynchronously.
public delegate string AsyncDelegate(int callDuration, out int threadId);
?
public class AsyncMain {
??? static void Main(string[] args) {
??????? // The asynchronous method puts the thread id here.
??????? int threadId;
?
??????? // Create an instance of the test class.
??????? AsyncDemo ad = new AsyncDemo();
?
??????? // Create the delegate.
??????? AsyncDelegate dlgt = new AsyncDelegate(ad.TestMethod);
??
??????? // Initiate the asychronous call.
??????? IAsyncResult ar = dlgt.BeginInvoke(3000,
??????????? out threadId, null, null);
?
??????? Thread.Sleep(0);
??????? Console.WriteLine("Main thread {0} does some work.",
??????????? AppDomain.GetCurrentThreadId());
?
??????? // Wait for the WaitHandle to become signaled.
??????? ar.AsyncWaitHandle.WaitOne();
/*??????????????
這個(gè)是輪詢異步執(zhí)行狀態(tài)
??????? // Poll while simulating work.
??????? while(ar.IsCompleted == false)
??????? {
??????????? Thread.Sleep(10);
??????? }
*/
??????? // Call EndInvoke to Wait for the asynchronous call to complete,
??????? // and to retrieve the results.
??????? string ret = dlgt.EndInvoke(out threadId, ar);
?
??????? Console.WriteLine("The call executed on thread {0}, with return value \"{1}\".", threadId, ret);
??? }
}
?
??????? 以下代碼是用回調(diào)函數(shù)執(zhí)行EndInvoke方法
public class AsyncMain {
??? // Asynchronous method puts the thread id here.
??? private static int threadId;
?
??? static void Main(string[] args) {
??????? // Create an instance of the test class.
??????? AsyncDemo ad = new AsyncDemo();
?
??????? // Create the delegate.
??????? AsyncDelegate dlgt = new AsyncDelegate(ad.TestMethod);
??
??????? // Initiate the asychronous call.? Include an AsyncCallback
??????? // delegate representing the callback method, and the data
??????? // needed to call EndInvoke.
??????? IAsyncResult ar = dlgt.BeginInvoke(3000,
??????????? out threadId,
??????????? new AsyncCallback(CallbackMethod),
??????????? dlgt );
?
??????? Console.WriteLine("Press Enter to close application.");
??????? Console.ReadLine();
??? }
???
????????
??? // Callback method must have the same signature as the
??? // AsyncCallback delegate.
??? static void CallbackMethod(IAsyncResult ar) {
??????? // Retrieve the delegate.
??????? AsyncDelegate dlgt = (AsyncDelegate) ar.AsyncState;
?
??????? // Call EndInvoke to retrieve the results.
??????? string ret = dlgt.EndInvoke(out threadId, ar);
?
??????? Console.WriteLine("The call executed on thread {0}, with return value \"{1}\".", threadId, ret);
??? }
}
-----------------------------------------------------------------------
?
當(dāng)進(jìn)行耗時(shí)的工作時(shí)，可以使用異步委托執(zhí)行。
view sourceprint?| using System; |
| using System.Collections.Generic; |
| using System.Linq; |
| using System.Text; |
| using System.Runtime.Remoting.Messaging; |
| ?? |
| namespace 線程 |
| { |
| ????class Program |
| ????{ |
| ????????delegate int facHandler(int n); |
| ????????static int Fac(int n) |
| ????????{ |
| ????????????if (n == 1) |
| ????????????????return 1;???????????? |
| ????????????System.Threading.Thread.Sleep(100);??????????? |
| ????????????return Fac(n - 1) * n; |
| ????????} |
| ?? |
| ????????static void callBack(IAsyncResult result) |
| ????????{ |
| ????????????//result是Fac()的返回值???????????? |
| ????????????//將AsyncDelegate強(qiáng)制轉(zhuǎn)換為用戶定義的委托。 |
| ????????????facHandler handler = (facHandler)((AsyncResult)result).AsyncDelegate; |
| ????????????Console.WriteLine("結(jié)果：" + handler.EndInvoke(result)); |
| ????????????Console.WriteLine(result.AsyncState); |
| ????????} |
| ?? |
| ????????static void Main(string[] args) |
| ????????{ |
| ????????????facHandler f = new facHandler(Fac); |
| ????????????//開異步方法開始執(zhí)行 |
| ????????????IAsyncResult result = f.BeginInvoke(10, new AsyncCallback(callBack), "計(jì)算結(jié)束"); |
| ????????????Console.WriteLine("做其他事情先……"); |
| ????????????Console.Read(); |
| ????????} |
| ????} |
| } |
?
C#委托的異步調(diào)用
本文將主要通過“同步調(diào)用”、“異步調(diào)用”、“異步回調(diào)”三個(gè)示例來講解在用委托執(zhí)行同一個(gè)“加法類”的時(shí)候的的區(qū)別和利弊。
首先，通過代碼定義一個(gè)委托和下面三個(gè)示例將要調(diào)用的方法：
/*添加的命名空間using?System.Threading;
using?System.Runtime.Remoting.Messaging;
*/
??? public?delegate?int?AddHandler(int?a,int?b);
????public?class?加法類
????{
????????public?static?int?Add(int?a,?int?b)
????????{
????????????Console.WriteLine("開始計(jì)算："?+?a?+?"+"?+?b);
????????????Thread.Sleep(3000);?//模擬該方法運(yùn)行三秒
????????????Console.WriteLine("計(jì)算完成！");
????????????return?a?+?b;
????????}
????}
?
?
同步調(diào)用
委托的Invoke方法用來進(jìn)行同步調(diào)用。同步調(diào)用也可以叫阻塞調(diào)用，它將阻塞當(dāng)前線程，然后執(zhí)行調(diào)用，調(diào)用完畢后再繼續(xù)向下進(jìn)行。
public?class?同步調(diào)用{
????????static?void?Main()
????????{
????????????Console.WriteLine("=====?同步調(diào)用?SyncInvokeTest?=====");
????????????AddHandler?handler?=?new?AddHandler(加法類.Add);
????????????int?result?=?handler.Invoke(1,?2);
????????????Console.WriteLine("繼續(xù)做別的事情。。。");
????????????Console.WriteLine(result);
????????????Console.ReadKey();
????????}
????????/*運(yùn)行結(jié)果：
?????????=====?同步調(diào)用?SyncInvokeTest?=====
?????????開始計(jì)算：1+2
?????????計(jì)算完成！
?????????繼續(xù)做別的事情。。。
?????????3???????*/
}
同步調(diào)用會(huì)阻塞線程，如果是要調(diào)用一項(xiàng)繁重的工作（如大量IO操作），可能會(huì)讓程序停頓很長時(shí)間，造成糟糕的用戶體驗(yàn)，這時(shí)候異步調(diào)用就很有必要了。
?
異步調(diào)用
異步調(diào)用不阻塞線程，而是把調(diào)用塞到線程池中，程序主線程或UI線程可以繼續(xù)執(zhí)行。
委托的異步調(diào)用通過BeginInvoke和EndInvoke來實(shí)現(xiàn)。
{
????????static?void?Main()
????????{
????????????Console.WriteLine("=====?異步調(diào)用?AsyncInvokeTest?=====");
????????????AddHandler?handler?=?new?AddHandler(加法類.Add);
????????????//IAsyncResult:?異步操作接口(interface)
????????????//BeginInvoke:?委托(delegate)的一個(gè)異步方法的開始
????????????IAsyncResult?result?=?handler.BeginInvoke(1,?2,?null,?null);
????????????Console.WriteLine("繼續(xù)做別的事情。。。");
????????????//異步操作返回
????????????Console.WriteLine(handler.EndInvoke(result));
????????????Console.ReadKey();
????????}
????????/*運(yùn)行結(jié)果：
?????????=====?異步調(diào)用?AsyncInvokeTest?=====
?????????繼續(xù)做別的事情。。。
?????????開始計(jì)算：1+2
?????????計(jì)算完成！
?????????3???????*/
}
可以看到，主線程并沒有等待，而是直接向下運(yùn)行了。
但是問題依然存在，當(dāng)主線程運(yùn)行到EndInvoke時(shí)，如果這時(shí)調(diào)用沒有結(jié)束（這種情況很可能出現(xiàn)），這時(shí)為了等待調(diào)用結(jié)果，線程依舊會(huì)被阻塞。
?異步委托，也可以參考如下寫法：
Action<object>?action=(obj)=>method(obj);action.BeginInvoke(obj,ar=>action.EndInvoke(ar),null);
簡(jiǎn)簡(jiǎn)單單兩句話就可以完成一部操作。
?
異步回調(diào)
用回調(diào)函數(shù)，當(dāng)調(diào)用結(jié)束時(shí)會(huì)自動(dòng)調(diào)用回調(diào)函數(shù)，解決了為等待調(diào)用結(jié)果，而讓線程依舊被阻塞的局面。
public?class?異步回調(diào){
????????static?void?Main()
????????{
????????????Console.WriteLine("=====?異步回調(diào)?AsyncInvokeTest?=====");
????????????AddHandler?handler?=?new?AddHandler(加法類.Add);
????????????//異步操作接口(注意BeginInvoke方法的不同！)
????????????IAsyncResult?result?=?handler.BeginInvoke(1,2,new?AsyncCallback(回調(diào)函數(shù)),"AsycState:OK");
????????????
????????????Console.WriteLine("繼續(xù)做別的事情。。。");
????????????Console.ReadKey();
????????}
????????static?void?回調(diào)函數(shù)(IAsyncResult?result)
????????{??????//result?是“加法類.Add()方法”的返回值
????????????//AsyncResult?是IAsyncResult接口的一個(gè)實(shí)現(xiàn)類，空間：System.Runtime.Remoting.Messaging
????????????//AsyncDelegate?屬性可以強(qiáng)制轉(zhuǎn)換為用戶定義的委托的實(shí)際類。
????????????AddHandler?handler?=?(AddHandler)((AsyncResult)result).AsyncDelegate;
????????????Console.WriteLine(handler.EndInvoke(result));
????????????Console.WriteLine(result.AsyncState);
????????}
????????/*運(yùn)行結(jié)果：
????????=====?異步回調(diào)?AsyncInvokeTest?=====
????????開始計(jì)算：1+2
????????繼續(xù)做別的事情。。。
????????計(jì)算完成！
????????3
????????AsycState:OK
?????????????????*/
}
我定義的委托的類型為AddHandler，則為了訪問 AddHandler.EndInvoke，必須將異步委托強(qiáng)制轉(zhuǎn)換為 AddHandler。可以在異步回調(diào)函數(shù)（類型為 AsyncCallback）中調(diào)用 MAddHandler.EndInvoke，以獲取最初提交的 AddHandler.BeginInvoke 的結(jié)果。?
?
問題：
（1）int result = handler.Invoke(1,2);
為什么Invoke的參數(shù)和返回值和AddHandler委托是一樣的呢？
答：
Invoke方法的參數(shù)很簡(jiǎn)單，一個(gè)委托，一個(gè)參數(shù)表(可選)，而Invoke方法的主要功能就是幫助你在UI線程上調(diào)用委托所指定的方法。Invoke方法首先檢查發(fā)出調(diào)用的線程(即當(dāng)前線程)是不是UI線程，如果是，直接執(zhí)行委托指向的方法，如果不是，它將切換到UI線程，然后執(zhí)行委托指向的方法。不管當(dāng)前線程是不是UI線程，Invoke都阻塞直到委托指向的方法執(zhí)行完畢，然后切換回發(fā)出調(diào)用的線程(如果需要的話)，返回。
所以Invoke方法的參數(shù)和返回值和調(diào)用他的委托應(yīng)該是一致的。
（2）IAsyncResult result = handler.BeginInvoke(1,2,null,null);
BeginInvoke : 開始一個(gè)異步的請(qǐng)求,調(diào)用線程池中一個(gè)線程來執(zhí)行，
返回IAsyncResult 對(duì)象(異步的核心). IAsyncResult 簡(jiǎn)單的說,他存儲(chǔ)異步操作的狀態(tài)信息的一個(gè)接口,也可以用他來結(jié)束當(dāng)前異步。
注意: BeginInvoke和EndInvoke必須成對(duì)調(diào)用.即使不需要返回值，但EndInvoke還是必須調(diào)用，否則可能會(huì)造成內(nèi)存泄漏。
?
（3）IAsyncResult.AsyncState 屬性：
獲取用戶定義的對(duì)象，它限定或包含關(guān)于異步操作的信息。 例如：
{???
??????AddHandler?handler?=?(AddHandler)result.AsyncState;????
??????Console.WriteLine(handler.EndInvoke(result));?
??????。。。。。
}
?
總結(jié)
以上是生活随笔為你收集整理的[转载]C#异步委托的用法 .的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： STL 容器和迭代器连载6_顺序容器的操
- 下一篇： 给要学习.NET（c#语言）的新手一些学