C#線程學習筆記五：線程同步--事件構造

来源:https://www.cnblogs.com/atomy/archive/2019/12/08/11996017.html
-Advertisement-
Play Games

本筆記摘抄自：https://www.cnblogs.com/zhili/archive/2012/07/23/Event_Constructor.html，記錄一下學習過程以備後續查用。 前面講的線程同步主要是用戶模式的（CLR Via C# 一書中是這麼定義的，書中說到線程同步分兩種：一、用戶模 ...


    本筆記摘抄自：https://www.cnblogs.com/zhili/archive/2012/07/23/Event_Constructor.html，記錄一下學習過程以備後續查用。

    前面講的線程同步主要是用戶模式的（CLR Via C# 一書中是這麼定義的，書中說到線程同步分兩種：一、用戶模式構造 二、內核模式構造），對於內核模式構造（指的的是構造操作系內核對象），我們使用.NET Framework中的類

如AutoResetEvent、Semaphore中方法來實現線程同步，其實其內部是調用操作系統中的內核對象來實現的線程同步，此時就會將線程從托管代碼轉為內核代碼。而用戶模式構造，因為沒有調用操作系統內核對象，所以線程只會在用

戶的托管代碼上執行。

    一、WaitHandle基類介紹

    System.Threading命名空間中提供了一個WaitHandle 的抽象基類，此類就是包裝了一個Windows內核對象的句柄（句柄可以理解為標示了對象實例的一個數字，

具體大家可以查資料深入理解下，在這裡只是提出理解句柄也是很重要的）。

    在.NET Framework中提供了從WaitHandle類派生的類，它們的繼承關係為：

    WaitHandle

　    EventWaitHandle

            AutoResetEvent

            ManualResetEvent

        Semaphore

        Mutex

    當我們用構造函數來實例化AutoResetEvent、ManualResetEvent、Semaphore、Mutex這些類的對象時，其內部都調用了Win32 CreateEvent或者CreateEvent函數

或者CreateSemaphore或者CreateMutex函數，這些函數調用返回的句柄值都保存在WaitHandle基類定義的SafeWaitHandle欄位中。

    二、事件(Event)類實現線程同步

    2.1 AutoResetEvent （自動重置事件）

    2.1.1先講講AutoResetEvent類的構造函數，其定義為：

    public AutoResetEvent(bool initialState);

    構造函數中用一個bool 類型的初始狀態來設置AutoResetEvent對象的狀態。如果要將AutoResetEvent對象的初始狀態設置為終止，則傳入bool值為true；

若要設置為非終止，則傳入bool值為false。 

    2.2.2WaitOne方法定義：

    public virtual bool WaitOne(int millisecondsTimeout);

    該方法用來阻塞線程，當在指定的時間間隔還沒有收到一個信號時，將返回false。

    調用Set方法發信號來釋放等待線程。

    在使用過程中WaitOne方法和Set方法都是成對出現的：

        一個用於阻塞線程，等待信號；

        一個用來釋放等待線程(就是說調用set方法來發送一個信號，此時WaitOne接受到信號，就釋放阻塞的線程，線程就可以繼續運行。)

    線程通過調用AutoResetEvent的WaitOne方法來等待信號，如果AutoResetEvent對象為非終止狀態，則線程被阻止，直到線程調用Set方法來恢複線程執行；

如果AutoResetEvent為終止狀態時，則線程不會被阻止，此時AutoResetEvent將立即釋放線程並返回為非終止狀態（指出有線程在使用資源的一種狀態）。

    下麵代碼演示AutoResetEvent的使用：

    class Program
    {
        //創建對象
        public static AutoResetEvent autoResetEvent = new AutoResetEvent(false);

        static void Main(string[] args)
        {
            #region 線程同步：AutoResetEvent的使用
            Console.WriteLine("Main thread start run at: " + DateTime.Now.ToLongTimeString());
            Thread thread = new Thread(WaitOneMethod);
            thread.Start();

            //阻塞主線程3秒鐘
            Thread.Sleep(3000);

            //釋放線程
            autoResetEvent.Set();
            Console.Read();
            #endregion
        }

        /// <summary>
        /// WaitOne方法
        /// </summary>
        public static void WaitOneMethod()
        {
            autoResetEvent.WaitOne();
            Console.WriteLine("Method restart run at: " + DateTime.Now.ToLongTimeString());
        }
    }

    運行結果如下：

    若創建對象時，把它改為public static AutoResetEvent autoResetEvent = new AutoResetEvent(true); ，看到的輸出結果的時間就是一樣的了。因為設置為True時，表示此時

