C#線程同步--限量使用

来源:https://www.cnblogs.com/scmail81/archive/2018/08/21/9514611.html
-Advertisement-
Play Games

問題抽象：當某一資源同一時刻允許一定數量的線程使用的時候，需要有個機制來阻塞多餘的線程，直到資源再次變得可用。線程同步方案：Semaphore、SemaphoreSlim、CountdownEvent方案特性：限量供應；除所有者外，其他人無條件等待；先到先得，沒有先後順序 1、Semaphore類 ...


問題抽象：當某一資源同一時刻允許一定數量的線程使用的時候，需要有個機制來阻塞多餘的線程，直到資源再次變得可用。
線程同步方案：Semaphore、SemaphoreSlim、CountdownEvent
方案特性：限量供應；除所有者外，其他人無條件等待；先到先得，沒有先後順序

1、Semaphore類
      用於控制線程的訪問數量，預設的構造函數為initialCount和maximumCount，表示預設設置的信號量個數和最大信號量個數。當你WaitOne的時候，信號量自減，當Release的時候，信號量自增，然而當信號量為0的時候，後續的線程就不能拿到WaitOne了，所以必須等待先前的線程通過Release來釋放。

using System;
using System.Threading;

namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            Thread t1 = new Thread(Run1);
            t1.Start();
            Thread t2 = new Thread(Run2);
            t2.Start();
            Thread t3 = new Thread(Run3);
            t3.Start();
            Console.ReadKey();
        }

        //初始可以授予2個線程信號，因為第3個要等待前面的Release才能得到信號
        static Semaphore sem = new Semaphore(2, 10);

        static void Run1()
        {
            sem.WaitOne();
            Console.WriteLine("大家好，我是Run1;" + DateTime.Now.ToString("mm:ss"));

            //兩秒後
            Thread.Sleep(2000);
            sem.Release();
        }

        static void Run2()
        {
            sem.WaitOne();
            Console.WriteLine("大家好，我是Run2;" + DateTime.Now.ToString("mm:ss"));

            //兩秒後
            Thread.Sleep(2000);
            sem.Release();
        }

        static void Run3()
        {
            sem.WaitOne();
            Console.WriteLine("大家好，我是Run3;" + DateTime.Now.ToString("mm:ss"));

            //兩秒後
            Thread.Sleep(2000);
            sem.Release();
        }
    }
}
Program

在以上的方法中Release()方法相當於自增一個信號量，Release(5)自增5個信號量。但是，Release()到構造函數的第二個參數maximumCount的值就不能再自增了。

Semaphore可用於進程級交互。

using System;
using System.Diagnostics;
using System.Threading;

namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {

            Thread t1 = new Thread(Run1);
            t1.Start();

            Thread t2 = new Thread(Run2);
            t2.Start();

            Console.Read();
        }

        //初始可以授予2個線程信號，因為第3個要等待前面的Release才能得到信號
        static Semaphore sem = new Semaphore(3, 10, "命名Semaphore");

        static void Run1()
        {
            sem.WaitOne();

            Console.WriteLine("進程：" + Process.GetCurrentProcess().Id + "  我是Run1" + DateTime.Now.TimeOfDay);
        }

        static void Run2()
        {
            sem.WaitOne();

            Console.WriteLine("進程：" + Process.GetCurrentProcess().Id + "  我是Run2" + DateTime.Now.TimeOfDay);
        }
    }
}
Program

直接運行兩次bin目錄的exe文件，就能發現最多只能輸出3個。

Semaphore可以限制可同時訪問某一資源或資源池的線程數。         Semaphore類在內部維護一個計數器，當一個線程調用Semaphore對象的Wait系列方法時，此計數器減一，只要計數器還是一個正數，線程就不會阻塞。當計數器減到0時，再調用Semaphore對象Wait系列方法的線程將被阻塞，直到有線程調用Semaphore對象的Release()方法增加計數器值時，才有可能解除阻塞狀態。   示例說明：
圖書館都配備有若幹台公用電腦供讀者查詢信息，當某日讀者比較多時，必須排隊等候。UseLibraryComputer實例用多線程模擬了多人使用多台電腦的過程 
using System;
using System.Threading;

namespace ConsoleApp1
{
    class Program
    {
        //圖書館擁有的公用電腦  
        private const int ComputerNum = 3;
        private static Computer[] LibraryComputers;
        //同步信號量  
        public static Semaphore sp = new Semaphore(ComputerNum, ComputerNum);

