通過一個示例形象地理解C# async await非同步

来源:https://www.cnblogs.com/s0611163/archive/2023/01/30/17076494.html
-Advertisement-
Play Games

前言 相信大家看過不少講C# async await的文章,博客園就能搜到很多,但還是有很多C#程式員不明白。 如果搞不明白,其實也不影響使用。但有人就會疑惑,為什麼要用非同步?我感覺它更慢了,跟同步有啥區別? 有的人研究深入,比如去研究狀態機,可能會明白其中的原理。但深入研究的畢竟少數。有的人寫一些 ...


前言

相信大家看過不少講C# async await的文章,博客園就能搜到很多,但還是有很多C#程式員不明白。
如果搞不明白,其實也不影響使用。但有人就會疑惑,為什麼要用非同步?我感覺它更慢了,跟同步有啥區別?
有的人研究深入,比如去研究狀態機,可能會明白其中的原理。但深入研究的畢竟少數。有的人寫一些示例,有的專業有的不是很專業,但看的人仍有不明白的。
所以我寫了一個示例,儘量簡單,讓大家形象地理解一下C#的非同步。
就是一個示例,沒有什麼理論講解,大家自己測試自己思考。如果大家看理論講解,就能明白,我也就沒必要寫這個示例了。

示例的測試步驟

先直接測試,看結果,下麵再放代碼

  1. 點擊VS2022的啟動按鈕,啟動程式,它會先啟動Server工程,再啟動AsyncAwaitDemo2工程
  2. 快速連續點擊5次button1(調用的是同步方法)
  3. 快速連續點擊5次button2(調用的是非同步方法)
  4. 觀察思考輸出結果,體會非同步的好處

測試截圖

測試截圖說明

  1. 5次點擊button1,界面是卡住的,但不影響輸出結果,5次點擊button2界面不會卡住(截圖看不出來,測試過程中有體現)
  2. 5次點擊button1,共5次同步請求,每個請求耗時2秒,一共耗時10秒,嫌慢,想要併發請求?那你可能要使用Task.Run,線上程中調用同步方法,這又涉及到線程占用問題
  3. 5次點擊button2,共5次非同步請求,每個請求耗時2秒,但一共耗時只有2秒,註意,代碼中請求web api介面使用Thread類了嗎?沒有!使用Task.Run了嗎?沒有!使用了async await語法糖,是不是比通過new Thread或Task.Run要簡單多了?就像寫同步代碼那樣,卻實現了非同步併發的效果。

一個問題

其它博客也寫過示例,是控制台示例,輸出的主線程ID,是有可能會變化的。這裡是Winform示例,輸出的主線程ID始終是UI線程的ID,即是1;
我沒有演示主線程ID發生變化的情況,這樣會使示例變得複雜一點,不容易看明白。

服務端

服務端和客戶端是兩個獨立的工程,測試時在一起跑,但其實可以分開部署,部署到不同的機器上
服務端是一個web api介面,用.NET 6、VS2022開發,代碼如下:

[ApiController]
[Route("[controller]")]
public class TestController : ControllerBase
{
    [HttpGet]
    [Route("[action]")]
    public async Task<string> ForPreheat()
    {
        return await Task.FromResult("預熱返回結果");
    }

    [HttpGet]
    [Route("[action]")]
    public async Task<string> Get()
    {
        await Task.Delay(2000); //模擬耗時操作
        return "測試返回結果";
    }
}

客戶端

大家看客戶端代碼時,不需要關心服務端怎麼寫
客戶端是一個Winform工程,用.NET 6、VS2022開發,代碼如下:

public partial class Form1 : Form
{
    private string _urlPreheat = "http://localhost:5028/Test/ForPreheat";
    private string _url = "http://localhost:5028/Test/Get";
    private int _index1 = 1; //測試時請快速連續點擊5次button1
    private int _index2 = 1; //測試時請快速連續點擊5次button2
    private Stopwatch _sw1;
    private Stopwatch _sw2;

    public Form1()
    {
        InitializeComponent();
    }

    private async void Form1_Load(object sender, EventArgs e)
    {
        Request(_urlPreheat); //預熱
        await RequestAsync(_urlPreheat); //預熱
        Log("==== 預熱請求結束 ====================================");
    }

    #region Log
    private void Log(string msg)
    {
        msg = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}  {msg}\r\n";

