C 8 0 寶藏好物 Async streams

2022-07-13 10:39:11 字數 2753 閱讀 3393

之前寫《.net grpc 核心功能初體驗》,利用grpc雙向流做了乙個打桌球的demo,儲存訊息的物件是iasyncenumerable,這個非同步可列舉泛型介面支撐了grpc的實時流式通訊。

本文我將回顧分享

foreach/ yield return/async await的本質

.net誕生之初,就通過ienumerable、ienumerator提供迭代能力,

前者代表具備可列舉的性質,後者代表可被列舉的方式。

(看你骨骼驚奇,再送你一本《2023年了,ienumerableienumerator介面還傻傻分不清楚?》)

如果你真的使用強型別ienumerable/ienumerator來產生/消費可列舉型別,會發現要寫很多瑣碎**。

c#推出的yield return迭代器語法糖,簡化了產生可列舉型別的編寫過程。(編譯器將yield return轉換為狀態機**來實現ienumerable,ienumerator)

yield 關鍵字可以執行狀態迭代,並逐個返回列舉元素,在返回資料時,無需建立臨時集合來儲存資料。

c#foreach語法糖,簡化了消費可列舉型別的編寫過程。(編譯器將foreach抓換為強型別的方法/屬性呼叫)

ienumerable src = ...;

ienumerator e = src.getenumerator();

tryfinally

.net framework4引入task,.net framework 4.5/c#5.0引入了await/async非同步程式設計語法糖,簡化了非同步程式設計的程式設計過程。(編譯器將await/async語法糖轉換為狀態機,產生task並在內部**)

☺️以上也看出微軟為幫助我們更快速優雅地編寫**,給了很多糖,編譯器做了很多事情。

c#提供了迭代、非同步的快捷方式,能否將兩者結合?

兩者結合的效果就是: 希望在資料就緒時,接受並處理資料,但不會以阻塞cpu的sing是等待,這在lot流式資料中很常見,

非同步迭代

有乙隻爬蟲要通過列表頁上的鏈結,抓取鏈結背後的html內容並顯示。

這是乙個[相互獨立的長耗時行為的集合(假設分別耗時5,4,3,2,1s)],

我們使用c#8.0非同步可列舉型別iasyncenumerable,非同步產生/消費列舉元素。

與同步版本iemunerable類似,iasyncenumerable也有對應的iasyncenumerator迭代器,迭代器的實現過程決定了消費的順序。

c#8.0 asynchronous streams

c#8.0中乙個重要的特性是非同步流(async stream), 可以輕鬆建立和消費非同步列舉。

返回非同步流的方法特徵:

static async task main(string args)

\r\n");

await foreach (var html in fetchallhtml())

\t" + $"\toutput:");

}console.writeline("\r\n" + datetime.now + $"\tthreadid:\t");

console.readkey();

} static async iasyncenumerablefetchallhtml()

",i); // 模擬長耗時

yield return html;}}

for迴圈結合yield關鍵字,決定了iasyncenymerator的實現;

以上**將使得await foreach消費非同步列舉時, 採用與for迴圈一樣的順序,也就是產生非同步任務的先後順序

以上不會等待15s然後一股腦丟擲所有資料,而是根據列舉for迴圈,一次就緒,依次顯示,總耗時還是15s,只不過每一步都是非同步的。

附加思考:實現乙個更有意思的迭代器

☺️ 但是我內心想,能不能按照完成非同步任務的順序,先完成先消費,這難道不是人之常情,互動體驗應該更好。

static async iasyncenumerablefetchallhtml()

",i); // 模擬長耗時任務

tasklist.add(t);

}while(tasklist.any())

}

上面我先構造了可等待的任務列表,通過task.whenany()按照任務完成的順序 返回迭代。

以上總耗時取決於 耗時最長的那個非同步任務5s.

.netcore 3.1 已經可以在webapi中使用非同步流,意味著我們可將流式資料返回到http響應。

前端也已經有試驗性的streams api可以對接消費流式資料。

傳送門:

瀏覽器相容列表: #browser_compatibility

對於web應用,這著實能提高 可互動性:

想象之前含多個長耗時行為的列表資料,現在不必等待所有資料,,配以loading,誰家完成誰載入,效果槓槓。

C 8 0 範圍型別 Range Type

目錄範圍型別 替代substring方法 我們最原始的 如下 static void main string args for int i 1 i 3 i console.readline 這裡我們顯示的定義了我們查詢陣列的索引1 3,並輸出他們的值。毫無疑問,當我們執行程式之後,結果如下 item...

C 8 0新特性介紹

c 語言是在2000發布的,至今已正式發布了7個版本,每個版本都包含了許多令人興奮的新特性和功能更新。同時,c 每個版本的發布都與同時期的 visual studio 以及 net 執行時版本高度耦合,這也有助於開發者更好的學習掌握 c 並將其與 visual studio 以及 net 的使用結合...

C 8 0先睹為快

可空的引用型別 nullable reference types infoq曾對可空的引用型別做了報道,該理念可概括地表述為,引用型別將不再預設可空。因此,開發人員必須使用定義可空值型別的同樣語法 type?顯式地標記乙個引用型別為可空。如果將乙個空值賦值給乙個非可空的引用型別,那麼將會給出乙個編譯...