1. 程式人生 > >C#老生常談之非同步呼叫的引數及返回值

C#老生常談之非同步呼叫的引數及返回值

首先,看程式碼

程式碼段1:
        public delegate string FuncHandle(int data1, int data2);
        FuncHandle fh ;
            
        private void BT_Temp_Click(object sender, RoutedEventArgs e)
        {
            fh = new FuncHandle(this.Foo);
            AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
            fh.BeginInvoke(1, 3, callback, null);
        }

        public void AsyncCallbackImpl(IAsyncResult ar)   
        {
            string re = fh.EndInvoke(ar);
            MessageBox.Show("" + ar.AsyncState);
        }   
  
        string Foo(int data1, int data2)   
        {   
            return "" + data1 + data2;   
        }  

在非同步呼叫中,如果想在非同步的回撥函式中,得到非同步函式的返回值(如上面程式碼中的Foo函式的string返回值),則必須要在回撥函式中使用EndInvoke(關於EndInvoke會在下文描述)。在上面的例子是如下這句。
        string re = fh.EndInvoke(ar);

但是,有的時候fh並不見得是個類變數,這個時候,就需要我們將EndInvoke的執行主體由BeginInvoke傳遞進去。看修改過後的程式碼片段。

程式碼段2:
        public delegate string FuncHandle(int data1, int data2);   
            
        private void BT_Temp_Click(object sender, RoutedEventArgs e)
        {
            FuncHandle fh = new FuncHandle(this.Foo);
            AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
            fh.BeginInvoke(1, 3, callback, fh);

        }
        public void AsyncCallbackImpl(IAsyncResult ar)   
        {   
            FuncHandle dl = ar.AsyncState as FuncHandle;   
            string re = dl.EndInvoke(ar);
            MessageBox.Show("" + ar.AsyncState);
        }   
  
        string Foo(int data1, int data2)   
        {   
            return "" + data1 + data2;   
        }  

通過舉一反三,其實BeginInvoke的最後一個引數,可以是任何物件,看具體的應用場景即可。

下面再介紹一下EndInvoke。EndInvoke在回撥函式中,用於承載執行的主體函式的返回值。在另外一個情況下,即上面的程式碼片段一個簡化版本,如下:

程式碼段3:
        public delegate string FuncHandle(int data1, int data2);   
        private void BT_Temp_Click(object sender, RoutedEventArgs e)
        {
            FuncHandle fh = new FuncHandle(this.Foo);
            IAsyncResult ar = fh.BeginInvoke(1, 3, null, fh);
            string re = fh.EndInvoke(ar);
            MessageBox.Show(re);
        }
        
        string Foo(int data1, int data2)   
        {   
            return "" + data1 + data2;   
        }  


我們可以看到,在這個程式碼片段中,我們根本沒有使用回撥函式,那麼,我們就需要通過EndInvoke來阻滯主執行緒,使得返回函式主體的返回值。

再多說一點,呼叫了 BeginInvoke 後,可以:

1.進行某些操作,然後呼叫 EndInvoke 一直阻塞到呼叫完成。如上文的最後一個程式碼片段。

2.使用 IAsyncResult.AsyncWaitHandle 獲取 WaitHandle,使用它的 WaitOne 方法將執行一直阻塞到發出 WaitHandle 訊號,然後呼叫EndInvoke。這裡主要是主程式等待非同步方法,等待非同步方法的結果。見程式碼段4。

3.輪詢由 BeginInvoke 返回的 IAsyncResult,IAsyncResult.IsCompeted確定非同步呼叫何時完成,然後呼叫 EndInvoke。

4.將用於回撥方法的委託傳遞給 BeginInvoke。該方法在非同步呼叫完成後在 ThreadPool 執行緒上執行,它可以呼叫 EndInvoke。這是在強制裝換回調函式裡面IAsyncResult.AsyncState(BeginInvoke方法的最後一個引數)成委託,然後用委託執行EndInvoke。即如上程式碼片段2。

程式碼段4:
        public delegate string FuncHandle(int data1, int data2);
        string _sTemp = string.Empty;

        private void BT_Temp_Click(object sender, RoutedEventArgs e)
        {
            FuncHandle fh = new FuncHandle(this.Foo);
            AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
            IAsyncResult ar = fh.BeginInvoke(1, 3, null, null);
            WaitHandle waitHandle = ar.AsyncWaitHandle;
            waitHandle.WaitOne();
            MessageBox.Show(_sTemp);
        }

        string Foo(int data1, int data2)   
        {
            Thread.Sleep(3000);
            string re = "" + data1 + data2;
            _sTemp = re;
            return re;
        }