一起谈.NET技术，.NET中的异步编程-Continuation passing style以及使用yield实现异步

　　传统的异步方式将本来紧凑的代码都分成两部分，不仅仅降低了代码的可读性，还让一些基本的程序构造无法使用，所以大部分开发人员在遇到应该使用异步的地方都忍痛割爱。本来我在本篇文章中想讨论一下.NET世界中已有的几个辅助异步开发的类库，但是经过思考后觉得在这之前介绍一下一些理论知识也许对理解后面的类库以及更新的内容有所帮助。今天我们要讨论的是Continuation Passing Style，简称CPS。

　　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。

　　思路貌似到这儿断了。但是我们是否可以换个角度想想，如果我们能给上面这段代码加上标识：在每个异步请求发起的地方都加一个标识，而标识之后的部分就是continue。

var request = HttpWebRequest.Create("http://www.google.com");

标识1var 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);

}

　　当执行到 标识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));

}

　　除了执行方式的不同外，我们几乎就可以像同步的方式那样编写异步的代码了。

　　完整的代码如下（为了更好的演示，我将下面代码改为Winform版本）：

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(