C#線程學習筆記四：線程同步

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

本筆記摘抄自：https://www.cnblogs.com/zhili/archive/2012/07/21/ThreadsSynchronous.html，記錄一下學習過程以備後續查用。 一、線程同步概述 創建多線程來實現讓我們能夠更好地響應應用程式，然而當我們創建了多個線程時，就存在多個線程同 ...


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

    一、線程同步概述

    創建多線程來實現讓我們能夠更好地響應應用程式，然而當我們創建了多個線程時，就存在多個線程同時訪問一個共用資源的情況。此時，我們就需要用到線程同步。線程同

步可以防止數據（共用資源）的損壞。

    一般來說，設計應用程式應儘量避免使用線程同步， 因為線程同步會產生一些問題：

    1.1、它的使用比較繁瑣。我們需要用額外的代碼，把多個線程同時訪問的數據包圍起來，並獲取和釋放一個線程同步鎖。如果有一個代碼塊忘記獲取鎖，就有可能造成數據損壞。

    1.2、使用線程同步會影響性能。

        1.2.1、獲取和釋放一個鎖是需要時間的，我們在決定哪個線程先獲取鎖的時候，CPU要進行協調，這些額外的工作就會對性能造成影響。

        1.2.2、線程同步一次只允許一個線程訪問資源，這樣就會阻塞線程，而阻塞線程會造成更多的線程被創建。這樣CPU就有可能要調度更多的線程，從而對性能造成影響。 

    二、線程同步使用

    2.1 使用鎖對性能的影響

    1.2.1描述過使用鎖會對性能產生影響，下麵通過比較使用鎖和不使用鎖消耗的時間來說明這點：

    class Program
    {
        static void Main(string[] args)
        {
            #region 線程同步：使用與不使用鎖的耗時對比
            int x = 0;
            //迭代500萬次
            const int iterationNumber = 5000000;

            //不使用鎖
            Stopwatch sw = Stopwatch.StartNew();
            for (int i = 0; i < iterationNumber; i++)
            {
                x++;
            }
            Console.WriteLine("Total time consuming is:{0}ms.", sw.ElapsedMilliseconds);

            sw.Restart();
            //使用鎖
            for (int i = 0; i < iterationNumber; i++)
            {
                Interlocked.Increment(ref x);
            }

            Console.WriteLine("Total time consuming is:{0}ms.", sw.ElapsedMilliseconds);
            Console.Read();
            #endregion
        }
    }

    運行結果如下：

    2.2 Interlocked實現線程同步

    Interlocked為多個線程共用變數提供了原子操作，當我們在多線程中對一個整數進行遞增操作時，就需要實現線程同步。

    下麵代碼演示加鎖與不加鎖的區別：

    不加鎖：

    class Program
    {
        //共用資源
        public static int number = 0;

        static void Main(string[] args)
        {
            #region 線程同步：使用Interlocked實現線程同步
            //不加鎖
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(Add);
                thread.Start();
            }
            Console.Read();
            #endregion
        }

        /// <summary>
        /// 遞增不加鎖
        /// </summary>
        public static void Add()
        {
            Thread.Sleep(1000);
            Console.WriteLine("The current value of number is:{0}", ++number);
        }
    }

    運行結果如下：

    結果與預期可能不太一樣。為瞭解決這樣的問題，我們可以通過使用 Interlocked.Increment方法來實現自增操作。

    實現原理：類似銀行叫號，當有空號且號碼是自己的，才能去辦理相關的業務，否則繼續等待。

    加鎖：

    class Program
    {
        //共用資源
        public static int number = 0;
        public static long signal = 0;

        static void Main(string[] args)
        {
            #region 線程同步：使用Interlocked實現線程同步
            //加鎖
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(new ParameterizedThreadStart(AddWithInterlocked));
                thread.Start(i);
            }
            Console.Read();
            #endregion
        }

        /// <summary>
        /// 遞增加Interlocked鎖
        /// </summary>
        public static void AddWithInterlocked(object parameter)
        {
            while (Interlocked.Read(ref signal) != 0 || (int)parameter != number)
            {
                Thread.Sleep(100);
            }

            Interlocked.Increment(ref signal);
            Console.WriteLine("The current value of number is:{0}", ++number);
            Interlocked.Decrement(ref signal);
        }
    }

    運行結果如下：

    2.3 Monitor實現線程同步

    對於上面那個情況，也可以通過Monitor.Enter和Monitor.Exit方法來實現線程同步。

    C#中通過lock關鍵字來提供簡化的語法(lock可以理解為Monitor.Enter和Monitor.Exit方法的語法糖)。

    class Program
    {
        //共用資源
        public static int number = 0;
        private static readonly object addLock = new object();

        static void Main(string[] args)
        {
            #region 線程同步：使用Monitor實現線程同步
            //非語法糖
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(AddWithMonitor);
                thread.Start();
            }
            Console.Read();
            //語法糖
            //for (int i = 0; i < 10; i++)
            //{
            //    Thread thread = new Thread(AddWithLock);
            //    thread.Start();
            //}
            //Console.Read();
            #endregion
        }
        
        /// <summary>
        /// 遞增加Monitor鎖
        /// </summary>
        public static void AddWithMonitor()
        {
            Thread.Sleep(100);
            Monitor.Enter(addLock);
            Console.WriteLine("The current value of number is:{0}", ++number);
            Monitor.Exit(addLock);
        }

        /// <summary>
        /// 遞增加Lock鎖
        /// </summary>
        public static void AddWithLock()
        {
            Thread.Sleep(100);
            lock (addLock)
            {
                Console.WriteLine("The current value of number is:{0}", ++number);
            }
        }
    }

    運行結果如下：

    接上面的addLock鎖(以下描述為obj鎖)，順便學習一下Monitor類的原理：

    Monitor在鎖對象obj上會維持兩個線程隊列R和W以及一個引用T ：

    (1)T是對當前獲得了obj鎖的線程的引用。

    (2) R為就緒隊列。

