专栏首页全栈码农画像C#8.0宝藏好物Async streams

C#8.0宝藏好物Async streams

之前写《.NET gRPC 核心功能初体验》,利用gRPC双向流做了一个打乒乓的Demo,存储消息的对象是IAsyncEnumerable<T>,这个异步可枚举泛型接口支撑了gRPC的实时流式通信。

本文我将回顾分享

  • foreach/yield return/async await语法糖的本质
  • 如何使用异步流
  • 附加探索: 编写一个更有意义的迭代效果

foreach/ yield return/async await的本质

.NET诞生之初,就通过IEnumerable、IEnumerator提供迭代能力, 前者代表具备可枚举的性质,后者代表可被枚举的方式。 (看你骨骼惊奇,再送你一本《2021年了,IEnumerableIEnumerator接口还傻傻分不清楚?》) 如果你真的使用强类型IEnumerable/IEnumerator来产生/消费可枚举类型,会发现要写很多琐碎代码。

C#推出的yield return迭代器语法糖,简化了产生可枚举类型的编写过程。(编译器将yield return转换为状态机代码来实现IEnumerable,IEnumerator)

yield 关键字可以执行状态迭代,并逐个返回枚举元素,在返回数据时,无需创建临时集合来存储数据。

C#foreach语法糖,简化了消费可枚举类型的编写过程。(编译器将foreach抓换为强类型的方法/属性调用)

IEnumerable src = ...;
IEnumerator e = src.GetEnumerator();
try
{
  while (e.MoveNext()) Use(e.Current);
}
finally { if (e != null) e.Dispose(); }

NET Framework4引入Task,.NET Framework 4.5/C#5.0引入了await/async异步编程语法糖,简化了异步的编写过程。(编译器将await/async语法糖转换为状态机,产生Task并在内部回调)

☺️以上也看出微软为帮助我们更快速优雅地编写代码,给了很多糖,编译器做了很多事情。

C#提供了迭代、异步的快捷方式,能否将两者结合? 两者结合的效果就是:我们希望在数据就绪时,接收并处理数据,但不会以阻塞cpu的形式等待,这在lot流式数据中很常见。

异步迭代

有一只爬虫要通过列表页上的链接,抓取链接背后的html内容并显示。

这是一个[相互独立的长耗时行为的集合(假设分别耗时5,4,3,2,1s)], 我们使用C#8.0异步可枚举类型IAsyncEnumerable,异步 产生/消费枚举元素。

与同步版本IEmunerable类似,IAsyncEnumerable也有对应的IAsyncEnumerator迭代器,迭代器的实现过程决定了foreach消费的顺序。

C#8.0 Asynchronous streams

C#8.0中一个重要的特性是异步流(async stream), 可以轻松创建和消费异步枚举。

返回异步流的方法特征:

  • async修饰符声明
  • 返回IAsyncEnumerable<T>对象
  • 方法包含yield return语句,用来异步持续返回元素
static async Task Main(string[] args)
{
      Console.WriteLine(DateTime.Now + $"\tThreadId:{Thread.CurrentThread.ManagedThreadId}\r\n");

      await foreach (var html in FetchAllHtml())
      {
           Console.WriteLine(DateTime.Now + $"\tThreadId:{Thread.CurrentThread.ManagedThreadId}\t" + $"\toutput:{html}");
      }
      Console.WriteLine("\r\n" + DateTime.Now + $"\tThreadId:{Thread.CurrentThread.ManagedThreadId}\t");
      Console.ReadKey();
 }

 static async IAsyncEnumerable<string> FetchAllHtml()
 {
    for (int i = 5; i >= 1; i--)
    {
        var html = await Task.Delay(i* 1000).ContinueWith((t,i)=> $"html{i}",i);    //  模拟长耗时
        yield return html;
    }
 }

for循环结合yield关键字,决定了IAsyncEnumerator的实现; 以上代码将使得await foreach消费异步枚举时, 采用与for循环一样的顺序,也就是产生异步任务的先后顺序

