深入多線程之:雙向信號與競賽的用法分析
更新時(shí)間：2013年05月14日 14:54:25 作者：
本篇文章是對雙向信號與競賽的用法進(jìn)行了詳細(xì)的分析介紹。需要的朋友參考下
雙向信號和競賽(Two-Way Signaling and Races)
Monitor.Pulse方法的一個(gè)重要特性是它是異步執(zhí)行的，這意味著調(diào)用pulse方法并不會(huì)阻塞自己等待Monitor.Pulse返回。如果任何一個(gè)線程在pulsed 對象上等待，它是不會(huì)阻塞的，換句話說，調(diào)用Monitor.Pulse對程序不會(huì)有什么作用，你可以認(rèn)為Monitor.Pulse方法被忽略了。
這樣Pulse提供了一個(gè)單向通信：一個(gè) pulsing線程悄悄的向一個(gè)waiting 線程發(fā)送信號。
Pulse并不會(huì)返回一個(gè)值來告訴你waiting線程是否收到信號。
但是有時(shí)候我們需要知道waiting線程是否受到信號，例如下面的例子：
復(fù)制代碼 代碼如下:
class Race
{
static readonly object _locker = new object();
static bool _go;
public static void MainThread()
{
new Thread(SaySomething).Start();
for (int i = 0; i < 5; i++)
{
lock (_locker)
{
_go = true;
Monitor.PulseAll(_locker); //通知等待的隊(duì)列
}
}
}
static void SaySomething()
{
for (int i = 0; i < 5; i++)
{
lock (_locker)
{
while (!_go) Monitor.Wait(_locker); //如果_go 為false，那么開始阻塞。
_go = false;
Console.WriteLine("Wassup?");
}
}
}
}
期待的輸出：
Wassup?
Wassup?
Wassup?
Wassup?
Wassup?
實(shí)際的輸出：
Wassup? (線程等待)
在SaySomething方法中，for循環(huán)執(zhí)行到while，此時(shí)_go為false，所以Monitor.Wait開始等待。在MainThread中，for循環(huán)設(shè)置_go為true。然后PulseAll.但是PulseAll方法是異步的。
所以在SaySomething線程被喚醒前，mainThread中的for循環(huán)可能已經(jīng)執(zhí)行完畢。所以SaySomething方法中的第一個(gè)Wait線程收到消息詞是_go為true，所以往下執(zhí)行，再次將_go字段設(shè)置為false。輸出”Wassup？”,但是下次循環(huán)由于_go為false，所以需要再次wait.所以實(shí)際的輸出打印了一個(gè)Wassup，然后開始等待。
我們需要主線程在每一次迭代中如果worker仍然在執(zhí)行上一個(gè)任務(wù)，那么主線程阻塞。等到worker執(zhí)行完畢，那么主線程恢復(fù)執(zhí)行，然后執(zhí)行迭代。
我們可以增加一個(gè)_ready 標(biāo)志，從而控制主線程在設(shè)置_go 標(biāo)志之前worker線程已經(jīng)ready了。也就是說主線程在設(shè)置_go之前，會(huì)等待worker完成任務(wù)，然后等待worker將ready設(shè)為true，當(dāng)worker將ready設(shè)置為true后，通過pulse來通知主線程。
復(fù)制代碼 代碼如下:
class Race
{
static readonly object _locker = new object();
static bool _ready, _go;
public static void MainThread()
{
new Thread(SaySomething).Start();
for (int i = 0; i < 5; i++)
{
lock (_locker)
{
while (!_ready) Monitor.Wait(_locker); //如果worker的ready為false，則等待worker。
_ready = false; //重置標(biāo)志
_go = true;
Monitor.PulseAll(_locker);
}
}
}
static void SaySomething()
{
for (int i = 0; i < 5; i++)
{
lock (_locker)
{
_ready = true; //將ready設(shè)置為true
Monitor.PulseAll(_locker); //通知主線程，worker已經(jīng)ready了，可以執(zhí)行任務(wù)了。
while (!_go) Monitor.Wait(_locker);
_go = false;
Console.WriteLine("Wassup?");
}
}
}
}
相關(guān)文章
基于使用BeginInvoke,EndInvoke異步調(diào)用委托的實(shí)現(xiàn)代碼
本篇文章是對使用BeginInvoke,EndInvoke異步調(diào)用委托的實(shí)現(xiàn)代碼進(jìn)行了分析介紹，需要的朋友參考下2013-05-05
這篇文章介紹了C#實(shí)現(xiàn)FTP上傳文件的方法，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-04-04
下面小編就為大家分享一篇c#打包文件解壓縮的實(shí)例，具有很好的參考價(jià)值，希望對大家有所幫助。一起跟隨小編過來看看吧2017-11-11
C#中字段、屬性、只讀、構(gòu)造函數(shù)賦值、反射賦值的問題
這篇文章主要介紹了C#中字段、屬性、只讀、構(gòu)造函數(shù)賦值、反射賦值的問題 ,非常不錯(cuò)，具有一定的參考借鑒借鑒價(jià)值，需要的朋友可以參考下2018-08-08
可能有的看到這個(gè)題目就會(huì)覺得這不簡單嗎？直接用+號相加就行了，可是當(dāng)你實(shí)際操作運(yùn)行的時(shí)候就會(huì)發(fā)現(xiàn)有錯(cuò)誤了，那么是什么錯(cuò)誤？那該如何讓C#中兩個(gè)byte相加呢？通過下面這篇文章來一起學(xué)習(xí)學(xué)習(xí)吧。
2016-11-11 
這篇文章主要為大家詳細(xì)介紹了Unity自定義編輯器界面，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2019-09-09 
C#實(shí)現(xiàn)文件壓縮與解壓的方法示例【ZIP格式】
這篇文章主要介紹了C#實(shí)現(xiàn)文件壓縮與解壓的方法,結(jié)合具體實(shí)例形式分析了C#針對文件進(jìn)行zip格式壓縮與解壓縮的相關(guān)操作技巧,需要的朋友可以參考下
2017-06-06 
C#中實(shí)現(xiàn)PriorityQueue優(yōu)先級隊(duì)列的代碼
這篇文章主要介紹了C#中PriorityQueue優(yōu)先級隊(duì)列的實(shí)現(xiàn),構(gòu)造初始化這部分主要介紹關(guān)鍵的字段和方法，比較器的初始化以及堆的初始化，需要的朋友可以參考下
2021-12-12 
詳解WPF雙滑塊控件的使用和強(qiáng)制捕獲鼠標(biāo)事件焦點(diǎn)
這篇文章主要為大家詳細(xì)介紹了WPF中雙滑塊控件的使用和強(qiáng)制捕獲鼠標(biāo)事件焦點(diǎn)的實(shí)現(xiàn)，文中的示例代碼講解詳細(xì)，感興趣的可以嘗試一下
2022-07-07