快捷導(dǎo)航

深入多線程之:Wait與Pulse的使用詳解

更新時(shí)間：2013年05月14日 15:21:19 作者：

本篇文章是對(duì)Wait與Pulse的使用進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下

Signaling with Wait and Pulse（等待和暫停的信號(hào)）

早期談?wù)撨^(guò)等待事件句柄(調(diào)用Wait的線程在沒(méi)有收到另一個(gè)線程的通知前會(huì)一直阻塞)。

Monitor借助它的靜態(tài)方法Wait，Pulse，PulseAll提供了一個(gè)更給力的信號(hào)構(gòu)造，使用這些方法和lock語(yǔ)句，你可以自己實(shí)現(xiàn)AutoResetEvent，ManualResetEvent和Semaphore。甚至WaitHandle的WaitAll和WaitAny方法了。

怎樣使用Wait 和Pulse ?

1:定義一個(gè)同步對(duì)象，例如：

　　Readonly object _locker=new object();

2:定義自己的阻塞條件中的字段。

　　bool _go 或者 int _semaphoreCount;

3:當(dāng)你想要阻塞的時(shí)候，包含下面的代碼

　　lock(_locker)

while(<阻塞條件 >) //比如while (_go ==false)

Monitor.Wait(_locker); //滿足阻塞條件，開始阻塞。

4:當(dāng)想要改變阻塞條件的時(shí)候，包含下面的代碼：

lock(_locker)

{

//<更改阻塞條件中的字段>,比如_go=true;

Monitor.Pulse(_locker); //或者: Monitor.PulseAll(_locker); //通知等待隊(duì)列中的線程鎖定對(duì)象狀態(tài)的更改。

}

這個(gè)模式可以讓你隨時(shí)隨地等待線程。下面是一個(gè)例子，worker線程在_go 字段變成true之前會(huì)一直等待。

復(fù)制代碼代碼如下:

static readonly object _locker = new object();
static bool _go;

        internal static void Main()
        {
            new Thread(Work).Start(); //新線程會(huì)被阻塞，因?yàn)開go == false
            Console.ReadLine(); //等待用戶輸入

            lock (_locker)
            {
                _go = true; //改變阻塞條件
                Monitor.Pulse(_locker); //通知等待的隊(duì)列。
            }
        }

        static void Work()
        {
            lock (_locker)
            {
                while (!_go) //只要_go字段是false，就等待。
                    Monitor.Wait(_locker); //在等待的時(shí)候，鎖已經(jīng)被釋放了。
            }

Console.WriteLine("被喚醒了");
}

為了線程安全，確保所有共享的字段在讀取的時(shí)候都加鎖了。

Work方法會(huì)一直阻塞，等待_go字段變成true，Monitor.Wait方法按順序的做了以下的操作。

1：釋放鎖_locker;

2：阻塞鎖，直到_locker 是”pulsed”。

3：重新在_locker 上獲取鎖，如果鎖已經(jīng)被其他線程獲得，那么線程開始阻塞，直到鎖變得可用為止。

復(fù)制代碼代碼如下:

lock(_locker)
{
    While(!_go)
        Monitor.Wait(_locker); //釋放鎖
    //已經(jīng)重新獲取了鎖。
}

如果我們拋棄該模式，例如移除while循環(huán)。_go字段和ReadLine方法等：

復(fù)制代碼代碼如下:

static object _locker = new object();

        internal static void Main()
        {
            new Thread(Work).Start();
            lock (_locker) Monitor.Pulse(_locker);
        }

        static void Work()
        {
            lock (_locker) Monitor.Wait(_locker);
            Console.WriteLine("被喚醒了");
        }

那么程序運(yùn)行的結(jié)果又如何呢?

實(shí)際上輸出是不確定的，有可能你不能顯示“被喚醒了”。

主要原因是主線程和Work線程之間存在著競(jìng)爭(zhēng)關(guān)系，如果Wait方法先執(zhí)行，那么可以正常顯示，但是如果Pulse方法先執(zhí)行，pulse就會(huì)丟失，worker線程就會(huì)永遠(yuǎn)的等待。這種行為和AutoResetEvent不同，AutoResetEvent的Set方法有一種記憶的效果，所以即使它在WaitOne方法前調(diào)用，它仍然有效。

但是Pulse沒(méi)有記憶功能，因?yàn)槟阆Ｍ约簩?shí)現(xiàn)記憶功能，就像我們之前使用_go 標(biāo)志一樣，

這就是為什么Wait和Pulse是通用的原因：使用一個(gè)boolean 標(biāo)志，我們可以實(shí)現(xiàn)AutoResetEvent的功能，使用一個(gè)integer標(biāo)志，我們可以實(shí)現(xiàn) CountdownEvent,Semaphore.使用更復(fù)雜的結(jié)構(gòu)，我么可以寫一些更復(fù)雜的構(gòu)造。