ET介紹——CSharp協程

来源:https://www.cnblogs.com/flamesky/archive/2023/05/18/17413661.html
-Advertisement-
Play Games

什麼是協程 說到協程,我們先瞭解什麼是非同步,非同步簡單說來就是,我要發起一個調用,但是這個被調用方(可能是其它線程,也可能是IO)出結果需要一段時間,我不想讓這個調用阻塞住調用方的整個線程,因此傳給被調用方一個回調函數,被調用方運行完成後回調這個回調函數就能通知調用方繼續往下執行。舉個例子:下麵的代碼 ...


什麼是協程

說到協程,我們先瞭解什麼是非同步,非同步簡單說來就是,我要發起一個調用,但是這個被調用方(可能是其它線程,也可能是IO)出結果需要一段時間,我不想讓這個調用阻塞住調用方的整個線程,因此傳給被調用方一個回調函數,被調用方運行完成後回調這個回調函數就能通知調用方繼續往下執行。舉個例子:
下麵的代碼,主線程一直迴圈,每迴圈一次sleep 1毫秒,計數加一,每10000次列印一次。

private static void Main()
        {
            int loopCount = 0;
            while (true)
            {
                int temp = watcherValue;
                
                Thread.Sleep(1);
                
                ++loopCount;
                if (loopCount % 10000 == 0)
                {
                    Console.WriteLine($"loop count: {loopCount}");
                }
            }
        }

 

這時我需要加個功能,在程式一開始,我希望在5秒鐘之後列印出loopCount的值。看到5秒後我們可以想到Sleep方法,它會阻塞線程一定時間然後繼續執行。我們顯然不能在主線程中Sleep,因為會破壞掉每10000次計數列印一次的邏輯。

// example2_1
    class Program
    {
        private static int loopCount = 0;

        private static void Main()
        {
            OneThreadSynchronizationContext _ = OneThreadSynchronizationContext.Instance;
            
            WaitTimeAsync(5000, WaitTimeFinishCallback);
            
            while (true)
            {
                OneThreadSynchronizationContext.Instance.Update();
                
                Thread.Sleep(1);
                
                ++loopCount;
                if (loopCount % 10000 == 0)
                {
                    Console.WriteLine($"loop count: {loopCount}");
                }
            }
        }

        private static void WaitTimeAsync(int waitTime, Action action)
        {
            Thread thread = new Thread(()=>WaitTime(waitTime, action));
            thread.Start();
        }
        
        private static void WaitTimeFinishCallback()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
        }

        /// <summary>
        /// 在另外的線程等待
        /// </summary>
        private static void WaitTime(int waitTime, Action action)
        {
            Thread.Sleep(waitTime);
            
            // 將action扔回主線程執行
            OneThreadSynchronizationContext.Instance.Post((o)=>action(), null);
        }
    }

 

我們在這裡設計了一個WaitTimeAsync方法,WaitTimeAsync其實就是一個典型的非同步方法,它從主線程發起調用,傳入了一個WaitTimeFinishCallback回調方法做參數,開啟了一個線程,線程Sleep一定時間後,將傳過來的回調扔回到主線程執行。OneThreadSynchronizationContext是一個跨線程隊列,任何線程可以往裡面扔委托,OneThreadSynchronizationContext的Update方法在主線程中調用,會將這些委托取出來放到主線程執行。為什麼回調方法需要扔回到主線程執行呢?因為回調方法中讀取了loopCount,loopCount在主線程中也有讀寫,所以要麼加鎖,要麼永遠保證只在主線程中讀寫。加鎖是個不好的做法,代碼中到處是鎖會導致閱讀跟維護困難,很容易產生多線程bug。這種將邏輯打包成委托然後扔回另外一個線程是多線程開發中常用的技巧。

我們可能又有個新需求,WaitTimeFinishCallback執行完成之後,再想等3秒,再列印一下loopCount。

