.NET Framework的IAsyncResult接口的细节

1[System.Runtime.InteropServices.ComVisible(true)]
2public interface IAsyncResult
3{
4    object AsyncState { get; }
5    WaitHandle AsyncWaitHandle { get; }
6    bool CompletedSynchronously { get; }
7    bool IsCompleted { get; }
8}

 1using System;
 2using System.Threading; 
 3
 4namespace Examples.AdvancedProgramming.AsynchronousOperations
 5{
 6    public class AsyncDemo 
 7    {
 8        // 将要被异步执行的函数
 9        public string TestMethod(int callDuration, out int threadId) 
10        {
11            Console.WriteLine("Test method begins.");
12            Thread.Sleep(callDuration); // 被异步执行的函数所在的线程休眠callDuration所指定的时间
13            threadId = Thread.CurrentThread.ManagedThreadId; // 拿到系统给本异步执行的函数分配的运行线程的id
14            return String.Format("My call time was {0}.", callDuration.ToString());
15        }
16    }
17
18    // 将要被异步执行的函数的签名声明
19    public delegate string AsyncMethodCaller(int callDuration, out int threadId);
20}

 1using System;
 2using System.Threading;
 3namespace Examples.AdvancedProgramming.AsynchronousOperations
 4{
 5    public class AsyncMain 
 6    {
 7        static void Main() 
 8        {
 9            int threadId;
10            AsyncDemo ad = new AsyncDemo();
11
12            // 创建一个delegate，这个delegate指向AsyncDemo.TestMethod方法
13            AsyncMethodCaller caller = new AsyncMethodCaller(ad.TestMethod);
14       
15            //  这里的BeginInvoke是Delegate的异步调用方法，该方法有以下特性：
16            //  a、委托的BeginInvoke方法，在线程池分配的子线程中执行委托
17            //  b、委托执行时不会阻塞主线程（调用委托的BeginInvoke线程），主线程继续向下执行。
18            //  c、委托执行时会阻塞子线程。
19            //  d、委托结束时，如果有返回值，子线程讲返回值传递给主线程；如果有回调函数，子线程
20            //     将继续执行回调函数。
21            //  参考网页 
22            //  https://www.cnblogs.com/EasonLeung/p/3683492.html
23            //  https://www.cnblogs.com/markhe/articles/5587956.html
24            //  https://www.jb51.net/article/155167.htm
25
26            // 第一个参数就是AsyncMethodCaller函数签名中的int callDuration参数
27            // 第二个参数就是AsyncMethodCaller函数签名中的out int threadId参数
28            IAsyncResult result = caller.BeginInvoke(3000, out threadId, null, null);
29
30            Thread.Sleep(0);
31            Console.WriteLine("Main thread {0} does some work.",Thread.CurrentThread.ManagedThreadId);
32
33            // Wait for the WaitHandle to become signaled.
34            // 执行本句代码之后，会阻塞当前运行的线程，直到WaitHanle得到赋值为止
35            result.AsyncWaitHandle.WaitOne();
36
37            // 参考网址： https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.waithandle.waitone?view=netframework-3.5#System_Threading_WaitHandle_WaitOne
38            // WaitHanle得到赋值之后，本线程可以继续执行下去了，要获取到本次delegate调用的回调值，需要
39            // 调用EndInvoke方法
40            string returnValue = caller.EndInvoke(out threadId, result);
41
42            // 获取完毕之后，关闭wait handle
43            result.AsyncWaitHandle.Close();
44
45            Console.WriteLine("The call executed on thread {0}, with return value \"{1}\".",
46                threadId, returnValue);
47        }
48    }
49}