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
  • C#TMS系統代碼-基礎頁面BaseCity學習 本人純新手,剛進公司跟領導報道,我說我是java全棧,他問我會不會C#,我說大學學過,他說這個TMS系統就給你來管了。外包已經把代碼給我了,這幾天先把增刪改查的代碼背一下,說不定後面就要趕鴨子上架了 Service頁面 //using => impo ...
  • 委托與事件 委托 委托的定義 委托是C#中的一種類型,用於存儲對方法的引用。它允許將方法作為參數傳遞給其他方法,實現回調、事件處理和動態調用等功能。通俗來講,就是委托包含方法的記憶體地址,方法匹配與委托相同的簽名,因此通過使用正確的參數類型來調用方法。 委托的特性 引用方法:委托允許存儲對方法的引用, ...
  • 前言 這幾天閑來沒事看看ABP vNext的文檔和源碼,關於關於依賴註入(屬性註入)這塊兒產生了興趣。 我們都知道。Volo.ABP 依賴註入容器使用了第三方組件Autofac實現的。有三種註入方式,構造函數註入和方法註入和屬性註入。 ABP的屬性註入原則參考如下: 這時候我就開始疑惑了,因為我知道 ...
  • C#TMS系統代碼-業務頁面ShippingNotice學習 學一個業務頁面,ok,領導開完會就被裁掉了,很突然啊,他收拾東西的時候我還以為他要旅游提前請假了,還在尋思為什麼回家連自己買的幾箱飲料都要叫跑腿帶走,怕被偷嗎?還好我在他開會之前拿了兩瓶芬達 感覺感覺前面的BaseCity差不太多,這邊的 ...
  • 概述:在C#中,通過`Expression`類、`AndAlso`和`OrElse`方法可組合兩個`Expression<Func<T, bool>>`,實現多條件動態查詢。通過創建表達式樹,可輕鬆構建複雜的查詢條件。 在C#中,可以使用AndAlso和OrElse方法組合兩個Expression< ...
  • 閑來無聊在我的Biwen.QuickApi中實現一下極簡的事件匯流排,其實代碼還是蠻簡單的,對於初學者可能有些幫助 就貼出來,有什麼不足的地方也歡迎板磚交流~ 首先定義一個事件約定的空介面 public interface IEvent{} 然後定義事件訂閱者介面 public interface I ...
  • 1. 案例 成某三甲醫預約系統, 該項目在2024年初進行上線測試,在正常運行了兩天後,業務系統報錯:The connection pool has been exhausted, either raise MaxPoolSize (currently 800) or Timeout (curren ...
  • 背景 我們有些工具在 Web 版中已經有了很好的實踐,而在 WPF 中重新開發也是一種費時費力的操作,那麼直接集成則是最省事省力的方法了。 思路解釋 為什麼要使用 WPF?莫問為什麼,老 C# 開發的堅持,另外因為 Windows 上已經裝了 Webview2/edge 整體打包比 electron ...
  • EDP是一套集組織架構,許可權框架【功能許可權,操作許可權,數據訪問許可權,WebApi許可權】,自動化日誌,動態Interface,WebApi管理等基礎功能於一體的,基於.net的企業應用開發框架。通過友好的編碼方式實現數據行、列許可權的管控。 ...
  • .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...