以前写《.NET gRPC 核心功能初体验》,利用gRPC双向流作了一个打乒乓的Demo,存储消息的对象是
IAsyncEnumerable<T>
,这个异步可枚举泛型接口
支撑了gRPC的实时流式通讯。html
本文我将回顾分享前端
.NET诞生之初,就经过IEnumerable、IEnumerator提供迭代能力,
前者表明具有可枚举的性质,后者表明可被枚举的方式。
(看你骨骼惊奇,再送你一本《2021年了,IEnumerable
、IEnumerator
接口还傻傻分不清楚?》)
若是你真的使用强类型IEnumerable/IEnumerator来产生/消费可枚举类型,会发现要写不少琐碎代码。web
C#推出的yield return
迭代器语法糖,简化了产生可枚举类型的编写过程。(编译器将yield return转换为状态机代码来实现IEnumerable,IEnumerator)编程
yield 关键字能够执行状态迭代,并逐个返回枚举元素,在返回数据时,无需建立临时集合来存储数据。api
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并在内部回调)异步
☺️以上也看出微软为帮助咱们更快速优雅地编写代码,给了不少糖,编译器作了不少事情。async
C#提供了迭代、异步的快捷方式,可否将二者结合?
二者结合的效果就是: 但愿在数据就绪时,接受并处理数据,但不会以阻塞CPU的sing是等待,这在lot流式数据中很常见,异步编程
有一只爬虫要经过列表页上的连接,抓取连接背后的html内容并显示。
这是一个[相互独立的长耗时行为的集合(假设分别耗时5,4,3,2,1s)],
咱们使用C#8.0异步可枚举类型IAsyncEnumerable
与同步版本IEmunerable
相似,IAsyncEnumerable 也有对应的IAsyncEnumerator迭代器,迭代器的实现过程决定了消费的顺序。
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关键字,决定了IAsyncEnymerator的实现;
以上代码将使得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/APs_API
浏览器兼容列表: https://developer.mozilla.org/en-US/docs/Web/API_API#browser_compatibility
对于web应用,这着实能提升 可交互性: 想象以前含多个长耗时行为的列表数据,如今没必要等待全部数据,,配以loading,谁家完成谁加载,效果杠杠。