以上不会等待15s然后一股脑抛出所有数据, 而是根据枚举for循环 依次就绪,依次显示,总共还是耗时15s,每一次枚举都是异步的。

附加思考:产生一个有意思的迭代器

☺️ 但是我内心想,能不能按照完成异步任务的顺序,先完成先消费,这难道不是人之常情,交互体验应该更好。

static async IAsyncEnumerable<string> FetchAllHtml()
{  
    var tasklist= new List<Task<string>>();
    for (int i = 5; i >= 1; i--)
    {
        var t= Task.Delay(i* 1000).ContinueWith((t,i)=>$"html{i}",i);      // 模拟长耗时任务
        tasklist.Add(t);
    }
     while(tasklist.Any())  
    {
       var tFinlish = await Task.WhenAny(tasklist);
       tasklist.Remove(tFinlish); 
       yield return await tFinlish;
    }
}  

上面我先构造了可等待的任务列表,通过Task.WhenAny() 返回异步任务先完成的迭代元素。

以上总耗时取决于 耗时最长的那个枚举任务:5s


.NETCore 3.1 已经可以在webapi中使用异步流,意味着我们可将流式数据返回到HTTP响应。

前端也已经有试验性的Streams API可以消费流式数据。

传送门: https://developer.mozilla.org/en-US/docs/Web/API/Streams_API 浏览器兼容列表: https://developer.mozilla.org/en-US/docs/Web/API/Streams_API#browser_compatibility

对于web应用,这着实能提高 可交互性: 想象之前含多个长耗时行为的列表数据,现在不必等待所有数据,配以loading,谁先完成谁加载,效果杠杠。

本文分享自微信公众号 - Dotnet Plus(nodotnet),作者:小码甲

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2021-03-30

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 聊一聊C# 8.0中的await foreach

    很开心今天能与大家一起聊聊C# 8.0中的新特性-Async Streams,一般人通常看到这个词表情是这样.

    码农阿宇
  • 如何在旧版本的 .NET Core / Framework 中使用 C# 8 的异步流(IAsyncDisposable / IAsyncEnumerable / IAsyncEnumerator)

    2020-01-03 09:17

    walterlv
  • C# 8中的Async Streams

    C# 5引入了Async/Await,用以提高用户界面响应能力和对Web资源的访问能力。换句话说,异步方法用于执行不阻塞线程并返回一个标量结果的异步操作。

    架构师修行之路
  • 刷新.NET

    .NET Core 发布的那一天起,它在完成自我刷新的过程,一切为了适应未来,云原生。不仅仅跨平台那么简单。

    李明成
  • Scalaz(57)- scalaz-stream: fs2-多线程编程,fs2 concurrency

        fs2的多线程编程模式不但提供了无阻碍I/O(java nio)能力,更为并行运算提供了良好的编程工具。在进入并行运算讨论前我们先示范一下fs2 pip...

    用户1150956
  • Oracle Linux 8.0 发布

    Oracle Linux 8.0 发布了,更新包中包括基础 BaseOS 和 Application Streams,其中 BaseOS 提供运行环境的用户空间...

    Debian中国
  • DAY9:阅读CUDA异步并发执行中的Streams

    GPUS Lady
  • VisualStudio 2019 尝试使用 C# 8.0 新的方式 可空类型Range异步的流

    在安装了几天之后,终于有了 VisualStudio 2019 于是再安装了 dotnet core 3.0 预览版,现在可以来尝试使用 C# 8.0 的新方式

    林德熙
  • C# 8 - using声明 和 异步流

    尽管.NET Core运行时有垃圾收集器(GC)来负责内存清理工作,但是我们还是要自己确保当非托管资源不再使用的时候应该被清理掉。以前针对实现了IDisposa...

    solenovex

扫码关注云+社区

领取腾讯云代金券