.NET中的異步編程:不同與傳統的異步實現
我們都知道.NET要實現異步編程，尤其是傳統的異步實現方法，很容易出現錯誤。所以有許多程序員就盡量避免使用異步編程，即使在知道應該使用的情況下。今天我要告訴大家就是不同與傳統異步實現的心得異步實現方式Continuation Passing Style簡稱CPS
首先，我們看看下面這個方法：
- public int Add(int a, int b)
- {
- return a + b;
- }
我們一般這樣調用它：
- Print(Add(5, 6))
- public void Print(int result)
- {
- Console.WriteLine(result);
- }
如果我們以CPS的方式編寫上面的代碼則是這個樣子：
- public void Add(int a, int b, Action<int> continueWith)
- {
- continueWith(a+b);
- }
- Add(5, 6, (ret) => Print(ret));
就好像我們將方法倒過來，我們不再是直接返回方法的結果；我們現在做的是接受一個委托，這個委托表示我這個方法運算完后要干什么，就是傳說的continue。對于這里來說，Add的continue就是Print。
不僅是上面這樣的代碼示例。在一個方法中，在本語句后面執行的語句都可以稱之為本語句的continue。
CPS 與 Async
那么可能有人要問，你說這么多跟異步有什么關系么？對，跟異步有很大的關系。回想上一篇文章，經典的異步模式都是一個以Begin開頭的方法發起異步請求，并且向這個方法傳入一個回調（callback），當異步執行完畢后該回調會被執行，那么我們可以稱該回調為這個異步請求的continue：
- stream.BeginRead(buffer, 0, 1024, continueWith, null)
這又有什么用呢？那先來看看我們期望寫出什么樣子的異步代碼吧（注意，這是偽代碼，不要沒有看文章就直接粘貼代碼到vs運行）：
- var request = HttpWebRequest.Create("http://www.google.com");
- var asyncResult1 = request.BeginGetResponse(...); var response = request.EndGetResponse(asyncResult1);
- using(stream = response.GetResponseStream())
- {
- var asyncResult2 = stream.BeginRead(buffer, 0, 1024, ...);
- var actualRead = stream.EndRead(asyncResult2);
- }
對，我們想要像同步的方式一樣編寫異步代碼，我討厭那么多回調，特別是一環嵌套一環的回調。
參照前面對CPS的討論，在request.BeginGetResponse之后的代碼，都是它的continue，如果我能夠有一種機制獲得我的continue，然后在我執行完畢之后調用continue該多好啊。可惜，C#沒有像Scheme那樣的控制操作符call/cc獲取continue。
- var request = HttpWebRequest.Create("http://www.google.com");
- 標識1 var asyncResult1 = request.BeginGetResponse(...);
- var response = request.EndGetResponse(asyncResult1);
- using(stream = response.GetResponseStream())
- {
- 標識2 var asyncResult2 = stream.BeginRead(buffer, 0, 1024, ...);
- var actualRead = stream.EndRead(asyncResult2);
- }
思路貌似到這兒斷了。但是我們是否可以換個角度想想，如果我們能給上面這段代碼加上標識：在每個異步請求發起的地方都加一個標識，而標識之后的部分就是continue。
當執行到 標識1 時，立即返回，并且記住本次執行只執行到了 標識1，當異步請求完畢后，它知道上次執行到了 標識1，那么這個時候就從標識1的下一行開始執行，當執行到標識2時，又遇到一個異步請求，立即返回并記住本次執行到了標識2，然后請求完畢后從標識2的下一行恢復執行。那么現在的任務就是如果打標識以及在異步請求完畢后如何從標識位置開始恢復執行。
yield 與 異步
如果你熟悉C# 2.0加入的迭代器特性，你就會發現yield就是我們可以用來打標識的東西。看下面的代碼：
- public IEnumerator<int> Demo()
- {
- //code 1
- yield return 1;
- //code 2
- yield return 2;
- //code 3
- yield return 3;
- }
經過編譯會生成類似下面的代碼（偽代碼，相差很遠，只是意義相近，想要了解詳情的同學可以自行打開Reflector觀看）：
- public IEnumerator<int> Demo()
- {
- return new GeneratedEnumerator();
- }
- public class GeneratedEnumerator
- {
- private int state = 0;
- private int currentValue = 0;
- public bool MoveNext()
- {
- switch(state)
- {
- case 0:
- //code 1
- currentValue = 1;
- state = 1;
- return true;
- case 1:
- //code 2
- currentValue = 2;
- state = 2;
- return true;
- case 2:
- //code 3
- currentValue = 3;
- state = 3;
- return true;
- default:return false;
- }
- }
- public int Current{get{return currentValue;}}
- }
對，C#編譯器將其翻譯成了一個狀態機。yield return就好像做了很多標記，MoveNext每調用一次，它就執行下個yield return之前的代碼，然后立即返回。
好，現在打標記的功能有了，我們如何在異步請求執行完畢后恢復調用呢？通過上面的代碼，你可能已經想到了，我們這里恢復調用只需要再次調用一下MoveNext就行了，那個狀態機會幫我們處理一切。
那我們改造我們的異步代碼：
- public IEnumerator<int> Download()
- {
- var request = HttpWebRequest.Create("http://www.google.com");
- var asyncResult1 = request.BeginGetResponse(...);
- yield return 1;
- var response = request.EndGetResponse(asyncResult1);
- using(stream = response.GetResponseStream())
- {
- var asyncResult2 = stream.BeginRead(buffer, 0, 1024, ...);
- yield return 1;
- var actualRead = stream.EndRead(asyncResult2);
- }
- }
標記打好了，考慮如何在異步調用完執行一下MoveNext吧。
呵呵，你還記得異步調用的那個AsyncCallback回調么？也就是異步請求執行完會調用的那個。如果我們向發起異步請求的BeginXXX方法傳入一個AsyncCallback，而這個回調里會調用MoveNext怎么樣？
- public IEnumerator<int> Download(Context context)
- {
- var request = HttpWebRequest.Create("http://www.google.com");
- var asyncResult1 = request.BeginGetResponse(context.Continue(),null);
- yield return 1;
- var response = request.EndGetResponse(asyncResult1);
- using(stream = response.GetResponseStream())
- {
- var asyncResult2 = stream.BeginRead(buffer, 0, 1024, context.Continue(),null);
- yield return 1;
- var actualRead = stream.EndRead(asyncResult2);
- }
- }
Continue方法的定義是：
- public class Context
- {
- //...
- private IEnumerator enumerator;
- public AsyncCallback Continue()
- {
- return (ar) => enumerator.MoveNext();
- }
- }
在調用Continue方法之前，Context類還必須保存有Download方法返回的IEnumerator，所以：
- public class Context
- {
- //...
- private IEnumerator enumerator;
- public AsyncCallback Continue()
- {
- return (ar) => enumerator.MoveNext();
- }
- public void Run(IEnumerator enumerator)
- {
- this.enumerator = enumerator;
- enumerator.MoveNext();
- }
- }
那調用Download的方法就可以寫成：
- public void Main()
- {
- Program p = new Program();
- Context context = new Context();
- context.Run(p.Download(context));
- }
除了執行方式的不同外，我們幾乎就可以像同步的方式那樣編寫異步的代碼了。
- public class Context
- {
- private IEnumerator enumerator;
- public AsyncCallback Continue()
- {
- return (ar) => enumerator.MoveNext();
- }
- public void Run(IEnumerator enumerator)
- {
- this.enumerator = enumerator;
- enumerator.MoveNext();
- }
- }
- private void btnDownload_click(object sender,EventArgs e)
- {
- Context context = new Context();
- context.Run(Download(context));
- }
- private IEnumerator<int> Download(Context context)
- {
- var request = HttpWebRequest.Create("http://www.google.com");
- var asyncResult1 = request.BeginGetResponse(context.Continue(),null);
- yield return 1;
- var response = request.EndGetResponse(asyncResult1);
- using(stream = response.GetResponseStream()) {
- var asyncResult2 = stream.BeginRead(buffer, 0, 1024, context.Continue(),null);
- yield return 1;
- var actualRead = stream.EndRead(asyncResult2);
- }
- }
完整的代碼如下（為了更好的演示，我將下面代碼改為Winform版本）：
不知道你注意到沒有，我們不僅可以順序的編寫異步代碼，連using這樣的構造也可以使用了。如果你想更深入的理解這段代碼，推薦你使用Reflector查看迭代器最后生成的代碼。我在這里做一下簡短的描述：
1、Context的Run調用時會調用Dowload方法，得到一個IEnumerator對象，我們將該對象保存在Context的實例字段中，以備后用
2、調用該IEnumerator對象的MoveNext方法，該方法會執行到第一個yield return位置，然后返回，這個時候request.BeginGetResponse已經調用，這個時候線程可以干其他的事情了。
3、在BeginGetResponse調用時我們通過Context的Continue方法傳入了一個回調，該回調里會執行剛才保存的IEnumerator對象的MoveNext方法。也就是在BeginGetResponse這個異步請求執行完畢后，會調用MoveNext方法，控制流又回到Download方法，執行到下一個yield return…… 以此類推。
總結
我們發現我們要的東西就是怎樣將順序風格的代碼轉換為CPS方式，如何去尋找發起異步請求這行代碼的continue。由于C#提供了yield這種機制，C#編譯器會為其生產一個狀態機，能夠將控制權在調用代碼和被調用代碼之間交換。
【編輯推薦】
