[.Net線程處理系列]專題六：線程同步——信號量和互斥體

也不多說了，直接進入主題了

讓客戶滿意是我們工作的目標，不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領域值得信任、有價值的長期合作伙伴，公司提供的服務項目有：申請域名、雅安服務器托管、營銷軟件、網(wǎng)站建設、合水網(wǎng)站維護、網(wǎng)站推廣。

一、信號量（Semaphore）

信號量（Semaphore）是由內(nèi)核對象維護的int變量，當信號量為0時，在信號量上等待的線程會堵塞，信號量大于0時，就解除堵塞。當在一個信號量上等待的線程解除堵塞時，內(nèi)核自動會將信號量的計數(shù)減1。在.net 下通過Semaphore類來實現(xiàn)信號量同步。

Semaphore類限制可同時訪問某一資源或資源池的線程數(shù)。線程通過調(diào)用 WaitOne方法將信號量減1，并通過調(diào)用 Release方法把信號量加1。

先說下構造函數(shù)：

public Semaphore(int initialCount,int maximumCount);通過兩個參數(shù)來設置信號的初始計數(shù)和最大計數(shù)。

下面通過一段代碼來演示信號量同步的使用：

 同樣信號量也可以實現(xiàn)進程中線程的同步，同樣也是通過對信號量命名來實現(xiàn)的，

通過調(diào)用public Semaphore(int initialCount,int maximumCount,string name);該構造函數(shù)多傳入一個信號量名來實現(xiàn)

下面一段實例代碼來演示下：

using System;  
using System.Threading;  
 
namespace SemaphoreSample  
{  
    class Program  
    {  
        // 初始信號量計數(shù)為4，最大計數(shù)為10 
        public static Semaphore semaphore =new Semaphore(4,10,"My");  
        public static int time = 0;  
        static void Main(string[] args)  
        {  
            for (int i = 0; i < 3; i++)  
            {  
                Thread test = new Thread(new ParameterizedThreadStart(TestMethod));  
 
                // 開始線程，并傳遞參數(shù) 
                test.Start(i);  
            }  
 
            // 等待1秒讓所有線程開始并阻塞在信號量上 
            Thread.Sleep(1000);  
 
            Console.Read();           
        }  
 
        public static void TestMethod(object number)  
        {  
            // 設置一個時間間隔讓輸出有順序 
            int span = Interlocked.Add(ref time, 500);  
            Thread.Sleep(1000 + span);  
 
            //信號量計數(shù)減1 
            semaphore.WaitOne();  
              
            Console.WriteLine("Thread {0} run ", number);  
        }  
    }  
} 

運行結果：

    從運行結果中可以看出， 第二個進程值運行了一行語句， 因為我們設置的初始信號計數(shù)為4，每運行一個線程，信號計數(shù)通過調(diào)用WaitOne方法減1,所以第二個進行一開始信號計數(shù)為1而不是進程一中的4，如果我們把信號計數(shù)后面的name參數(shù)去除的話，此時第二個進程和第一個進程中的結果應該是一樣的（因為此時沒有進行不同進程中線程的同步）。

二、互斥體（Mutex）

同樣互斥體也是同樣可以實現(xiàn)線程之間的同步和不同進程中線程的同步的

先看看線程之間的同步的例子吧（在這里我也不多做解釋了，因為他們之間的使用很類似，直接貼出代碼）：

class Program  
    {  
        public static Mutex mutex = new Mutex();  
        public static int count;  
 
        static void Main(string[] args)  
        {  
            for (int i = 0; i < 10; i++)  
            {  
                Thread test = new Thread(TestMethod);  
 
                // 開始線程，并傳遞參數(shù) 
                test.Start();  
            }  
 
            Console.Read();  
        }  
 
        public static void TestMethod()  
        {  
            mutex.WaitOne();  
            Thread.Sleep(500);  
            count++;  
            Console.WriteLine("Current Cout Number is {0}", count);  
            mutex.ReleaseMutex();  
        }  
    } 

運行結果：

 實現(xiàn)進程間同步：

class Program  
    {  
        public static Mutex mutex = new Mutex(false,"My");  
 
        static void Main(string[] args)  
        {  
            Thread t = new Thread(TestMethod);  
            t.Start();  
 
            Console.Read();  
        }  
 
        public static void TestMethod()  
        {  
            mutex.WaitOne();  
            Thread.Sleep(5000);  
            Console.WriteLine("Method start at : " + DateTime.Now.ToLongTimeString());  
            mutex.ReleaseMutex();  
        }  
    } 

    從運行結果看出兩個進程之間的時間間隔為5秒，當我們把構造函數(shù)中命名參數(shù)去掉時就可以看出差別了。

 三、小結

    到這里多線程處理基本上講完，這個系列也只是一個入門，真真要好好掌握多線程，還是要在項目中多去實戰(zhàn)的。接下來我可能會做一個小的例子的，大概的思路是實現(xiàn)一個文件的下載的這樣的例子。如果大家有什么好的例子來運用多線程的知識的話，可以留言給我，我也會盡量去實現(xiàn)（如果不會的話，這樣也可以促使我去學習），實現(xiàn)后也會和大家分享的。

 

分享文章：[.Net線程處理系列]專題六：線程同步——信號量和互斥體
文章來源：http://www.jbt999.com/article18/ihsddp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供App設計、響應式網(wǎng)站、企業(yè)網(wǎng)站制作、微信公眾號、營銷型網(wǎng)站建設、軟件開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：[email protected]。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)