已經為終止狀態了。因此，autoResetEvent.Set()可以理解為將autoResetEvent的狀態設置為終止狀態，因而釋放線程。 

    上面用到的是沒帶參數的WaitOne方法，該方法表示無限制阻塞線程，直到收到一個事件為止（通過Set方法來發送一個信號）。

    通過bool WaitOne(int millisecondsTimeout)，當超時時，線程即使沒收到Set發來的信號，也將不再阻塞線程而讓它繼續運行，只是WaitOne方法返回的值不一樣：

    當收到Set信號時返回值為True，否則返回值為false。

    下麵代碼演示WaitOne(millisecondsTimeout)的使用：

    class Program
    {
        //創建對象
        public static AutoResetEvent autoResetEvent = new AutoResetEvent(false);

        static void Main(string[] args)
        {
            #region 線程同步：WaitOne(millisecondsTimeout)的使用
            Console.WriteLine("Main thread start run at: " + DateTime.Now.ToLongTimeString());
            Thread thread = new Thread(WaitOneTimeoutMethod);
            thread.Start();

            //阻塞主線程3秒鐘
            Thread.Sleep(3000);

            //釋放線程
            autoResetEvent.Set();
            Console.Read();
            #endregion
        }

        /// <summary>
        /// WaitOneTimeout方法
        /// </summary>
        public static void WaitOneTimeoutMethod()
        {
            if (autoResetEvent.WaitOne(2000))
            {
                Console.WriteLine("Get signal to work.");
                Console.WriteLine("Method restart run at: " + DateTime.Now.ToLongTimeString());
            }
            else
            {
                Console.WriteLine("Time out to work.");
                Console.WriteLine("Method restart run at: " + DateTime.Now.ToLongTimeString());
            }
        }
    }

    運行結果如下：

    若把Thread.Sleep(3000);設為Thread.Sleep(1000);，此時線程將收到Set發過來的信號，得到的結果將是Get signal to work，時間相差就只有1秒了。

    2.2 ManualResetEvent(手動重置事件)

    ManualResetEvent和AutoResetEvent的使用方法很類似，因為他們都是從EventWaitHandle類派生的，不過他們還是有些區別：

    2.2.1AutoResetEvent 為終止狀態(true)時，如果線程調用WaitOne方法的話線程是不會被阻止的。此時AutoResetEvent將立即釋放線程並返回到非終止狀態(false)，

在這之後如果線程再次調用WaitOne方法的話，線程將會被阻止。(註：調用WaitOne方法自動改變狀態，僅對初始狀態為終止狀態時有效。)

    2.2.2ManualResetEvent為終止狀態(true)時，如果線程調用WaitOne方法的話線程也是不會被阻止的。此ManualResetEvent將立即釋放線程但不會返回到非終止狀態(false)，

除非我們手動將狀態改為終止狀態(false)，否則在這之後如果線程再次調用WaitOne方法的話，線程不會被阻止。

    下麵代碼演示兩者的區別：

    class Program
    {
        //創建對象
        public static AutoResetEvent autoResetEvent = new AutoResetEvent(false);
        public static ManualResetEvent manualResetEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        {
            #region 線程同步：ManualResetEvent的使用
            Console.WriteLine("Main thread start run at: " + DateTime.Now.ToLongTimeString());

            Thread threadAuto = new Thread(AutoResetEventMethod);
            threadAuto.Start();
            autoResetEvent.Set();
            threadAuto = new Thread(AutoResetEventMethod);
            threadAuto.Start();

            Thread threadManual = new Thread(ManualResetEventMethod);
            threadManual.Start();
            manualResetEvent.Set();
            threadManual = new Thread(ManualResetEventMethod);
            threadManual.Start();

            Console.Read();
            #endregion
        }

        /// <summary>
        /// AutoResetEvent方法
        /// </summary>
        public static void AutoResetEventMethod()
        {
            autoResetEvent.WaitOne();
            Console.WriteLine("Autoresetevent method restart run at: " + DateTime.Now.ToLongTimeString());
        }

        /// <summary>
        /// ManualResetEvent方法
        /// </summary>
        public static void ManualResetEventMethod()
        {
            manualResetEvent.WaitOne();
            Console.WriteLine("Manualresetevent method restart run at: " + DateTime.Now.ToLongTimeString());
        }
    }

    運行結果如下：

    2.3 跨進程之間同步

    內核模式構造可實現同一臺機器上的不同進程中的線程進行同步，因此可以使用AutoResetEvent來實現此功能。此時需要對AutoResetEvent進行命名，但是AutoResetEvent只提供了帶一個參數的構造函數，該如何實現呢？