        if (this.InvokeRequired)
        {
            this.BeginInvoke(new Action(() =>
            {
                txtLog.AppendText(msg);
            }));
        }
        else
        {
            txtLog.AppendText(msg);
        }
    }
    #endregion

    private async void button1_Click(object sender, EventArgs e)
    {
        await Task.Delay(1000); //為了能1秒內快速點擊幾次,為了能寫這句代碼button1_Click前面加了async,但後面的代碼仍是同步調用;如果不加這句,第一次點擊界面就卡死了,無法連續點擊5次。

        Log("==== 同步請求開始 ====================================");
        if (_index1 == 1) _sw1 = Stopwatch.StartNew();

        Request(_url);

        if (_index1 == 5)
        {
            _sw1.Stop();
            Log($"5次請求耗時:{_sw1.Elapsed.TotalSeconds:0.000}秒");
        }
        _index1++;
    }

    private async void button2_Click(object sender, EventArgs e)
    {
        await Task.Delay(1000); //為了和button1保持一致

        Log("==== 非同步請求開始 ====================================");
        if (_index2 == 1) _sw2 = Stopwatch.StartNew();

        await RequestAsync(_url);

        if (_index2 == 5)
        {
            _sw2.Stop();
            Log($"5次請求耗時:{_sw2.Elapsed.TotalSeconds:0.000}秒");
        }
        _index2++;
    }

    private async Task RequestAsync(string url)
    {
        Stopwatch sw = Stopwatch.StartNew();
        HttpClient httpClient = HttpClientFactory.GetClient();
        var result = await (await httpClient.GetAsync(url)).Content.ReadAsStringAsync();
        sw.Stop();
        Log($"線程ID={Thread.CurrentThread.ManagedThreadId},請求耗時:{sw.Elapsed.TotalSeconds:0.000}秒,返回內容長度:{result.Length}");
    }

    private void Request(string url)
    {
        Stopwatch sw = Stopwatch.StartNew();
        var result = HttpUtil.HttpGet(url);
        sw.Stop();
        Log($"線程ID={Thread.CurrentThread.ManagedThreadId},請求耗時:{sw.Elapsed.TotalSeconds:0.000}秒,返回內容長度:{result.Length}");
    }
}

思考

把button2_Click方法中的await RequestAsync(_url);修改為兩行:

await RequestAsync(_url);
await RequestAsync(_url);

那麼5次點擊,每次點擊請求2次,共5×2=10次請求,請問這10次請求的總耗時大約是幾秒?
答案是4秒,為什麼?
因為每次點擊的2次請求是順序的,耗時是2+2=4秒,而5次點擊是併發的,沒有增加耗時時長

Demo完整代碼

https://gitee.com/s0611163/AsyncAwaitDemo2

流程圖

最後,我畫了兩個流程圖,但這兩個流程圖可能畫的很不專業,所以僅供參考
button1點擊5次的流程圖:

button2點擊5次的流程圖:

我之前說過,非同步的本質是回調,這句話是否正確我也不知道,主要是為了大家理解非同步。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 上一篇說了關於MDC跨線程為null的理解,而本講主要說一下,如何去解決它,事實上,Hystrix為我們留了這個口,我們只需要繼承HystrixConcurrencyStrategy,然後重寫wrapCallable方法,再把這個重寫的對象註冊到Hystrix里就可以了,跨線程共用數據,可以使用阿裡 ...
  • 本文已收錄至Github,推薦閱讀 👉 Java隨想錄 微信公眾號:Java隨想錄 CSDN: 碼農BookSea 世界上最快樂的事,莫過於為理想而奮鬥。——蘇格拉底 HotSpot使用的是可達性分析演算法,該演算法需要進行根節點枚舉,查找根節點枚舉的過程要做到高效並非一件容易的事情,現在Java應用 ...
  • 本文已收錄至Github,推薦閱讀 👉 Java隨想錄 微信公眾號:Java隨想錄 CSDN: 碼農BookSea 知道的越多,才知知道的越少。——蘇格拉底 在堆裡面存放著Java世界中幾乎所有的對象實例,垃圾收集器在對堆進行回收前,第一件事情就是要確定這些對象之中哪些還“存活”著,哪些已經“死去 ...
  • 卸載jdk 找到jdk安裝目錄(在環境變數裡面找到JAVA_HOME的值就是jdk目錄) 在環境變數裡面刪除JAVA_HOME和Path裡面與JAVA_HOME相關的兩個 打開dos視窗輸入java -version驗證 安裝jdk 搜索jdk直接下載 記住安裝路徑 配置環境 我的電腦-右鍵-屬性- ...
  • 這篇文章主要描述RPC框架中的非同步與安全,包括服務調用方和服務提供方的非同步計算設計方案,服務調用方與服務提供方之間的身份驗證以及服務提供方和服務發現之間的安全設計。 ...
  • 集合框架體系Collection和Map常用API【彙總】 Collection公共的方法 Collection是單列結合的頂層介面,它的方法是所有單列集合都可以繼承使用的。 //把給定元素添加到集合中 public boolean add(E e) //把給定元素從集合中刪除 public boo ...
  • 本文介紹基於Python語言,按照一定命名規則批量修改多個文件的文件名的方法。 已知現有一個文件夾,其中包括班級所有同學上交的作業文件,每人一份;所有作業文件命名格式統一,都是地信1701_姓名_學習心得格式。 現需要對每一位同學的作業文件加以改名,有很多種需求。 第一種需求,將每一位同學作業文件名 ...
  • Python 是一種代表簡單思想的語言,其語法相對簡單,很容易上手。不過,如果就此小視 Python 語法的精妙和深邃,那就大錯特錯了。本文精心篩選了最能展現 Python 語法之精妙的十個知識點,並附上詳細的實例代碼。如能在實戰中融會貫通、靈活使用,必將使代碼更為精煉、高效,同時也會極大提升代碼B ...
