C#多線(xiàn)程之線(xiàn)程同步WaitHandle
一、引言
在前面的文章中,我們是使用“鎖”的方式實(shí)現(xiàn)了線(xiàn)程間的通信,這種通信方式比較笨重。除了鎖之外,.NET中還提供了一些線(xiàn)程間更自由通訊的工具,他們提供了通過(guò)“信號(hào)”進(jìn)行通訊的機(jī)制,通俗的比喻為“開(kāi)門(mén)”、“關(guān)門(mén)”:Set()開(kāi)門(mén)、Reset()關(guān)門(mén)、WaitOne()等著。
二、WaitHandle
WaitHandle位于System.Threading命名空間下,是用來(lái)封裝等待對(duì)共享資源進(jìn)行獨(dú)占訪(fǎng)問(wèn)的操作系統(tǒng)特定的對(duì)象。WaitHandle是一個(gè)抽象類(lèi),我們一般不直接使用,而是使用它的派生類(lèi):
- AutoResetEvent。
- EventWaitHandle。
- ManualResetEvent。
- Mutex。
- Semaphore。
1、AutoResetEvent
AutoResetEvent表示線(xiàn)程同步事件在一個(gè)等待線(xiàn)程釋放后收到信號(hào)時(shí)自動(dòng)重置。此類(lèi)不能被繼承。
是一個(gè)自動(dòng)阻塞,WaitOne()方法阻塞程序執(zhí)行,Set()方法釋放信息。當(dāng)釋放后阻塞的代碼繼續(xù)執(zhí)行。但下一次執(zhí)行還需要等待信號(hào)。
通俗來(lái)說(shuō),WaitOne()是關(guān)門(mén),Set()是開(kāi)門(mén)。但開(kāi)門(mén)之后,執(zhí)行完又自動(dòng)關(guān)門(mén),還需要開(kāi)門(mén)。可以知道超時(shí)時(shí)間:
// 設(shè)置超時(shí)時(shí)間為2秒,如果2秒后沒(méi)有信號(hào)程序繼續(xù)執(zhí)行 are.WaitOne(2000);
看下面的一個(gè)例子:
using System; using System.Threading; namespace AutoResetEventDemo { class Program { static void Main(string[] args) { // 通過(guò)構(gòu)造函數(shù)創(chuàng)建,默認(rèn)是關(guān)門(mén) AutoResetEvent are = new AutoResetEvent(false); Thread t1 = new Thread(() => { while (true) { Console.WriteLine("開(kāi)始等著開(kāi)門(mén)"); // 執(zhí)行完WaitOne之后自動(dòng)關(guān)門(mén) are.WaitOne(); Console.WriteLine("又關(guān)門(mén)了"); } }); // 啟動(dòng)線(xiàn)程 t1.Start(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadKey(); //開(kāi)門(mén) are.Set(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadKey(); //開(kāi)門(mén) are.Set(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadKey(); //開(kāi)門(mén) are.Set(); Console.ReadKey(); } } }
程序輸出結(jié)果:
舉一個(gè)形象點(diǎn)的例子,AutoResetEvent相當(dāng)于火車(chē)或者地鐵的閘機(jī)口,過(guò)了一個(gè)以后自動(dòng)關(guān)門(mén)。
2、ManualResetEvent
Manual表示手動(dòng)的??聪旅娴拇a:
using System; using System.Threading; namespace ManualResetEventDemo { class Program { static void Main(string[] args) { // 通過(guò)構(gòu)造函數(shù)初始化 // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén) ManualResetEvent mre = new ManualResetEvent(false); // 創(chuàng)建一個(gè)線(xiàn)程 Thread t1 = new Thread(() => { // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén) Console.WriteLine("開(kāi)始等著開(kāi)門(mén)"); // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼 mre.WaitOne(); // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼 Console.WriteLine("終于開(kāi)門(mén)了"); }); // 啟動(dòng)線(xiàn)程 t1.Start(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadLine(); // 調(diào)用開(kāi)門(mén)的方法 mre.Set(); Console.ReadKey(); } } }
運(yùn)行程序,什么也不輸入,看一下輸出結(jié)果:
我們隨意輸入,再看運(yùn)行結(jié)果:
怎么關(guān)門(mén)呢?關(guān)門(mén)也需要我們手動(dòng)的調(diào)用:
using System; using System.Threading; namespace ManualResetEventDemo { class Program { static void Main(string[] args) { // 通過(guò)構(gòu)造函數(shù)初始化 // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén) ManualResetEvent mre = new ManualResetEvent(false); // 創(chuàng)建一個(gè)線(xiàn)程 Thread t1 = new Thread(() => { // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén) Console.WriteLine("開(kāi)始等著開(kāi)門(mén)"); // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼 mre.WaitOne(); // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼 Console.WriteLine("終于開(kāi)門(mén)了"); }); // 啟動(dòng)線(xiàn)程 t1.Start(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadLine(); // 調(diào)用開(kāi)門(mén)的方法 mre.Set(); // 休眠3秒 Thread.Sleep(3000); // 關(guān)門(mén) mre.Reset(); Console.WriteLine("關(guān)門(mén)了"); Console.ReadKey(); } } }
程序輸出結(jié)果:
WaitOne()方法還可以設(shè)置等待超時(shí)時(shí)間,超過(guò)了等待時(shí)間就不會(huì)再等了。如果不設(shè)置等待超時(shí)時(shí)間,那么就會(huì)一直等下去??聪旅娲a:
using System; using System.Threading; namespace ManualResetEventDemo { class Program { static void Main(string[] args) { // 通過(guò)構(gòu)造函數(shù)初始化 // false表示“初始狀態(tài)為關(guān)門(mén)”,設(shè)置為true則表示初始狀態(tài)為開(kāi)門(mén) ManualResetEvent mre = new ManualResetEvent(false); //// 創(chuàng)建一個(gè)線(xiàn)程 //Thread t1 = new Thread(() => //{ // // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén) // Console.WriteLine("開(kāi)始等著開(kāi)門(mén)"); // // 調(diào)用等著開(kāi)門(mén)的方法,只有開(kāi)門(mén)以后才會(huì)執(zhí)行下面的代碼 // mre.WaitOne(); // // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼 // Console.WriteLine("終于開(kāi)門(mén)了"); //}); // 創(chuàng)建一個(gè)線(xiàn)程 Thread t1 = new Thread(() => { // 因?yàn)槌跏蓟臓顟B(tài)為關(guān)門(mén) Console.WriteLine("開(kāi)始等著開(kāi)門(mén)"); // 設(shè)置超時(shí)等待時(shí)間為5秒鐘 if(mre.WaitOne(5000)) { // 開(kāi)門(mén)之后才會(huì)執(zhí)行這句代碼 Console.WriteLine("終于開(kāi)門(mén)了"); } else { // 等待超時(shí) Console.WriteLine("過(guò)了5秒鐘了還沒(méi)開(kāi)門(mén)"); } }); // 啟動(dòng)線(xiàn)程 t1.Start(); Console.WriteLine("按任意鍵開(kāi)門(mén)"); Console.ReadLine(); // 調(diào)用開(kāi)門(mén)的方法 mre.Set(); // 休眠3秒 Thread.Sleep(3000); // 關(guān)門(mén) mre.Reset(); Console.WriteLine("關(guān)門(mén)了"); Console.ReadKey(); } } }
運(yùn)行程序,什么也不輸入,看運(yùn)行結(jié)果:
WaitHandle.WaitAll(WaitHandle[] waitHandles)用來(lái)等待所有信號(hào)都變?yōu)?ldquo;開(kāi)門(mén)狀態(tài)”,WaitHandle.WaitAny(WaitHandle[] waitHandles) 用來(lái)等待任意一個(gè)信號(hào)都變?yōu)?ldquo;開(kāi)門(mén)狀態(tài)”。
ManualResetEvent是一旦設(shè)定Set()后就一直開(kāi)門(mén),除非調(diào)用Reset()方法關(guān)門(mén)。
舉一個(gè)形象點(diǎn)的例子,ManualResetEvent就相當(dāng)于是學(xué)校的大門(mén),只要開(kāi)門(mén)以后大家都可以進(jìn)入,除非主動(dòng)關(guān)門(mén)(等于執(zhí)行了Reset()方法)。
到此這篇關(guān)于C#多線(xiàn)程之線(xiàn)程同步WaitHandle的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
MVVM簡(jiǎn)化的Messager類(lèi)實(shí)例代碼
這篇文章主要給大家介紹了關(guān)于MVVM簡(jiǎn)化的Messager類(lèi)的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2018-06-06Unity ScrollView實(shí)現(xiàn)無(wú)限循環(huán)效果
這篇文章主要為大家詳細(xì)介紹了Unity ScrollView實(shí)現(xiàn)無(wú)限循環(huán)效果,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-07-07C#實(shí)現(xiàn)基于加減按鈕形式控制系統(tǒng)音量及靜音的方法
這篇文章主要介紹了C#實(shí)現(xiàn)基于加減按鈕形式控制系統(tǒng)音量及靜音的方法,涉及C#引用user32.dll動(dòng)態(tài)鏈接庫(kù)操作系統(tǒng)音量的相關(guān)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-10-10探討:如何使用委托,匿名方法對(duì)集合進(jìn)行萬(wàn)能排序
本篇文章是對(duì)使用委托,匿名方法對(duì)集合進(jìn)行萬(wàn)能排序進(jìn)行了詳細(xì)的分析介紹,需要的朋友參考下2013-06-06