using System;
using System.Threading; 
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
using System.Runtime.Remoting.Messaging;

namespace test
{
    [Serializable]
    public class AsyncDemo 
    {
        public delegate void TestRaiseEventHandler(object sender, EventArgs e);
        public event TestRaiseEventHandler TestRaise;
        protected virtual void OnTestRaiseEventHandler()
        {
            if (TestRaise != null)
            {
                TestRaise(this, null);
            }
        }
        // 将被异步调用的方法
        //
        public string TestMethod(int callDuration, out int threadId) 
        {
            Console.WriteLine("Test method begins.");
            OnTestRaiseEventHandler();
            Thread.Sleep(callDuration);
            threadId = AppDomain.GetCurrentThreadId();
            return "MyCallTime was " + callDuration.ToString();
        }

        // 序列化操作
        public void Serialize(string filename)
        {
            Serialize(filename, this);
        }

        public static void Serialize(string filename, AsyncDemo async) 
        { 
            FileStream fs = new FileStream(filename, FileMode.Create); 
            BinaryFormatter formatter = new BinaryFormatter(); 
            try
            {
                formatter.Serialize(fs, async);
            }
            finally
            {
                fs.Close(); 
            }
        } 
    }

    // 用来执行异步调用的代理
    public delegate string AsyncDelegate(int callDuration, out int threadId);

    public class AsyncMain 
    {
        private static int threadId;

        static void Main(string[] args) 
        {
            // 创建测试类
            AsyncDemo ad = new AsyncDemo();
            // 添加事件.(1)
            ad.TestRaise += new test.AsyncDemo.TestRaiseEventHandler((new AsyncMain()).ad_TestRaise);
            // 创建异步方法的代理
            AsyncDelegate dlgt = new AsyncDelegate(ad.TestMethod);
   
            // 开始执行异步调用
            IAsyncResult ar = dlgt.BeginInvoke(1000,
                out threadId, 
                new AsyncCallback(CallbackMethod),
                ad );

            // 等待调用完成
            Console.WriteLine("Press Enter to close application.");
            Console.ReadLine();        
        }

        // 事件响应函数
        void ad_TestRaise(object sender, EventArgs e)
        {
            Console.WriteLine("delegate call");
        }

        // 异步调用完成时的回调函数
        static void CallbackMethod(IAsyncResult ar) 
        {
            // 得到异步方法的代理
            AsyncDelegate dlgt = (AsyncDelegate) (ar as AsyncResult).AsyncDelegate;        
            Console.WriteLine("begin EndInvoke");
            string ret = dlgt.EndInvoke(out threadId, ar);
            Console.WriteLine("The call executed on thread {0}, with return value \"{1}\".", threadId, ret);

            // 执行序列化操作(2)
            AsyncDemo demo = ar.AsyncState as AsyncDemo;
            demo.Serialize("Test.dat");
        }
    }
}