C#的進程同步Mutex類使用實例分析

這篇文章主要介紹“C#的進程同步Mutex類使用實例分析”，在日常操作中，相信很多人在C#的進程同步Mutex類使用實例分析問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”C#的進程同步Mutex類使用實例分析”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

Mutex 中文為互斥，Mutex 類叫做互斥鎖。它還可用于進程間同步的同步基元。

Mutex 跟 lock 相似，但是 Mutex 支持多個進程。Mutex 大約比 lock 慢 20 倍。

互斥鎖(Mutex)，用于多線程中防止兩條線程同時對一個公共資源進行讀寫的機制。

Windows 操作系統中，Mutex 同步對象有兩個狀態：

• signaled：未被任何對象擁有；

• nonsignaled：被一個線程擁有；

Mutex 只能在獲得鎖的線程中，釋放鎖。

構造函數和方法

Mutex 類其構造函數如下：

Mutex 對于進程同步有所幫助，例如其應用場景主要是控制系統只能運行一個此程序的實例。

Mutex 構造函數中的 String類型參數 叫做互斥量而互斥量是全局的操作系統對象。 
Mutex 只要考慮實現進程間的同步，它會耗費比較多的資源，進程內請考慮 Monitor/lock。

Mutex 的常用方法如下：

關于 Mutex 類，我們可以先通過幾個示例去了解它。

系統只能運行一個程序的實例

下面是一個示例，用于控制系統只能運行一個此程序的實例，不允許同時啟動多次。

    class Program
    {
        // 第一個程序
        const string name = "www.whuanle.cn";
        private static Mutex m;
        static void Main(string[] args)
        {
            // 本程序是否是 Mutex 的擁有者
            bool firstInstance;
            m = new Mutex(false,name,out firstInstance);
            if (!firstInstance)
            {
                Console.WriteLine("程序已在運行！按下回車鍵退出！");
                Console.ReadKey();
                return;
            }
            Console.WriteLine("程序已經啟動");
            Console.WriteLine("按下回車鍵退出運行");
            Console.ReadKey();
            m.ReleaseMutex();
            m.Close();
            return;
        }
    }

上面的代碼中，有些地方前面沒有講，沒關系，我們運行一下生成的程序先。

解釋一下上面的示例

Mutex 的工作原理：

當兩個或兩個以上的線程同時訪問共享資源時，操作系統需要一個同步機制來確保每次只有一個線程使用資源。

Mutex 是一種同步基元，Mutex 僅向一個線程授予獨占訪問共享資源的權限。這個權限依據就是 互斥體，當一個線程獲取到互斥體后，其它線程也在試圖獲取互斥體時，就會被掛起(阻塞)，直到第一個線程釋放互斥體。

對應我們上一個代碼示例中，實例化 Mutex 類的構造函數如下：

m = new Mutex(false,name,out firstInstance);

其構造函數原型如下：

public Mutex (bool initiallyOwned, string name, out bool createdNew);

前面我們提出過，Mutex 對象有兩種狀態，signaled 和 nonsignaled。

通過 new 來實例化 Mutex 類，會檢查系統中此互斥量 name 是否已經被使用，如果沒有被使用，則會創建 name 互斥量并且此線程擁有此互斥量的使用權；此時 createdNew == true。

那么 initiallyOwned ，它的作用是是否允許線程是否能夠獲取到此互斥量的初始化所有權。因為我們希望只有一個程序能夠在后臺運行，因此我們要設置為 false。

驅動開發中關于Mutex ：https://docs.microsoft.com/zh-cn/windows-hardware/drivers/kernel/introduction-to-mutex-objects

對了， Mutex 的 參數中，name 是非常有講究的。

在運行終端服務的服務器上，命名系統 mutex 可以有兩個級別的可見性。

• 如果其名稱以前綴 "Global" 開頭，則 mutex 在所有終端服務器會話中可見。

• 如果其名稱以前綴 "Local" 開頭，則 mutex 僅在創建它的終端服務器會話中可見。 在這種情況下，可以在服務器上的其他每個終端服務器會話中存在具有相同名稱的單獨 mutex。

如果在創建已命名的 mutex 時未指定前綴，則采用前綴 "Local"。 在終端服務器會話中，兩個互斥體的名稱只是它們的前綴不同，它們都是對終端服務器會話中的所有進程都可見。

也就是說，前綴名稱 "Global" 和 "Local" 描述互斥體名稱相對于終端服務器會話的作用域，而不是相對于進程。

請參考：

https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.mutex?view=netcore-3.1#methods

http://www.5655pk.com/article/237313.htm

接替運行

這里要實現，當同時點擊一個程序時，只能有一個實例A可以運行，其它實例進入等待隊列，等待A運行完畢后，然后繼續運行隊列中的下一個實例。