private static void WaitTimeAsync(int waitTime, Action action)
        {
            Thread thread = new Thread(()=>WaitTime(waitTime, action));
            thread.Start();
        }
        private static void WaitTimeFinishCallback()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
            WaitTimeAsync(3000, WaitTimeFinishCallback2);
        }
        
        private static void WaitTimeFinishCallback2()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
        }

 

我們這時還可能改需求,需要在程式啟動5秒後,接下來4秒,再接下來3秒,列印loopCount,也就是上面的邏輯中間再插入一個3秒等待。

private static void WaitTimeAsync(int waitTime, Action action)
        {
            Thread thread = new Thread(()=>WaitTime(waitTime, action));
            thread.Start();
        }
        
        private static void WaitTimeFinishCallback()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
            WaitTimeAsync(4000, WaitTimeFinishCallback3);
        }
        
        private static void WaitTimeFinishCallback3()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
            WaitTimeAsync(3000, WaitTimeFinishCallback2);
        }
        
        private static void WaitTimeFinishCallback2()
        {
            Console.WriteLine($"WaitTimeAsync finsih loopCount的值是: {loopCount}");
        }

 

這樣中間插入一段代碼,顯得非常麻煩。這裡可以回答什麼是協程了,其實這一串串回調就是協程。

ET開源地址地址:egametang/ET: Unity3D Client And C# Server Framework (github.com)   qq群:474643097


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

-Advertisement-
Play Games
更多相關文章
  • 基於java的校園二手交易系統或跳蚤市場設計與實現,java二手交易平臺,二手商城,交易商城,大學生交易平臺,springboot二手交易系統,二手交易平臺,購物平臺,大學生跳蚤平臺設計與實現,閑置物品交易平臺,校園閑置二手。 ...
  • Lambda 表達式(lambda expression)是一個匿名函數,Lambda表達式基於數學中的λ演算得名,直接對應於其中的lambda抽象(lambda abstraction),是一個匿名函數,即沒有函數名的函數。Lambda表達式可以表示閉包,和傳統數學上的意義有區別。 文末有本文重點 ...
  • Java是通過垃圾回收機制回收記憶體,C/C++是通過malloc,free,new,delete手動管理空間。那麼在JNI層,同時存在Java和C/C++的空間時,該如何進行空間的管理呢?本文參考Oracle的官方文檔,對JNI層中空間的管理進行說明。明確哪些內容需要手動調用Delete,哪些不需要... ...
  • 數據集拆分是將一個大型的數據集拆分為多個較小的數據集,可以讓數據更加清晰易懂,也方便對單個數據集進行分析和處理。 同時,分開的數據集也可以分別應用不同的數據分析方法進行處理,更加高效和專業。 數據集合併則是將多個數據集合併成一個大的數據集,可以提供更全面的信息,也可以進行更綜合的數據分析。 同時,數 ...
  • ###第1關 類的繼承 package step1; import java.util.Scanner; class Person { /********** Begin **********/ // 自行設計類的實現 //姓名 private String name; //性別 private S ...
  • 介紹史上最全PYTHON文件類型讀寫庫大盤點!包含常用和不常用的大量文件格式!文本、音頻、視頻應有盡有!廢話不多說!走起來! ...
  • 單線程非同步 前面幾個例子都是多線程實現的非同步,但是非同步顯然不僅僅是多線程的。我們在之前的例子中使用了Sleep來實現時間的等待,每一個計時器都需要使用一個線程,會導致線程切換頻繁,這個實現效率很低,平常是不會這樣做的。一般游戲邏輯中會設計一個單線程的計時器,我們這裡做一個簡單的實現,用來講解單線程異 ...
  • 更好的協程 上文講了一串回調就是協程,顯然這樣寫代碼,增加邏輯,插入邏輯非常容易出錯。我們需要利用非同步語法把這個非同步回調的形式改成同步的形式,幸好C#已經幫我們設計好了,看代碼 // example2_2 class Program { private static int loopCount = ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...