        static void Main(string[] args)
        {
            //圖書館擁有ComputerNum臺電腦  
            LibraryComputers = new Computer[ComputerNum];
            for (int i = 0; i < ComputerNum; i++)
                LibraryComputers[i] = new Computer("Computer" + (i + 1).ToString());
            int peopleNum = 0;
            Random ran = new Random();
            Thread user;
            System.Console.WriteLine("敲任意鍵模擬一批批的人排隊使用{0}台電腦，ESC鍵結束模擬……", ComputerNum);
            //每次創建若幹個線程，模擬人排隊使用電腦  
            while (System.Console.ReadKey().Key != ConsoleKey.Escape)
            {
                peopleNum = ran.Next(0, 10);
                System.Console.WriteLine("\n有{0}人在等待使用電腦。", peopleNum);

                for (int i = 1; i <= peopleNum; i++)
                {
                    user = new Thread(UseComputer);
                    user.Start("User" + i.ToString());
                }
            }
        }

        //線程函數  
        static void UseComputer(Object UserName)
        {
            sp.WaitOne();//等待電腦可用  

            //查找可用的電腦  
            Computer cp = null;
            for (int i = 0; i < ComputerNum; i++)
                if (LibraryComputers[i].IsOccupied == false)
                {
                    cp = LibraryComputers[i];
                    break;
                }
            //使用電腦工作  
            cp.Use(UserName.ToString());

            //不再使用電腦，讓出來給其他人使用  
            sp.Release();
        }
    }

    class Computer
    {
        public readonly string ComputerName = "";
        public Computer(string Name)
        {
            ComputerName = Name;
        }
        //是否被占用  
        public bool IsOccupied = false;
        //人在使用電腦  
        public void Use(String userName)
        {
            System.Console.WriteLine("{0}開始使用電腦{1}", userName, ComputerName);
            IsOccupied = true;
            Thread.Sleep(new Random().Next(1, 2000)); //隨機休眠，以模擬人使用電腦  
            System.Console.WriteLine("{0}結束使用電腦{1}", userName, ComputerName);
            IsOccupied = false;
        }
    }
}
Program

 

2、SemaphoreSlim類      在.net 4.0之前，framework中有一個重量級的Semaphore，可以跨進程同步，SemaphoreSlim輕量級不行，msdn對它的解釋為：限制可同時訪問某一資源或資源池的線程數。 
using System;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        static SemaphoreSlim slim = new SemaphoreSlim(Environment.ProcessorCount, 12);

        static void Main(string[] args)
        {
            for (int i = 0; i < 12; i++)
            {
                Task.Factory.StartNew((obj) =>
                {
                    Run(obj);
                }, i);
            }
            Console.Read();
        }

        static void Run(object obj)
        {
            slim.Wait();
            Console.WriteLine("當前時間:{0}任務 {1}已經進入。", DateTime.Now, obj);
            //這裡busy3s中
            Thread.Sleep(3000);
            slim.Release();
        }
    }
}
Program

同樣，防止死鎖的情況，我們需要知道”超時和取消標記“的解決方案，像SemaphoreSlim這種定死的”線程請求範圍“，其實是降低了擴展性，使用需謹慎，在覺得有必要的時候使用它

註:Semaphore類是SemaphoreSlim類的老版本,該版本使用純粹的內核時間(kernel-time)方式。     SemaphoreSlim類不使用Windows內核信號量,而且也不支持進程間同步。所以在跨程式同步的場景下可以使用Semaphore   3、CountdownEvent類      這種採用信號狀態的同步基元非常適合在動態的fork,join的場景，它採用“信號計數”的方式，就比如這樣，一個麻將桌只能容納4個人打麻將，如果後來的人也想搓一把碰碰運氣，那麼他必須等待直到麻將桌上的人走掉一位。好，這就是簡單的信號計數機制，從技術角度上來說它是定義了最多能夠進入關鍵代碼的線程數。      但是CountdownEvent更牛X之處在於我們可以動態的改變“信號計數”的大小，比如一會兒能夠容納8個線程，一下又4個，一下又10個，這樣做有什麼好處呢？比如一個任務需要載入1w條數據，那麼可能出現這種情況。 例如: 載入User表：         根據user表的數據量，我們需要開5個task。 載入Product表：    產品表數據相對比較多，計算之後需要開8個task。 載入order表：       由於我的網站訂單豐富，計算之後需要開12個task。 
using System;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        //預設的容納大小為“硬體線程“數
        static CountdownEvent cde = new CountdownEvent(Environment.ProcessorCount);

        static void LoadUser(object obj)
        {
            try
            {
                Console.WriteLine("ThreadId={0};當前任務:{1}正在載入User部分數據！", Thread.CurrentThread.ManagedThreadId, obj);
            }
            finally
            {
                cde.Signal();
            }
        }

        static void LoadProduct(object obj)
        {
            try
            {
                Console.WriteLine("ThreadId={0};當前任務:{1}正在載入Product部分數據！", Thread.CurrentThread.ManagedThreadId, obj);
            }
            finally
            {
                cde.Signal();
            }
        }

        static void LoadOrder(object obj)
        {
            try
            {
                Console.WriteLine("ThreadId={0};當前任務:{1}正在載入Order部分數據！", Thread.CurrentThread.ManagedThreadId, obj);
            }
            finally
            {
                cde.Signal();
            }
        }

        static void Main(string[] args)
        {
            //載入User表需要5個任務
            var userTaskCount = 5;
            //重置信號
            cde.Reset(userTaskCount);
            for (int i = 0; i < userTaskCount; i++)
            {
                Task.Factory.StartNew((obj) =>
                {
                    LoadUser(obj);
                }, i);
            }
            //等待所有任務執行完畢
            cde.Wait();
            Console.WriteLine("\nUser表數據全部載入完畢！\n");

            //載入product需要8個任務
            var productTaskCount = 8;
            //重置信號
            cde.Reset(productTaskCount);
            for (int i = 0; i < productTaskCount; i++)
            {
                Task.Factory.StartNew((obj) =>
                {
                    LoadProduct(obj);
                }, i);
            }
            cde.Wait();
            Console.WriteLine("\nProduct表數據全部載入完畢！\n");

            //載入order需要12個任務
            var orderTaskCount = 12;
            //重置信號
            cde.Reset(orderTaskCount);
            for (int i = 0; i < orderTaskCount; i++)
            {
                Task.Factory.StartNew((obj) =>
                {
                    LoadOrder(obj);
                }, i);
            }
            cde.Wait();
            Console.WriteLine("\nOrder表數據全部載入完畢！\n");

            Console.WriteLine("\n(*^__^*) 嘻嘻，恭喜你，數據全部載入完畢\n");
            Console.Read();
        }
    }
}
Program

