圖1. 計算pi值的程序

耗時操作（long-running operations）的進度

雖然大多數的程序不需要計算pi的值，但是很多的程序都需要進行一些耗時的操作，比如打印、調用一個web service或者計算一位太平洋西北岸億萬富翁的利息收入。對用戶來說，只要可以看到當前完成的進度，這樣的等待通常還是可以接受的，甚至是一個抽身忙些其他事情的機會。所以我給我的每一個小程序都添加了一個進度條（progress bar）。我的這個計算pi值的程序所用的算法每次計算9位數字。一旦新的一組數字被計算出來，我的程序就更新textbox控件并移動progressbar來顯示我們的進度。比如圖2就是正在計算1000位pi值的情形（如果21位沒有問題，1000位也必定更好）。

圖2. 正在計算1000位pi值

下面的代碼展示了pi值的數字被計算出來之后，用戶界面（ui）是如何更新的：

void showprogress(string pi, int totaldigits, int digitssofar) {

  _pi.text = pi;

  _piprogress.maximum = totaldigits;

  _piprogress.value = digitssofar;

}

void calcpi(int digits) {

  stringbuilder pi = new stringbuilder("3", digits + 2);

  // 顯示進度

  showprogress(pi.tostring(), digits, 0);

  if( digits > 0 ) {

    pi.append(".");

    for( int i = 0; i < digits; i += 9 ) {

      int ninedigits = ninedigitsofpi.startingat(i+1);

      int digitcount = math.min(digits - i, 9);

      string ds = string.format("{0:d9}", ninedigits);

      pi.append(ds.substring(0, digitcount));

      // 顯示進度

      showprogress(pi.tostring(), digits, i + digitcount);

    }

  }

}

一切進行的都很順利，直到我在計算pi的1000位的過程中切換到了其他程序做了些什么然后再切換回來時……。我看到了圖3顯示的畫面：

圖3. 沒有paint事件了

問題的根源當然在于我們的程序是單線程的。當這個線程忙于計算pi值時，就沒有機會去繪制ui了。之前我之所以沒有遇到這個問題是因為當我設置textbox.text屬性和progressbar.value屬性時，這些控件，作為設置屬性操作的一部分，可以強制他們的繪畫操作立即進行（盡管我注意到了progress bar的情況要比text box好一些）。然而，當我把這個程序放到后臺然后再帶回前臺時，我需要重繪整個客戶區，對窗口來說就是一個paint事件。因為當前正在處理的事件（calc按鈕的click事件）返回之前其他事件是不會得到處理的，于是我們就沒有機會看到更多的進度顯示了。我現在需要做的就是把ui線程釋放出來專做ui工作，把耗時的操作放到后臺處理。為了實現這個目標，我們需要另外一個線程。

異步操作

現在我的同步click handler看起來是這樣的：

void _calcbutton_click(object sender, eventargs e) {

  calcpi((int)_digits.value);

}

回憶一下我們的問題是“直到calcpi返回，線程才可以從click handler返回，窗口才有機會處理paint（或其他）事件”。處理這種情況的一個方法是啟動另外的線程，比如：

using system.threading;

int _digitstocalc = 0;

void calcpithreadstart() {

  calcpi(_digitstocalc);

}

void _calcbutton_click(object sender, eventargs e) {

  _digitstocalc = (int)_digits.value;

  thread pithread = new thread(new threadstart(calcpithreadstart));           

  pithread.start();

}

現在，在button click事件返回之前無需再等待calcpi的完成了，我創建并啟動了一個新的線程，thread.start方法將調度并啟動新的線程，然后立即返回，讓ui線程回到它自己的工作上來。現在如果用戶和程序交互（比如放到后臺，置到前臺，改變窗口大小，關閉它），ui線程可以自由地處理這些事件，同時worker線程也在進行它的計算pi的工作。圖4顯示了兩個線程工作的情形：

圖4. 幼稚的多線程

你也許注意到了，我沒有為worker線程的入口點——calcpithreadstart傳遞任何參數，而是把需要計算的位數放入一個字段（field）_digitstocalc中，調用線程的入口點，calcpi被調用。這是一種痛苦，也是我喜歡用delegate來作異步工作的一個原因。delegate支持參數，避免了我對增加一個額外的臨時field和一個額外的函數而做激烈的思想斗爭。

