淺談.Net非同步程式設計的前世今生----EAP篇
前言
在上一篇博文中,我們提到了APM模型實現非同步程式設計的模式,通過使用APM模型,可以簡化.Net中編寫非同步程式的方式,但APM模型本身依然存在一些缺點,如無法得知操作進度,不能取消非同步操作等。
針對這些缺點,微軟在.Net 2.0中提出了基於事件的非同步模式,簡稱為EAP模型。
第二個非同步程式設計模型:EAP
概述
EAP,全稱Event-based Asynchronous Pattern,基於事件的非同步模式,它提供了一系列的事件宣告與方法,用於實現非同步模式的各個階段。
典型的內建元件為BackgroundWorker元件,本文中我們將使用它來探尋此種模式的執行過程。
使用
我們需要建立一個窗體應用,並模擬下載實時進度顯示。建立WinForm後,放入Label控制元件用於展示下載進度和其他資訊,並加入兩個Button按鈕,分別為開始下載和取消下載,再放入我們的主角:BackgroundWorker元件,如圖所示:
在加入這些基本元件後,我們開始這一次的編碼之旅,BackgroundWorker在後臺屬於一個類,因此它已經內建了部分屬性和事件:
這些屬性中包含取消、支援進度更新、判斷是否執行等,恰恰是我們在這次非同步操作中需要的。於是,我們根據需求編寫了以下程式碼:
1 using System; 2 using System.Collections.Generic; 3 using System.ComponentModel; 4 using System.Data; 5 using System.Drawing; 6 using System.IO; 7 using System.Linq; 8 using System.Text; 9 using System.Threading; 10 using System.Threading.Tasks; 11 using System.Windows.Forms; 12 13 namespace BackgroundWorkerDemo 14 { 15 public partial class BackgroundWorkerForm : Form 16 { 17 public BackgroundWorkerForm() 18 { 19 InitializeComponent(); 20 backgroundWorker1.WorkerReportsProgress = true; 21 backgroundWorker1.WorkerSupportsCancellation = true; 22 } 23 24 /// <summary> 25 /// 點選開始下載按鈕 26 /// </summary> 27 /// <param name="sender"></param> 28 /// <param name="e"></param> 29 private void btnDownLoad_Click(object sender, EventArgs e) 30 { 31 if (!backgroundWorker1.IsBusy) //判斷是否正在執行非同步操作 32 { 33 //backgroundWorker開始執行非同步操作 34 backgroundWorker1.RunWorkerAsync(); 35 } 36 } 37 38 /// <summary> 39 /// 點選取消按鈕 40 /// </summary> 41 /// <param name="sender"></param> 42 /// <param name="e"></param> 43 private void btnCancel_Click(object sender, EventArgs e) 44 { 45 if (backgroundWorker1.WorkerSupportsCancellation) //判斷是否支援非同步取消操作 46 { 47 //開始執行取消操作 48 backgroundWorker1.CancelAsync(); 49 } 50 } 51 52 /// <summary> 53 /// backgroundworker非同步執行事件 54 /// </summary> 55 /// <param name="sender"></param> 56 /// <param name="e"></param> 57 private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e) 58 { 59 System.ComponentModel.BackgroundWorker worker = sender as System.ComponentModel.BackgroundWorker; 60 string msg = "當前執行緒是否為後臺執行緒:" + Thread.CurrentThread.IsBackground + ",是否為執行緒池執行緒:" + Thread.CurrentThread.IsThreadPoolThread; 61 WriteLog("Backgroundworker日誌", msg); 62 for (int i = 0; i < 20; i++) 63 { 64 if (worker.CancellationPending) 65 { 66 e.Cancel = true; 67 break; 68 } 69 else 70 { 71 //模擬下載執行進度 72 Thread.Sleep(500); 73 worker.ReportProgress(i * 5); 74 } 75 } 76 } 77 78 /// <summary> 79 /// 進度報告事件 80 /// </summary> 81 /// <param name="sender"></param> 82 /// <param name="e"></param> 83 private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e) 84 { 85 lblProcess.Text = "當前下載進度為:" + e.ProgressPercentage + "%,是否為後臺執行緒:" + Thread.CurrentThread.IsBackground + ",是否為執行緒池執行緒:" + Thread.CurrentThread.IsThreadPoolThread; 86 } 87 88 /// <summary> 89 /// 非同步操作完成事件 90 /// </summary> 91 /// <param name="sender"></param> 92 /// <param name="e"></param> 93 private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 94 { 95 if (e.Cancelled) //此狀態為取消 96 { 97 lblProcess.Text = "下載已經被取消"; 98 } 99 else if (e.Error != null) 100 { 101 lblProcess.Text = "出現錯誤:" + e.Error.Message; 102 } 103 else 104 { 105 lblProcess.Text = "下載已完成"; 106 } 107 } 108 109 /// <summary> 110 /// 記錄日誌 111 /// </summary> 112 /// <param name="documentName"></param> 113 /// <param name="msg"></param> 114 public void WriteLog(string documentName, string msg) 115 { 116 string errorLogFilePath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Log"); 117 if (!System.IO.Directory.Exists(errorLogFilePath)) 118 { 119 System.IO.Directory.CreateDirectory(errorLogFilePath); 120 } 121 string logFile = System.IO.Path.Combine(errorLogFilePath, documentName + "@" + DateTime.Today.ToString("yyyy-MM-dd") + ".txt"); 122 bool writeBaseInfo = System.IO.File.Exists(logFile); 123 StreamWriter swLogFile = new StreamWriter(logFile, true, Encoding.Unicode); 124 swLogFile.WriteLine(DateTime.Now.ToString("HH:mm:ss") + "\t" + msg); 125 swLogFile.Close(); 126 swLogFile.Dispose(); 127 } 128 } 129 }
在這段示例程式碼中,我們首先設定元件支援取消及報告進度操作屬性,其次在點選開始按鈕時,判斷是否執行,若未執行,則執行RunWorkerAsync方法,避免多次重複執行。
在EAP模型中,執行RunWorkerAsync方法後,會觸發backgroundWorker1_DoWork事件。此事件中我們放入模擬實時下載進度程式碼,並呼叫ReportProgress進行進度報告,這時backgroundWorker1_ProgressChanged事件會被觸發,同時對UI進行更新操作,此段過程執行結果如下圖所示:
通過結果可以看出,執行過程中已經實現了實時更新進度的功能。於此同時,根據反饋的資訊我們發現,backgroundWorker1_ProgressChanged事件內部是執行緒安全的,在操作UI時不會出現跨執行緒對UI進行更新的問題。
那麼BackgroundWorker內部是不是依然使用了執行緒池及後臺執行緒呢?我們來一起看看在backgroundWorker1_DoWork事件中記錄的日誌:
通過日誌我們發現,EAP與APM一樣,也使用了執行緒池中的執行緒,不得不感嘆一句,執行緒池是個偉大的發明,微軟真是無所不用其極啊!
講到這裡,細心的同學會發現,我們嘮叨了這麼半天,似乎還少了點什麼,對了,取消操作,一起來看看效果:
點選介面上的"取消下載"按鈕後,會提示下載已經被取消。原因是我們在點選按鈕時,首先判斷了WorkerSupportsCancellation屬性,看元件是否支援取消操作,隨後執行CancelAsync方法進行非同步取消。
由於這個過程是非同步的,因此我們在backgroundWorker1_DoWork事件中不斷判斷CancellationPending屬性,若取消則設定e.Cancel=true進行標誌位標誌,標誌後我們可以在backgroundWorker1_RunWorkerCompleted判斷是否已經取消,最後對UI進行提示輸出,取消操作完成。
小結
對比APM呼叫委託進行非同步操作的方式,EAP顯得更加簡潔明瞭,只需更少的程式碼即可實現更多的功能。尤其是BackgroundWorker元件,定義相應的事件後,在不同階段根據需求編寫方法即可實現非同步操作、報告進度及取消等。
但是EAP模型的使用,侷限性會更強,主要包括以下幾點:
1、可用元件少,除了BackgroundWorker之外,僅有WebClient類支援此模型,在B/S程式中難以使用
2、只能使用預定義事件,無法手動定義回撥函式,且依賴事件的執行順序
3、內部封裝較多,佔用資源比APM方式多
因此在愈演愈烈的需求中,微軟又對非同步程式設計模型進行了變革,一種兼顧強大與靈活的新模型誕生了,它會是誰呢?預知後事如何,且聽下回分解。
下集預告
淺談.Net非同步程式設計的前世今生----TP