辦法還是有的，因為AutoResetEvent是繼承自EventWaitHandle類，而EventWaitHandle類有多個構造函數。

    除了之前的方法創建AutoResetEvent對象外，還可以通過EventWaitHandle autoEvent = new EventWaitHandle (false, EventResetMode.Auto,"My");這樣的方式來構造AutoResetEvent對象，此方式指定了名稱。

    下麵代碼演示跨進程之間的線程同步：

    第一個進程代碼：

    class Program
    {
        //創建對象
        public static EventWaitHandle autoEventFirst = new EventWaitHandle(false, EventResetMode.AutoReset, "First");
        public static EventWaitHandle autoEventSecond = new EventWaitHandle(false, EventResetMode.AutoReset, "Second");

        static void Main(string[] args)
        {
            #region 線程同步：跨進程之間的線程同步
            Console.WriteLine("First main thread start run at: " + DateTime.Now.ToLongTimeString());
            Thread thread = new Thread(EventWaitHandleMethod);
            thread.Start();

            //為了有時間去啟動另外一個進程
            Thread.Sleep(15000);
            autoEventFirst.Set();
            autoEventSecond.Set();
            Console.Read();
            #endregion
        }

        /// <summary>
        /// EventWaitHandle方法
        /// </summary>
        public static void EventWaitHandleMethod()
        {
            autoEventFirst.WaitOne();
            Console.WriteLine("First method start at:" + DateTime.Now.ToLongTimeString());
        }
    }

    第二個進程代碼：

    class Program
    {
        //創建對象
        public static EventWaitHandle autoEventSecond = new EventWaitHandle(false, EventResetMode.AutoReset, "Second");
        static void Main(string[] args)
        {
            Console.WriteLine("Second main thread start run at: " + DateTime.Now.ToLongTimeString());
            Thread thread = new Thread(EventWaitHandleMethod);
            thread.Start();
            Console.Read();
        }

        /// <summary>
        /// EventWaitHandle方法
        /// </summary>
        public static void EventWaitHandleMethod()
        {
            autoEventSecond.WaitOne();
            Console.WriteLine("Second method start at:" + DateTime.Now.ToLongTimeString());
        }
    }

    運行結果如下：

    從結果可以看出，第一個進程的autoEventSecond.Set();信號發出後，第二個進程可以收到並釋放線程。 


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