如果你對delegate(委托)不熟悉，就認為他們是調用static或instance函數的對象。在c#中它們的聲明語法和函數是一樣的。比如calcpi的一個委托看起來是這樣的：

delegate void calcpidelegate(int digits);

一旦有了一個委托，我就可以實例化一個對象來同步調用calcpi函數：

void _calcbutton_click(object sender, eventargs e) {

  calcpidelegate  calcpi = new calcpidelegate(calcpi);

  calcpi((int)_digits.value);

}

當然，我并不想同步調用calcpi；我想要異步調用它。然而，在我做這個之前我們需要了解一點委托的工作原理。上面的委托聲明實際上聲明了一個類，該類繼承自一個自帶有三個函數（invoke、begininvoke和endinvoke）的multicastdelegate類，像這樣：

class calcpidelegate : multicastdelegate {

  public void invoke(int digits);

  public void begininvoke(int digits, asynccallback callback,

                          object asyncstate);

  public void endinvoke(iasyncresult result);

}

當我先實例化一個calcpidelegate對象然后像調用函數一樣調用它時，我實際上調用了他的同步invoke函數。它隨后調用了我的calcpi。然而begininvoke和endinvoke是一對可以讓你異步調用并收獲(harvest)返回值的函數。所以，為了讓calcpi在另外一個線程中運行，我需要像下面那樣調用begininvoke：

void _calcbutton_click(object sender, eventargs e) {

  calcpidelegate  calcpi = new calcpidelegate(calcpi);

  calcpi.begininvoke((int)_digits.value, null, null);

}

注意我們為begininvoke的最后兩個參數傳遞了null。這兩個參數在我們需要隨后收獲（harvest）函數的返回值時（endinvoke就是用來做這個的）就有用了。由于calcpi函數直接更新ui，我們僅需為這兩個參數傳遞null。如果你對委托的細節（同步和異步）感興趣，可以看看.net委托：一個c#睡前故事（中文翻譯版）這篇文章。

到這時，我應該感到高興。我已經在我的程序里顯示耗時操作進度并保持了ui的良好交互性。

多線程安全

看起來我足夠幸運（或者說不幸，看你怎么看待這些事情了）。microsoft windows(r)xp給我提供了一個非常健壯的windows forms賴以建立的windows系統底層實現。它是如此健壯，以至于優雅地幫我包攬了所有問題，即使我違反了主要的windows編程方針——不要在創建一個窗口的線程之外的線程操作這個窗口。不幸的是，不能保證其他不太健壯的windows實現不會同樣優雅地給我臉色看。

問題當然是我自己造成的。回憶一下圖4，我用兩個線程同時訪問一個窗口。然而，因為耗時操作在windows程序中是如此的普遍，以至于windows forms里的每個ui類（每一個本質上從system.windows.forms.control繼承的類）都有一個可以在任何線程中安全訪問的屬性invokerequired。這個屬性在一個線程調用控件的對象方法之前需要先封傳該控件到創建這個控件的線程時返回true。我的showprogress函數中如果簡單地增加一個assert就會立即顯現出我上述做法的錯誤之處。

using system.diagnostics;

void showprogress(string pi, int totaldigits, int digitssofar) {

  // make sure we're on the right thread

  debug.assert(_pi.invokerequired == false);

  ...

}

實事上，.net文檔在這一點上是很清晰的。它描述如下：“控件上有四種方法可以安全地從任何線程進行調用：invoke、begininvoke、endinvoke 和 creategraphics。對于所有其他方法調用，當從另一個線程進行調用時，應使用這些 invoke 方法之一。”所以，當我設置控件屬性時，就明確地違反了這條規則。前三個函數的名字就明確地指出了我需要構建另外一個在ui線程中執行的委托。如果我不想像阻塞ui線程一樣阻塞我的worker線程，我就需要使用異步的begininvoke和endinvoke。然而，由于我的worker線程生來就是為ui線程服務的，就讓世界簡單一點，使用同步的invoke方法吧。像下面：

public object invoke(delegate method);

public object invoke(delegate method, object[] args);