我們看到有兩個主要方法：Wait和Signal。每調用一次Signal相當於麻將桌上走了一個人，直到所有人都搓過麻將wait才給放行，這裡同樣要註意也就是“超時“問題的存在性，尤其是在並行計算中，輕量級別給我們提供了”取消標記“的機制，這是在重量級別中不存在的

註:如果調用Signal()沒有到達指定的次數,那麼Wait()將一直等待,請確保使用每個線程完成後都要調用Signal方法。

 


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

-Advertisement-
Play Games
更多相關文章
  • Flask-藍圖、模型與CodeFirst
    應用、藍圖與視圖函數 1. 結構，如圖： 1. Flask最上層是 ，在這個核心對象上可以插入很多藍圖，這個藍圖是不能單獨存在的，必須將app作為插板插入app ,在每一個藍圖上，可以註冊很多靜態文件，視圖函數，模板 ，一個業務模塊可以做為一個藍圖，比如book,之前的book.py 放到了app/ ...
  • python鎖機制
    python多進程，多線程之鎖機制 鎖添加的原因： 在多進程/多線程同時進入臨界資源區獲取和操作共有資源時，會出現資源的爭奪而出現混亂。為了避免這種混亂現象，python提出了鎖機制 線程鎖/進程鎖的定義和運用： 創建鎖對象: lock = Lock() 鎖對象一旦創建，就可以隨時被進程或者線程調用 ...
  • 答案在哪裡？action config/Interceptor/class/servlet
    項目已提測，這兩天我們都集中精力梳理外包團隊給我司研發的這個三方支付系統的代碼邏輯。今天下午愛琴海會議室，開發組裡一同學分享他對支付結果回調的梳理成果。 支付結果回調的整體時序是：支付渠道方處理完用戶支付信息後，主動調用我方在支付發起時提供的回調地址，把支付結果推給我方，我方處理完成後，回寫字元串“ ...
  • 課時35：圖形用戶界面入門
    目錄： 一、安裝GUI工具包：EasyGui 二、導入EasyGui 三、使用EasyGui 四、修改預設設置 五、課時35課後習題及答案 *********************************** 一、安裝GUI工具包：EasyGui ************************* ...
  • python列表、元組、字典、集合的簡單操作
    一、列表和集合 二、字典 1 #Author:CGQ 2 #key-value 3 #版本3.6以後dica字典是有序的 4 info={ 5 '123456':"Ren Gong", 6 '123457':"Luan Gong", 7 '123458':"Xiao Gong", 8 } 9 inf ...
  • C#線程同步--線程通信
    問題抽象：當某個操作的執行必須依賴於另一個操作的完成時，需要有個機制來保證這種先後關係。線程通信方案：ManualResetEventSlim、ManualResetEvent、AutoResetEvent方案特性：提供線程通知的能力，沒有接到通知前，線程必須等待，有先後順序。 1、ManualRe ...
  • 造輪子，模仿WPF的UI框架，還沒完善。。。
    Wtf(暫時命名，隨便起的 = _=)，模仿WPF的框架，還沒有完善，只有簡單的基礎元素，支持數據綁定。雖然支持mono但是mono有bug 寫這個只是興趣愛好，感覺也沒多大意義了，如果這個UI框架完善了，有多少人願意用？畢竟Windows上有WPF，而且C#跨平臺需求也不多啊。我對WPF也不算熟悉 ...
  • C# 冒泡排序
    冒泡排序的運行原理(好理解)： 備註：上述講解來自 維基百科 冒泡排序 代碼如下（從大到小排序）： ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類