-Advertisement-
Play Games
更多相關文章
  • python 調試大法
    說在前面 我覺得沒有什麼錯誤是調試器無法解決的，如果沒有，那我再說一遍，如果有，那當我沒說 一、拋出異常 可以通過 raise 語句拋出異常，使程式在我們已經知道的缺陷處停下，併進入到 except 語句 raise句法： raise關鍵字 調用的異常函數名 ValueError （這個函數必須是異 ...
  • 對Python中一些“坑”的總結及技巧
    一.賦值即定義 1.運行以下代碼會出現報錯 2.使用global關鍵字解決以上報錯 3.不推薦使用global global總結 x+=1這種是特殊形式產生的錯誤的原因？先引用後賦值，而python動態語言是賦值才算定義，才能被引用。解決辦法，在這條語句前增加x=0之類的賦值語句，或者使用globa ...
  • 如何寫出讓同事無法維護的代碼？
    作者：陳皓 （@左耳朵耗子） | 編輯：玲玲 來源：https://dwz.cn/YELpxqyC 對，你沒看錯，本文就是教你怎麼寫出讓同事無法維護的代碼。 一、程式命名 1、容易輸入的變數名。比如：Fred，asdf 2、單字母的變數名。比如：a,b,c, x,y,z（如果不夠用，可以考慮a1,a ...
  • Laravel 中使用 swoole 項目實戰開發案例一 (建立 swoole 和前端通信)
    1 開發需要環境 工欲善其事，必先利其器。在正式開發之前我們檢查好需要安裝的拓展，不要開發中發現這些問題，打斷思路影響我們的開發效率。 安裝 swoole 拓展包 安裝 redis 拓展包 安裝 laravel5.5 版本以上 如果你還不會用swoole就out了 2 Laravel 生成命令行 p ...
  • Python使用RMF聚類分析客戶價值
    投資機構或電商企業等積累的客戶交易數據繁雜。需要根據用戶的以往消費記錄分析出不同用戶群體的特征與價值，再針對不同群體提供不同的營銷策略。 用戶分析指標 根據美國資料庫營銷研究所Arthur Hughes的研究，客戶資料庫中有三個神奇的要素，這三個要素構成了數據分析最好的指標 R-最近一次消費(Rec ...
  • 如何優雅的爬妹子網，手把手教你
    前言本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。作者：bihl 直接上代碼，哈哈！！ from urllib import request import os from user_agents import ua_list i ...
  • Spring Cloud系列-Zuul網關集成JWT身份驗證
    前言 這兩三年項目中一直在使用比較流行的spring cloud框架，也算有一定積累，打算有時間就整理一些乾貨與大家分享。 本次分享zuul網關集成jwt身份驗證 業務背景 項目開發少不了身份認證，jwt作為當下比較流行的身份認證方式之一主要的特點是無狀態，把信息放在客戶端，伺服器端不需要保存ses ...
  • python爬蟲--多任務非同步協程, 快點,在快點......
    多任務非同步協程asyncio asyncio的使用 多任務協程 aiohttp的使用 非同步協程爬蟲案例 基於aiohttp的多任務協程的爬蟲 ...
一周排行
    -Advertisement-
    Play Games
  • Dapr Outbox 執行流程
    Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程，Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor，topic=orders 本文前提知識：熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • Advanced .Net Debugging 7：托管堆與垃圾收集
    引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識，這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示，用於衡量代碼被測試覆蓋的程度，幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率（Line Coverage）、分支覆蓋率（Bra ...
  • C#S7.NET實現西門子PLCDB塊數據採集的完整步驟
    前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫，記錄了使用電腦模擬，模擬PLC，自至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1.Windows環境下鏈路層網路訪問的行業標準工具（WinPcap_4_1_3.exe）下載鏈接：http ...
  • WPF控制項：密碼框綁定MVVM
    從依賴倒置原則（Dependency Inversion Principle, DIP）到控制反轉（Inversion of Control, IoC）再到依賴註入（Dependency Injection, DI）的演進過程，我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • Python中的私有屬性與私有方法
    關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制，這與其他面相對對象語言有區別。關於私有屬性和私有方法，有如下要點： 1、通常我們約定，兩個下劃線開頭的屬性是私有的（private）。其他為公共的（public）； 2、類內部可以訪問私有屬性（方法）； 3、類外 ...
  • C++ 訪問說明符詳解：封裝數據，控制訪問，提升安全性
    C++ 訪問說明符 訪問說明符是 C++ 中控制類成員（屬性和方法）可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符： public：允許從類外部的任何地方訪問成員。 private：僅允許在類內部訪問成員。 protected：允許在類內部及其派生類中訪問成員。 示 ...
  • static_cast與dynamic_cast到底是什麼？
    寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先，【static_cast，dynamic_cast】【父類指針，子類指針】，兩兩一組，共有4種組合：用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • C語言數據結構：雙向鏈表的增刪操作
    /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • @ComponentScan註解的實現，Spring掃描包的過程
    相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage，將包下的類按照一定規則註冊成Be ...
  • opensips開啟python支持
    操作系統 ：CentOS 7.6_x64 opensips版本： 2.4.9 python版本：2.7.5 python作為腳本語言，使用起來很方便，查了下opensips的文檔，支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...
所有分類