第一個重載的invoke接收一個包含我們將要在ui線程中調用的方法的委托的實例，這個委托（或方法）必須沒有參數。然而我們想要用來更新ui的函數showprogress帶有三個參數，所以我們需要第二個重載形式。我們同樣需要為我們的showprogress方法定義一個單獨的委托以便我們可以正確地傳遞參數。這里給出了如何使用invoke來確保我們調用的showprogress也包括我們對窗口的使用是在正確的線程中執行的方法：（請確認替換calcpi中兩處對showprogress的調用）。

delegate

void showprogressdelegate(string pi, int totaldigits, int digitssofar);

void calcpi(int digits) {

  stringbuilder pi = new stringbuilder("3", digits + 2);

  // 準備異步顯示進度

  showprogressdelegate showprogress =

    new showprogressdelegate(showprogress);

  // 顯示進度

  this.invoke(showprogress, new object[] { pi.tostring(), digits, 0});

  if( digits > 0 ) {

    pi.append(".");

    for( int i = 0; i < digits; i += 9 ) {

      ...

      // 顯示進度

      this.invoke(showprogress,

        new object[] { pi.tostring(), digits, i + digitcount});

    }

  }

}

invoke的使用最終讓我在windows forms程序中安全的使用多線程。ui線程孵化出一個worker線程來執行耗時操作，當ui需要更新時worker線程把控制傳遞回ui線程。圖5顯示了我們的安全多線程構架。

圖5. 安全的多線程

簡化了的多線程

對invoke的調用多少有點麻煩，因為它在calcpi中調用了兩次，我可以簡化一下，改進showprogress讓它自己來作異步調用。如果showprogress是在正確的線程中調用的，他將更新控件，但是如果它在不正確的線程中被調用，它就會使用invoke在正確的線程中回頭調用它自身。這讓我們回到了以前，簡單些的calcpi：

void showprogress(string pi, int totaldigits, int digitssofar) {

  // 確保我們在正確的線程中

  if( _pi.invokerequired == false ) {

    _pi.text = pi;

    _piprogress.maximum = totaldigits;

    _piprogress.value = digitssofar;

  }

  else {

    // 異步顯示進度

    showprogressdelegate showprogress =

      new showprogressdelegate(showprogress);

    this.invoke(showprogress,

      new object[] { pi, totaldigits, digitssofar});

  }

}

void calcpi(int digits) {

  stringbuilder pi = new stringbuilder("3", digits + 2);

  // 顯示進度

  showprogress(pi.tostring(), digits, 0);

  if( digits > 0 ) {

    pi.append(".");

    for( int i = 0; i < digits; i += 9 ) {

      ...

      //顯示進度

      showprogress(pi.tostring(), digits, i + digitcount);

    }

  }

}

因為invoke是一個異步調用并且我們并不真的需要它的返回值（事實上，showprogress本身就不返回任何值），這里最好是使用begininvoke以便worker線程不阻塞。就像下面：

begininvoke(showprogress, new object[] { pi, totaldigits, digitssofar});

如果不需要函數調用的返回值，begininvoke總是應該優先考慮，因為它可以讓worker線程立即回到自己的工作上來，并且避免死鎖的可能性。

我們做了什么？

我用了一個簡短的例子，演示了如何在執行耗時操作的同時顯示進度并保持ui的用戶操作的響應。為了完成這個任務，我用了一個異步委托來“孵化”出一個worker線程、主窗口上的invoke方法和另外一個要封傳回ui線程執行的代理。

我非常小心地避免做一件事情，那就是在ui線程和worker線程之間共享數據。相反，對于那些必需的數據我傳遞它們的拷貝（要計算的位數、已經計算出來的數字和進度）。在最終的解決方案中，我從來都沒有傳遞對象的引用，比如當前stringbuilder的引用（雖然傳遞引用可以節省每次回到ui線程時對字符串的拷貝）。如果我要在兩個線程之間傳遞數據的引用，我就必須使用.net原始的同步手段來確保任一時刻只有一個線程訪問一個對象，這將增加許多工作量。這樣已經足夠了，無需引入同步進制。

當然，如果你需要處理的是數據庫，你肯定不會打算把數據庫到處復制。然而在windows forms程序中，如果可能我推薦你在worker線程和ui線程之間使用異步委托和消息來實現耗時操作。