我們將每個程序比作一個人，模擬一個廁所坑位，每次只能有一個人上廁所，其他人需要排隊等候。

使用 WaitOne() 方法來等待別的進程釋放互斥量，即模擬排隊；ReleaseMutex() 方法解除對坑位的占用。

    class Program
    {
        // 第一個程序
        const string name = "www.whuanle.cn";
        private static Mutex m;
        static void Main(string[] args)
        {
            // wc 還有沒有位置
            bool firstInstance;
            m = new Mutex(true,name,out firstInstance);

            // 已經有人在上wc
            if (!firstInstance)
            {
                // 等待運行的實例退出，此進程才能運行。
                Console.WriteLine("排隊等待");
                m.WaitOne();
                GoWC();
                return;
            }
            GoWC();

            return;
        }

        private static void GoWC()
        {
            Console.WriteLine(" 開始上wc");
            Thread.Sleep(1000);
            Console.WriteLine(" 開門");
            Thread.Sleep(1000);
            Console.WriteLine(" 關門");
            Thread.Sleep(1000);
            Console.WriteLine(" xxx");
            Thread.Sleep(1000);
            Console.WriteLine(" 開門");
            Thread.Sleep(1000);
            Console.WriteLine(" 離開wc");
            m.ReleaseMutex();
            Thread.Sleep(1000);
            Console.WriteLine(" 洗手");
        }
    }

此時，我們使用了

            m = new Mutex(true,name,out firstInstance);

一個程序結束后，要允許其它線程能夠創建 Mutex 對象獲取互斥量，需要將構造函數的第一個參數設置為 true。

你也可以改成 false，看看會報什么異常。

你可以使用 WaitOne(Int32) 來設置等待時間，單位是毫秒，超過這個時間就不排隊了，去別的地方上廁所。

為了避免出現問題，請考慮在 finally 塊中執行 m.ReleaseMutex()。

進程同步示例

這里我們實現一個這樣的場景：

父進程 Parent 啟動子進程 Children ，等待子進程 Children 執行完畢，子進程退出，父進程退出。

新建一個 .NET Core 控制臺項目，名稱為 Children，其 Progarm 中的代碼如下

using System;
using System.Threading;

namespace Children
{
    class Program
    {
        const string name = "進程同步示例";
        private static Mutex m;
        static void Main(string[] args)
        {
            Console.WriteLine("子進程被啟動...");
            bool firstInstance;

            // 子進程創建互斥體
            m = new Mutex(true, name, out firstInstance);

            // 按照我們設計的程序，創建一定是成功的
            if (firstInstance)
            {
                Console.WriteLine("子線程執行任務");
                DoWork();
                Console.WriteLine("子線程任務完成");

                // 釋放互斥體
                m.ReleaseMutex();
                // 結束程序
                return;
            }
            else
            {
                Console.WriteLine("莫名其妙的異常，直接退出");
            }
        }
        private static void DoWork()
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("子線程工作中");
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }
        }
    }
}

然后發布或生成項目，打開程序文件位置，復制線程文件路徑。
創建一個新項目，名為 Parent 的 .NET Core 控制臺，其 Program 中的代碼如下：

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

namespace Parent
{
    class Program
    {
        const string name = "進程同步示例";
        private static Mutex m;
        static void Main(string[] args)
        {
            // 晚一些再執行，我錄屏要對正窗口位置
            Thread.Sleep(TimeSpan.FromSeconds(3));
            Console.WriteLine("父進程啟動！");

            new Thread(() =>
            {
                // 啟動子進程
                Process process = new Process();
                process.StartInfo.UseShellExecute = true;
                process.StartInfo.CreateNoWindow = false;
                process.StartInfo.WorkingDirectory = @"../../../ConsoleApp9\Children\bin\Debug\netcoreapp3.1";
                process.StartInfo.FileName = @"../../../ConsoleApp9\Children\bin\Debug\netcoreapp3.1\Children.exe";
                process.Start();
                process.WaitForExit();
            }).Start();


            // 子進程啟動需要一點時間
            Thread.Sleep(TimeSpan.FromSeconds(1));

            // 獲取互斥體
            bool firstInstance;
            m = new Mutex(true, name, out firstInstance);

            // 說明子進程還在運行
            if (!firstInstance)
            {
                // 等待子進程運行結束
                Console.WriteLine("等待子進程運行結束");
                m.WaitOne();
                Console.WriteLine("子進程運行結束，程序將在3秒后自動退出");
                m.ReleaseMutex();
                Thread.Sleep(TimeSpan.FromSeconds(3));
                return;
            }
        }
    }
}

請將 Children 項目的程序文件路徑，替換到 Parent 項目啟動子進程的那部分字符串中。

然后啟動 Parent.exe，可以觀察到如下圖的運行過程：

到此，關于“C#的進程同步Mutex類使用實例分析”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！