　R隊列上的線程，是已經準備好了去競爭獲取obj鎖的線程。    

    線程可通過調用Monitor.Enter(obj)或Monitor.TryEnter(obj)而直接進入R隊列，可通過調用Monitor.Exit(obj)或Monitor.Wait(obj)釋放其所獲得的obj鎖。

    當obj鎖被某個線程釋放後，這個隊列上的線程就會去競爭obj鎖，而獲得obj鎖的線程將被T引用。

    (3) W為等待隊列。

    W隊列上的線程，是不會被OS直接調度執行的線程。也就是說，等待隊列上的線程不能去獲得obj鎖。

    線程可通過調用Monitor.Wait(obj)而直接進入W隊列，可通過調用Monitor.Pulse(obj)或Monitor.PulseAll(obj)將W隊列中的第一個等待線程或所有等待線程移至R隊列，

這時被移至R隊列的這些線程就有機會被OS直接調度執行，也就是可以去競爭obj鎖。

    (4)Monitor的成員方法。

    Monitor.Enter(obj)/Monitor.TryEnter(obj) ：線程會進入R隊列以等待獲取obj鎖

    Monitor.Exit(obj) ：線程釋放obj鎖（只有獲取了obj鎖的線程才能執行Monitor.Exit(obj)）

    Monitor.Wait(obj)： 線程釋放當前獲得的obj鎖，然後進入W隊列並阻塞。

    Monitor.Pulse(obj) ：將W隊列中的第一個等待線程移至R隊列中以使第一個線程有機會獲取obj鎖。

    Monitor.PulseAll(obj)：將W隊列中的所有等待線程移至R隊列以使得這些線程有機會獲得obj鎖。

    下麵代碼演示Monitor.Wait及Monitor.Pulse的使用：

    class Program
    {
        //共用資源
        private static readonly object addLock = new object();

        static void Main(string[] args)
        {
            #region 線程同步：Monitor.Wait與Monitor.Pulse的使用
            for (int i = 0; i < 10; i++)
            {
                Thread thread = new Thread(MonitorWaitAndPulse);
                thread.Start();
            }
            Console.Read();
            #endregion
        }

        /// <summary>
        /// Monitor中的Wait與Pulse方法
        /// </summary>
        public static void MonitorWaitAndPulse()
        {
            //進入就緒隊列等待獲取鎖資源
            Monitor.Enter(addLock);
            //進來打聲招呼
            Console.WriteLine("{0}：我來了，臨時要出去辦一下事。", Thread.CurrentThread.ManagedThreadId);
            //喚醒等待隊列中的第一個線程進入就緒隊列
            Monitor.Pulse(addLock);
            //暫時釋放鎖資源進入等待隊列
            Monitor.Wait(addLock);
            //出去辦事
            Thread.Sleep(1000);
            //回來打聲招呼
            Console.WriteLine("{0}：我回來了。", Thread.CurrentThread.ManagedThreadId);
            //釋放鎖資源
            Monitor.Exit(addLock);
        }
    }

    運行結果如下：

    2.4 ReaderWriterLock實現線程同步

    如果我們需要對一個共用資源執行多次讀取時，用前面所講的類實現的同步鎖都僅允許一個線程進行訪問，而其它線程將被阻塞。由於只是進行讀取操作，其實是沒有必要

