C# 8 新特性 – 异步流 Asynchronous Streams

2014 年 5 月 5 日

异步流 Asynchronous Streams

这是一个很简单的控制台程序。它有一个 NumberFactory ，它可以根据传递的参数来产生一串数字（ IEnumerable < int> ）。然后在这个程序中把每个数字都打印出来，同时在前边显示出当前的线程ID。

这里面的 NumberFactory 也是非常的简单：

这里我做了延迟，模拟读取外部资源的效果。

运行程序（文章考不到挨个输出的停顿效果）：

可以看到所在线程的ID都是 1 。因为其工作原理就是这样的，程序会阻塞线程以便让Number Factory 来做它的工作。所以说这样不是很理想，最理想的办法是使用C#的异步编程模型，但是在C# 8 之前，这是做不到的。但是从 C# 8 开始，我们就可以这样做了。

首先修改NumberFactory，在Task . Delay (1000) 前边加上await关键字来代替 .Wait() 方法，然后再修改返回类型为 IAsyncEnumberable ，并在前面添加async关键字 :

回到Main方法，需要做出两个修改：

首先，就是在 foreach 循环前面加上 await 关键字，这看起来比较奇怪，但这就是我们遍历异步流的方式。注意是在 foreach 前边加await，而不是在 factory .GenerateNumbers(5) 前边加await。

然后，还需要改变Main方法的返回类型为Task，并加上async关键字。

最后运行程序，看看效果：

可以看到，线程的ID有时候会发生变化，这就是我们想要的效果。在这里流是异步的，当它await任务的时候，该线程是可以去做其它工作的。而当程序继续执行的时候，它确实可能结束于其它的线程。

更详细教程请点击原文链接。