異步編程模型(APM)模式

什么是APM

.net 1.0時期就提出的一種異步模式，並且基於IAsyncResult接口實現BeginXXX和EndXXX類似的方法。

.net中有很多類實現了該模式(比如HttpWebRequest)，同時我們也可以自定義類來實現APM模式(繼承IAsyncResult接口並且實現BeginXXX和EndXXX方法)，下面的Demo就以HttpWebRequest類來實現APM模式的異步。

Demo

下面分別使用同步和異步APM模式來實現，讀取一個網頁內容，並且將內容展示到界面上。

1，同步

就是平常我們寫代碼的方式，代碼如下。

/// <summary>
        /// 同步
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button1_Click(object sender, EventArgs e)
        {
            //先清空上一次查詢結果
            this.richTextBox1.Text = "";

            var url = this.textBox1.Text.Trim();
            var request = HttpWebRequest.Create(url);
            var response = request.GetResponse();
            var stream = response.GetResponseStream();
            using (StreamReader reader= new StreamReader(stream))
            {
                var content = reader.ReadToEnd();
                this.richTextBox1.Text = content;
            }
        }

2，異步(APM)

主要是通過BeginGetResponse和EndGetResponse來調用的。

/// <summary>
        /// 異步
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void button2_Click(object sender, EventArgs e)
        {
            //先清空上一次查詢結果
            this.richTextBox1.Text = "";

            var url = this.textBox1.Text.Trim();
            var request = HttpWebRequest.Create(url);
            request.BeginGetResponse(AsyncCallbackImpl, request);//BeginGetResponse,發起異步請求
        }

        /// <summary>
        /// 回調
        /// </summary>
        /// <param name="ar"></param>
        public void AsyncCallbackImpl(IAsyncResult ar)
        {
            HttpWebRequest request = ar.AsyncState as HttpWebRequest;
            var response = request.EndGetResponse(ar);//EndGetResponse,異步請求完成
            var stream = response.GetResponseStream();
            StringBuilder sb = new StringBuilder();
            sb.AppendLine("當前線程Id:" + Thread.CurrentThread.ManagedThreadId);
            using (StreamReader reader = new StreamReader(stream))
            {
                var content = reader.ReadLine();
                sb.AppendLine(content);
                this.richTextBox1.Text = sb.ToString();
            }
        }

同步的方式，代碼是順序執行的，並且發送請求的時候界面會阻塞。但是異步模式界面不會阻塞，主線程會立即返回，等到異步請求完成的時候再從線程池中取一個線程處理。