堵塞其他的線程， 應該讓它們併發的執行。

    此時，可通過ReaderWriterLock類來實現並行讀取。

    class Program
    {
        //創建對象
        public static List<int> lists = new List<int>();
        public static ReaderWriterLock readerWriteLock = new ReaderWriterLock();

        static void Main(string[] args)
        {
            #region 線程同步：使用ReaderWriterLock實現線程同步
            //創建一個線程讀取數據
            Thread threadWrite = new Thread(Write);
            threadWrite.Start();
            //創建10個線程讀取數據
            for (int i = 0; i < 10; i++)
            {
                Thread threadRead = new Thread(Read);
                threadRead.Start();
            }

            Console.Read();
            #endregion
        }

        /// <summary>
        /// 寫入方法
        /// </summary>
        public static void Write()
        {
            //獲取寫入鎖，以10毫秒為超時。
            readerWriteLock.AcquireWriterLock(10);
            Random ran = new Random();
            int count = ran.Next(1, 10);
            lists.Add(count);
            Console.WriteLine("Write the data is:" + count);
            //釋放寫入鎖
            readerWriteLock.ReleaseWriterLock();
        }

        /// <summary>
        /// 讀取方法
        /// </summary>
        public static void Read()
        {
            Thread.Sleep(100);
            //獲取讀取鎖
            readerWriteLock.AcquireReaderLock(10);

            foreach (int list in lists)
            {
                //輸出讀取的數據
                Console.WriteLine(list);
            }

            // 釋放讀取鎖
            readerWriteLock.ReleaseReaderLock();
        }
    }

    運行結果如下：

 


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

-Advertisement-
Play Games
更多相關文章
  • EFCore的外鍵級聯刪除導致的【可能會導致迴圈或多重級聯路徑】
    之前也是經常遇到這個問題，但好在每次創建的實體不多，很容易就能找到是哪個外鍵導致級聯迴圈刪除問題 之前都是這麼處理，因為創建的實體也不多，所以還處理得來 但最近跟別人合作寫後端，別人寫了好多實體，我一Update-Database，傻了，我得一個個地處理。其實我也不太喜歡這個級聯刪除，是否刪除關聯實 ...
  • C#表達式樹
    前言 在使用 EF 開中我們經常使用 xx.Where(p=>p.Name="張三") 查詢數據，之把能這樣是因為 EF 框架會把這些C#代碼轉成Sql語句， 其中主要用到的就是表達式樹，今天就來學習一下表達式樹。 認識表達式樹 Func<int,int,int> func = (a, b) => ...
  • .Net Core控制台&EFCore連接Mysql
    在用慣了Asp.Net Core提供的基架後，反過來想一想，貌似忘記了控制台如何去連接資料庫了，因此，寫一篇文章來藉此鞏固下並以後再來回顧時，加快步驟。 1、新建一個.Net Core控制台，然後安裝Nuget包 2、添加一個文件夾Models，並增加一個實體類Company，增加該實體類一系列屬性 ...
  • .Net Core 項目發佈到Linux - CentOS 7（二）用Supervisor守護netcore進程
    簡介 supervisor可以保證程式崩潰後，可以重新把程式啟動起來等相關功能。 安裝 yum install -y supervisor 安裝好後在/etc/會生成一個supervisord.conf文件及一個supervisord.d文件目錄 查看supervisor是否安裝成功 supervi ...
  • .Net Core 項目發佈到Linux - CentOS 7（一）
    由於項目的需求，需要發佈到Linux伺服器上，在這裡記錄一下我發佈的過程。 安裝Linux 安裝liunx系統很簡單，網上也有很多教程，我是直接使用阿裡雲的CentOS 7.7 64位 部署環境 Linux - CentOS 7 安裝 .Net Core 運行環境 發佈項目 右鍵項目->發佈->啟動 ...
  • Linux - CentOS 7 安裝 .Net Core 運行環境
    阿裡雲的CentOS 7.7 64位，所需要的環境：MySql 5.7，.Net Core 2.2 ，Nginx 我這裡用的 Xshell 工具，首先用root進入系統 版本信息 打開終端輸入命令： lsb_release -a 安裝 .Net Core 2.2 SDK 官網參考文檔：https:/ ...
  • 你真的瞭解foreach嗎？
    有C#基礎的，當問到迴圈有哪些，會毫不猶豫的說出的for、do while、foreach及while這幾種，但是到具體實際開發中，我們遇到一些問題，比如：到底選擇哪種？為什麼選擇這種？哪種好像都可以？，其實在大多數情況下基本上可以通用，但是遇到比如Dictionary <[key] , [valu... ...
  • C# Lazy Loading
    前言 按需載入對象延遲載入實際是推遲進行創建對象，直到對其調用後才進行創建初始化，延遲（懶載入）的好處是提高系統性能，避免不必要的計算以及不必要的資源浪費。 常規有這些情況： 對象創建成本高且程式可能不會使用它。 例如，假定記憶體中有具有 Orders 屬性的 Customer 對象，該對象包含大量 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類