C#多線程系列之線程通知
AutoRestEvent 類用于從一個線程向另一個線程發(fā)送通知。
微軟文檔是這樣介紹的:表示線程同步事件在一個等待線程釋放后收到信號時自動重置。
其構(gòu)造函數(shù)只有一個:
構(gòu)造函數(shù)里面的參數(shù)用于設(shè)置信號狀態(tài)。
構(gòu)造函數(shù) | 說明 |
---|---|
AutoResetEvent(Boolean) | 用一個指示是否將初始狀態(tài)設(shè)置為終止的布爾值初始化 AutoResetEvent 類的新實例。 |
真糟糕的機器翻譯。
常用方法
AutoRestEvent 類是干嘛的,構(gòu)造函數(shù)的參數(shù)又是干嘛的?不著急,我們來先來看看這個類常用的方法:
方法 | 說明 |
---|---|
Close() | 釋放由當前 WaitHandle 占用的所有資源。 |
Reset() | 將事件狀態(tài)設(shè)置為非終止,從而導(dǎo)致線程受阻。 |
Set() | 將事件狀態(tài)設(shè)置為有信號,從而允許一個或多個等待線程繼續(xù)執(zhí)行。 |
WaitOne() | 阻止當前線程,直到當前 WaitHandle 收到信號。 |
WaitOne(Int32) | 阻止當前線程,直到當前 WaitHandle 收到信號,同時使用 32 位帶符號整數(shù)指定時間間隔(以毫秒為單位)。 |
WaitOne(Int32, Boolean) | 阻止當前線程,直到當前的 WaitHandle 收到信號為止,同時使用 32 位帶符號整數(shù)指定時間間隔,并指定是否在等待之前退出同步域。 |
WaitOne(TimeSpan) | 阻止當前線程,直到當前實例收到信號,同時使用 TimeSpan 指定時間間隔。 |
WaitOne(TimeSpan, Boolean) | 阻止當前線程,直到當前實例收到信號為止,同時使用 TimeSpan 指定時間間隔,并指定是否在等待之前退出同步域。 |
一個簡單的示例
這里我們編寫一個這樣的程序:
創(chuàng)建一個線程,能夠執(zhí)行多個階段的任務(wù);每完成一個階段,都需要停下來,等待子線程發(fā)生通知,才能繼續(xù)下一步執(zhí)行。
.WaitOne()
用來等待另一個線程發(fā)送通知;
.Set()
用來對線程發(fā)出通知,此時 AutoResetEvent
變成終止狀態(tài);
.ReSet()
用來重置 AutoResetEvent
狀態(tài);
class Program { // 線程通知 private static AutoResetEvent resetEvent = new AutoResetEvent(false); static void Main(string[] args) { // 創(chuàng)建線程 new Thread(DoOne).Start(); // 用于不斷向另一個線程發(fā)送信號 while (true) { Console.ReadKey(); resetEvent.Set(); // 發(fā)生通知,設(shè)置終止狀態(tài) } } public static void DoOne() { Console.WriteLine("等待中,請發(fā)出信號允許我運行"); // 等待其它線程發(fā)送信號 resetEvent.WaitOne(); Console.WriteLine("\n 收到信號,繼續(xù)執(zhí)行"); for (int i = 0; i < 5; i++) Thread.Sleep(TimeSpan.FromSeconds(0.5)); resetEvent.Reset(); // 重置為非終止狀態(tài) Console.WriteLine("\n第一階段運行完畢,請繼續(xù)給予指示"); // 等待其它線程發(fā)送信號 resetEvent.WaitOne(); Console.WriteLine("\n 收到信號,繼續(xù)執(zhí)行"); for (int i = 0; i < 5; i++) Thread.Sleep(TimeSpan.FromSeconds(0.5)); Console.WriteLine("\n第二階段運行完畢,線程結(jié)束,請手動關(guān)閉窗口"); } }
解釋一下
AutoResetEvent 對象有終止和非終止狀態(tài)。Set()
設(shè)置終止狀態(tài),Reset()
重置非終止狀態(tài)。
這個終止狀態(tài),可以理解成信號已經(jīng)通知;非終止狀態(tài)則是信號還沒有通知。
注意,注意終止狀態(tài)和非終止狀態(tài)指的是 AutoResetEvent 的狀態(tài),不是指線程的狀態(tài)。
線程通過調(diào)用 WaitOne() 方法,等待信號;
另一個線程可以調(diào)用 Set() 通知 AutoResetEvent 釋放等待線程。
然后 AutoResetEvent 變?yōu)榻K止狀態(tài)。
需要注意的是,如果 AutoResetEvent 已經(jīng)處于終止狀態(tài),那么線程調(diào)用 WaitOne()
不會再起作用。除非調(diào)用Reset()
。
構(gòu)造函數(shù)中的參數(shù),正是設(shè)置這個狀態(tài)的。true 代表終止狀態(tài),false 代表非終止狀態(tài)。如果使用 new AutoResetEvent(true);
,則線程一開始是無需等待信號的。
在使用完類型后,您應(yīng)直接或間接釋放類型,顯式調(diào)用 Close()/Dispose()
或 使用 using
。 當然,也可以直接退出程序。
需要注意的是,如果多次調(diào)用 Set()
的時間間隔過短,如果第一次 Set()
還沒有結(jié)束(信號發(fā)送需要處理時間),那么第二次 Set()
可能無效(不起作用)。
復(fù)雜一點的示例
我們設(shè)計一個程序:
- Two 線程開始處于阻塞狀態(tài);
- 線程 One 可以設(shè)置線程 Two 繼續(xù)運行,然后阻塞自己;
- 線程 Two 可以設(shè)置 One 繼續(xù)運行,然后阻塞自己;
程序代碼如下(運行后,請將鍵盤設(shè)置成英文輸入狀態(tài)再按下按鍵):
class Program { // 控制第一個線程 // 第一個線程開始時,AutoResetEvent 處于終止狀態(tài),無需等待信號 private static AutoResetEvent oneResetEvent = new AutoResetEvent(true); // 控制第二個線程 // 第二個線程開始時,AutoResetEvent 處于非終止狀態(tài),需要等待信號 private static AutoResetEvent twoResetEvent = new AutoResetEvent(false); static void Main(string[] args) { new Thread(DoOne).Start(); new Thread(DoTwo).Start(); Console.ReadKey(); } public static void DoOne() { while (true) { Console.WriteLine("\n① 按一下鍵,我就讓DoTwo運行"); Console.ReadKey(); twoResetEvent.Set(); oneResetEvent.Reset(); // 等待 DoTwo() 給我信號 oneResetEvent.WaitOne(); Console.ForegroundColor = ConsoleColor.Green; Console.WriteLine("\n DoOne() 執(zhí)行"); Console.ForegroundColor = ConsoleColor.White; } } public static void DoTwo() { while (true) { Thread.Sleep(TimeSpan.FromSeconds(1)); // 等待 DoOne() 給我信號 twoResetEvent.WaitOne(); Console.ForegroundColor = ConsoleColor.Yellow; Console.WriteLine("\n DoTwo() 執(zhí)行"); Console.ForegroundColor = ConsoleColor.White; Console.WriteLine("\n② 按一下鍵,我就讓DoOne運行"); Console.ReadKey(); oneResetEvent.Set(); twoResetEvent.Reset(); } } }
解釋
兩個線程具有的功能:阻塞自己、解除另一個線程的阻塞。
用電影《最佳拍檔》里面的一個畫面來理解。
DoOne 、DoTwo 輪流呼吸,不能自己控制自己呼吸,但自己能夠決定別人呼吸。
你搞我,我搞你,就能相互呼吸了。
當然WaitOne()
也可以設(shè)置等待時間,如果 光頭佬(DoOne) 耍賴不讓 金剛(DoTwo)呼吸,金剛等待一定時間后,可以強行蕩動天平,落地呼吸。
注意,AutoRestEvent 用得不當容易發(fā)生死鎖。
另外 AutoRestEvent 使用的是內(nèi)核時間模式,因此等待時間不能太長,不然比較耗費 CPU 時間。
AutoResetEvent 也適合用于線程同步。
另外,線程中使用 WaitOne()
,另一個線程使用 Set()
通知后, AutoResetEvent 對象會自動恢復(fù)非終止狀態(tài),不需要線程使用 Reset()
。
到此這篇關(guān)于C#多線程系列之線程通知的文章就介紹到這了。希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
C#/VB.NET 在PDF中添加文件包(Portfolio)的方法
這篇文章主要介紹了C#/VB.NET 在PDF中添加文件包(Portfolio)的方法,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧2020-06-06.net C# 實現(xiàn)任意List的笛卡爾乘積算法代碼
笛卡爾(Descartes)乘積又叫直積。假設(shè)集合A={a,b},集合B={0,1,2},則兩個集合的笛卡爾積為{(a,0),(a,1),(a,2),(b,0),(b,1), (b,2)}。2013-05-05C# winform實現(xiàn)右下角彈出窗口結(jié)果的方法
這篇文章主要介紹了C# winform實現(xiàn)右下角彈出窗口結(jié)果的方法,結(jié)合實例形式分析了C#窗口操作的相關(guān)技巧,需要的朋友可以參考下2017-06-06C#通過第三方組件生成二維碼(QR Code)和條形碼(Bar Code)
用C#如何生成二維碼,我們可以通過現(xiàn)有的第三方dll直接來實現(xiàn),下面列出幾種不同的生成方法2016-12-12提權(quán)函數(shù)之RtlAdjustPrivilege()使用說明
RtlAdjustPrivilege() 這玩意是在 NTDLL.DLL 里的一個不為人知的函數(shù),MS沒有公開,原因就是這玩意實在是太NB了,以至于不需要任何其他函數(shù)的幫助,僅憑這一個函數(shù)就可以獲得進程ACL的任意權(quán)限!2011-06-06