C#每天進步一點--異步編程模式


         C#可以有一個簡單易用的機制用於異步執行方法,那就是委托。下面我介紹三種模式,對於這三種模式來說,原始線程都發起了一個異步方法,然后做一些其他處理。然而這些模式不同的是,原始線程獲取發起的線程已經完成的消息的方式。

1:在等待一直到完成(wait-nutil-done)模式。

  在發起了異步方法以及做了一些其他處理之后,原始線程就中斷並且等異步方法完成之后再繼續。

   

    class Program
    {
        private delegate int  MyDel(int a);

        public static int MyMenthod(int a)
        {
            for (int i = 0; i < 1000; i++)
            {
                a++;
            }
            return a;
        }
  
        static void Main(string[] args)
        {
            var del = new MyDel(MyMenthod);
            Console.WriteLine("Before BeginInvoke");
            IAsyncResult iar = del.BeginInvoke(5, null, null);
            Console.WriteLine("After BeginInvoke");

            Console.WriteLine("Doing stuff");

            long result = del.EndInvoke(iar);

            Console.WriteLine("結果為{0}",result);
        }
    }

  運行結果為

2:輪詢模式(polling)。

  原始線程定期檢查發起的線程是否完成,如果沒有則可以繼續做其他的事情。上代碼

  class Program
    {
        private delegate int  MyDel(int a);

        public static int MyMenthod(int a)
        {
            for (int i = 0; i < 1000; i++)
            {
                a++;
            }
            Thread.Sleep(3000);
            return a;
        }
  
        static void Main(string[] args)
        {
            var del = new MyDel(MyMenthod);

            IAsyncResult iar = del.BeginInvoke(5,null,null);
            Console.WriteLine("After BeginInvoke");

            while (!iar.IsCompleted)
            {
                Console.WriteLine("還沒處理完");

                Thread.Sleep(2000);
                Console.WriteLine("繼續處理其他事情");
            }
            Console.WriteLine("異步執行完成");
            long result = del.EndInvoke(iar);
            Console.WriteLine("結果為{0}",result);
        }
    }

  運行結果為:

3:回調模式(callbacl)。

  原始線程一直執行,無需等待或檢查發起的線程是否完成,在發起的線程中的引用方法完成之后,發起的線程就會調用回調方法,由回調方法在調用EndInvoke之前處理異步方法的結構。上代碼

   class Program
    {
        private delegate int  MyDel(int a);

        public static int MyMenthod(int a)
        {
            for (int i = 0; i < 1000; i++)
            {
                a++;
            }
            return a;
        }
        public static void CallBack(IAsyncResult iar)
        {
            AsyncResult ar = iar as AsyncResult;
            MyDel del = (MyDel)ar.AsyncDelegate;
            long r = del.EndInvoke(iar);
            Thread.Sleep(2000);
            Console.WriteLine("結果出來了,為{0}", r);
        }
        static void Main(string[] args)
        {
            var del = new MyDel(MyMenthod);

            Console.WriteLine("After BeginInvoke");
            IAsyncResult iar= del.BeginInvoke(5, CallBack, del);

            Console.WriteLine("Doing More Work In Main");
            Thread.Sleep(5000);
        }
    }

  運行結果為:

回調方法的簽名和返回類型必須和AsyncCallbacl委托類型所描述的形式一致。它需要方法接受一個IAsyncResult作為參數並且返回類型是void,如下:

 void AsyncCallback(IAsyncResult iar)

我們有多種方式可以為BeginInvoke方法提供回調方法,由於BeginInvoke中的callback參數是AsyncCallback類型的委托,我們可以以委托形式提供,我們也可以只提供回調方法名稱,讓編譯器為我們創建委托,兩種形式是等價的。

IAsyncResult iar1 = del.BeginInvoke(5,new AsyncCallback(CallWhenDone),null);

IAsyncResult iar2 = del.BenginInvoke(5,CallWhenDone,null);


免責聲明!

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



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