public class TestDelegate { private string Uname = "joyet"; private int Num1 = 109; private int Num2 = 5; private int Num3=0; /// <summary> /// 测试同步方法 /// </summary> public void TestYncMethod() { Console.WriteLine("同步Show方法开始====="); DelegateShow showDelegate = new DelegateShow(TestMethods.Show); showDelegate.Invoke(Uname); Console.WriteLine("同步Show方法结束=====。"); Console.WriteLine("同步Add方法开始====="); DelegatePlus plusDelegate = new DelegatePlus(TestMethods.Add); int addResult = plusDelegate.Invoke(Num1, Num2); Console.WriteLine("同步Add方法相加结果:" + Convert.ToString(addResult)); Console.WriteLine("同步Add方法结束=====。"); } public void TestAsyncShow() { Console.WriteLine("异步Show方法开始====="); DelegateShow showDelegate = new DelegateShow(TestMethods.Show); showDelegate.BeginInvoke(Uname,null,null); //异步操作返回,当主线程运行到EndInvoke时,如果这时调用没有结束(这种情况很可能出现),这时为了等待调用结果,线程依旧会被阻塞 showDelegate.EndInvoke(null); Console.WriteLine("异步Show方法结束=====。"); } public void TestAsyncPlus() { Console.WriteLine("异步Plus方法主线程开始====="); DelegatePlus plusDelegate = new DelegatePlus(TestMethods.Add); IAsyncResult result = plusDelegate.BeginInvoke(Num1, Num2, new AsyncCallback(TestAsyncPlusCallBack), "AsycState:OK"); Console.WriteLine("异步Plus方法主线程结束=====。"); } /// <summary> /// 异步回调用回调函数,当调用结束时会自动调用回调函数,解决了为等待调用结果,而让线程依旧被阻塞的局面。 /// </summary> /// <param name="result"></param> private void TestAsyncPlusCallBack(IAsyncResult result) { DelegatePlus handler = (DelegatePlus)((AsyncResult)result).AsyncDelegate; Num3=handler.EndInvoke(result); Console.WriteLine("异步Add方法相加结果:" + Convert.ToString(Num3)); } }
public class TestMethods { public static void Show(string uname) { Thread.Sleep(3000); Console.WriteLine("Your name is :" + uname); } public static int Add(int a, int b) { Thread.Sleep(3000); return a + b; } }