也不多說了,直接進(jìn)入主題了
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務(wù)項目有:申請域名、雅安服務(wù)器托管、營銷軟件、網(wǎng)站建設(shè)、合水網(wǎng)站維護(hù)、網(wǎng)站推廣。
一、信號量(Semaphore)
信號量(Semaphore)是由內(nèi)核對象維護(hù)的int變量,當(dāng)信號量為0時,在信號量上等待的線程會堵塞,信號量大于0時,就解除堵塞。當(dāng)在一個信號量上等待的線程解除堵塞時,內(nèi)核自動會將信號量的計數(shù)減1。在.net 下通過Semaphore類來實現(xiàn)信號量同步。
Semaphore類限制可同時訪問某一資源或資源池的線程數(shù)。線程通過調(diào)用 WaitOne方法將信號量減1,并通過調(diào)用 Release方法把信號量加1。
先說下構(gòu)造函數(shù):
public Semaphore(int initialCount,int maximumCount);通過兩個參數(shù)來設(shè)置信號的初始計數(shù)和最大計數(shù)。
下面通過一段代碼來演示信號量同步的使用:
- class Program
- {
- // 初始信號量計數(shù)為0,最大計數(shù)為10
- public static Semaphore semaphore =new Semaphore(0,10);
- public static int time = 0;
- static void Main(string[] args)
- {
- for (int i = 0; i < 5; i++)
- {
- Thread test = new Thread(new ParameterizedThreadStart(TestMethod));
- // 開始線程,并傳遞參數(shù)
- test.Start(i);
- }
- // 等待1秒讓所有線程開始并阻塞在信號量上
- Thread.Sleep(500);
- // 信號量計數(shù)加4
- // 最后可以看到輸出結(jié)果次數(shù)為4次
- semaphore.Release(4);
- Console.Read();
- }
- public static void TestMethod(object number)
- {
- // 設(shè)置一個時間間隔讓輸出有順序
- int span = Interlocked.Add(ref time, 100);
- Thread.Sleep(1000 + span);
- //信號量計數(shù)減1
- semaphore.WaitOne();
- Console.WriteLine("Thread {0} run ", number);
- }
- }
同樣信號量也可以實現(xiàn)進(jìn)程中線程的同步,同樣也是通過對信號量命名來實現(xiàn)的,
通過調(diào)用public Semaphore(int initialCount,int maximumCount,string name);該構(gòu)造函數(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)
- {
- // 設(shè)置一個時間間隔讓輸出有順序
- int span = Interlocked.Add(ref time, 500);
- Thread.Sleep(1000 + span);
- //信號量計數(shù)減1
- semaphore.WaitOne();
- Console.WriteLine("Thread {0} run ", number);
- }
- }
- }
運行結(jié)果:
從運行結(jié)果中可以看出, 第二個進(jìn)程值運行了一行語句, 因為我們設(shè)置的初始信號計數(shù)為4,每運行一個線程,信號計數(shù)通過調(diào)用WaitOne方法減1,所以第二個進(jìn)行一開始信號計數(shù)為1而不是進(jìn)程一中的4,如果我們把信號計數(shù)后面的name參數(shù)去除的話,此時第二個進(jìn)程和第一個進(jìn)程中的結(jié)果應(yīng)該是一樣的(因為此時沒有進(jìn)行不同進(jìn)程中線程的同步)。
二、互斥體(Mutex)
同樣互斥體也是同樣可以實現(xiàn)線程之間的同步和不同進(jì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();
- }
- }
運行結(jié)果:
實現(xiàn)進(jì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();
- }
- }
從運行結(jié)果看出兩個進(jìn)程之間的時間間隔為5秒,當(dāng)我們把構(gòu)造函數(shù)中命名參數(shù)去掉時就可以看出差別了。
三、小結(jié)
到這里多線程處理基本上講完,這個系列也只是一個入門,真真要好好掌握多線程,還是要在項目中多去實戰(zhàn)的。接下來我可能會做一個小的例子的,大概的思路是實現(xiàn)一個文件的下載的這樣的例子。如果大家有什么好的例子來運用多線程的知識的話,可以留言給我,我也會盡量去實現(xiàn)(如果不會的話,這樣也可以促使我去學(xué)習(xí)),實現(xiàn)后也會和大家分享的。
分享文章:[.Net線程處理系列]專題六:線程同步——信號量和互斥體
文章來源:http://chinadenli.net/article18/ihsddp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供App設(shè)計、響應(yīng)式網(wǎng)站、企業(yè)網(wǎng)站制作、微信公眾號、營銷型網(wǎng)站建設(shè)、軟件開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)