一周排行
    -Advertisement-
    Play Games
  • 一、openKylin簡介 openKylin(開放麒麟) 社區是在開源、自願、平等和協作的基礎上,由基礎軟硬體企業、非營利性組織、社團組織、高等院校、科研機構和個人開發者共同創立的一個開源社區,致力於通過開源、開放的社區合作,構建桌面操作系統開源社區,推動Linux開源技術及其軟硬體生態繁榮發展。 ...
  • 簡介 Flurl是一個用於構建基於HTTP請求的C#代碼的庫。它的主要目的是簡化和優雅地處理網路請求(只用很少的代碼完成請求)。Flurl提供了一種簡單的方法來構建GET、POST、PUT等類型的請求,以及處理響應和異常。它還提供了一些高級功能,如鏈式調用、緩存請求結果、自動重定向等。本文將介紹Fl ...
  • 一:背景 1. 講故事 最近也挺奇怪,看到了兩起 CPU 爆高的案例,且誘因也是一致的,覺得有一些代表性,合併分享出來幫助大家來避坑吧,閑話不多說,直接上 windbg 分析。 二:WinDbg 分析 1. CPU 真的爆高嗎 這裡要提醒一下,別人說爆高不一定真的就是爆高,我們一定要拿數據說話,可以 ...
  • 剛開始寫文章,封裝Base基類的時候,添加了trycatch異常塊,不過當時沒有去記錄日誌,直接return了。有小伙伴勸我不要吃了Exception 其實沒有啦,項目剛開始,我覺得先做好整體結構比較好。像是蓋樓一樣。先把樓體建造出來,然後再一步一步的美化完善。 基礎的倉儲模式已經ok,Autofa ...
  • 框架目標 什麼是框架,框架能做到什麼? 把一個方向的技術研發做封裝,具備通用性,讓使用框架的開發者用起來很輕鬆。 屬性: 通用性 健壯性 穩定性 擴展性 高性能 組件化 跨平臺 從零開始-搭建框架 建立項目 主鍵查詢功能開發 綁定實體 一步一步的給大家推導: 一邊寫一邊測試 從零開始--搭建框架 1 ...
  • 大家好,我是沙漠盡頭的狼。 本方首發於Dotnet9,介紹使用dnSpy調試第三方.NET庫源碼,行文目錄: 安裝dnSpy 編寫示常式序 調試示常式序 調試.NET庫原生方法 總結 1. 安裝dnSpy dnSpy是一款功能強大的.NET程式反編譯工具,可以對.NET程式進行反編譯,代替庫文檔的功 ...
  • 在`Windows`操作系統中,每個進程的虛擬地址空間都被劃分為若幹記憶體塊,每個記憶體塊都具有一些屬性,如記憶體大小、保護模式、類型等。這些屬性可以通過`VirtualQueryEx`函數查詢得到。該函數可用於查詢進程虛擬地址空間中的記憶體信息的函數。它的作用類似於`Windows`操作系統中的`Task... ...
  • 背景介紹 1,最近有一個大數據量插入的操作入庫的業務場景,需要先做一些其他修改操作,然後在執行插入操作,由於插入數據可能會很多,用到多線程去拆分數據並行處理來提高響應時間,如果有一個線程執行失敗,則全部回滾。 2,在spring中可以使用@Transactional註解去控制事務,使出現異常時會進行 ...
  • 線程(thread)是操作系統能夠進行運算調度的最小單位。它被包含在進程之中,是進程中的實際 運作單位。一條線程指的是進程中一個單一順序的控制流,一個進程中可以併發多個線程,每條線 程並行執行不同的任務。 ...
  • 發現Java 21的StringBuilder和StringBuffer中多了repeat方法: /** * @throws IllegalArgumentException {@inheritDoc} * * @since 21 */ @Override public StringBuilder ...