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
  • .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...
  • 目錄前言PostgreSql安裝測試額外Nuget安裝Person.cs模擬運行Navicate連postgresql解決方案Garnet為什麼要選擇Garnet而不是RedisRedis不再開源Windows版的Redis是由微軟維護的Windows Redis版本老舊,後續可能不再更新Garne ...
  • C#TMS系統代碼-聯表報表學習 領導被裁了之後很快就有人上任了,幾乎是無縫銜接,很難讓我不想到這早就決定好了。我的職責沒有任何變化。感受下來這個系統封裝程度很高,我只要會調用方法就行。這個系統交付之後不會有太多問題,更多應該是做小需求,有大的開發任務應該也是第二期的事,嗯?怎麼感覺我變成運維了?而 ...
  • 我在隨筆《EAV模型(實體-屬性-值)的設計和低代碼的處理方案(1)》中介紹了一些基本的EAV模型設計知識和基於Winform場景下低代碼(或者說無代碼)的一些實現思路,在本篇隨筆中,我們來分析一下這種針對通用業務,且只需定義就能構建業務模塊存儲和界面的解決方案,其中的數據查詢處理的操作。 ...
  • 對某個遠程伺服器啟用和設置NTP服務(Windows系統) 打開註冊表 HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\W32Time\TimeProviders\NtpServer 將 Enabled 的值設置為 1,這將啟用NTP伺服器功 ...
  • title: Django信號與擴展:深入理解與實踐 date: 2024/5/15 22:40:52 updated: 2024/5/15 22:40:52 categories: 後端開發 tags: Django 信號 松耦合 觀察者 擴展 安全 性能 第一部分:Django信號基礎 Djan ...
  • 使用xadmin2遇到的問題&解決 環境配置: 使用的模塊版本: 關聯的包 Django 3.2.15 mysqlclient 2.2.4 xadmin 2.0.1 django-crispy-forms >= 1.6.0 django-import-export >= 0.5.1 django-r ...
  • 今天我打算整點兒不一樣的內容,通過之前學習的TransformerMap和LazyMap鏈,想搞點不一樣的,所以我關註了另外一條鏈DefaultedMap鏈,主要調用鏈為: 調用鏈詳細描述: ObjectInputStream.readObject() DefaultedMap.readObject ...
  • 後端應用級開發者該如何擁抱 AI GC?就是在這樣的一個大的浪潮下,我們的傳統的應用級開發者。我們該如何選擇職業或者是如何去快速轉型,跟上這樣的一個行業的一個浪潮? 0 AI金字塔模型 越往上它的整個難度就是職業機會也好,或者說是整個的這個運作也好,它的難度會越大,然後越往下機會就會越多,所以這是一 ...
  • @Autowired是Spring框架提供的註解,@Resource是Java EE 5規範提供的註解。 @Autowired預設按照類型自動裝配,而@Resource預設按照名稱自動裝配。 @Autowired支持@Qualifier註解來指定裝配哪一個具有相同類型的bean,而@Resourc... ...