深入多线程之:Wait与Pulse的使用详解

 更新时间:2013年05月14日 15:21:19   作者:  
本篇文章是对Wait与Pulse的使用进行了详细的分析介绍,需要的朋友参考下

Signaling with Wait and Pulse(等待和暂停的信号)

早期谈论过等待事件句柄(调用Wait的线程在没有收到另一个线程的通知前会一直阻塞)。

Monitor借助它的静态方法Wait,Pulse,PulseAll提供了一个更给力的信号构造,使用这些方法和lock语句,你可以自己实现AutoResetEvent,ManualResetEvent和Semaphore。甚至WaitHandle的WaitAll和WaitAny方法了。

怎样使用Wait 和Pulse ?

1:定义一个同步对象,例如:

  Readonly object _locker=new object();

2:定义自己的阻塞条件中的字段。

  bool _go 或者 int _semaphoreCount;

3:当你想要阻塞的时候,包含下面的代码

  lock(_locker)

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

                   Monitor.Wait(_locker);    //满足阻塞条件,开始阻塞。

4:当想要改变阻塞条件的时候,包含下面的代码:

     lock(_locker)

{

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

         Monitor.Pulse(_locker); //或者: Monitor.PulseAll(_locker); //通知等待队列中的线程锁定对象状态的更改。

}

这个模式可以让你随时随地等待线程。下面是一个例子,worker线程在_go 字段变成true之前会一直等待。

复制代码 代码如下:

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

        internal static void Main()
        {
            new Thread(Work).Start(); //新线程会被阻塞,因为_go == false
            Console.ReadLine(); //等待用户输入

            lock (_locker)
            {
                _go = true; //改变阻塞条件
                Monitor.Pulse(_locker); //通知等待的队列。
            }
        }

        static void Work()
        {
            lock (_locker)
            {
                while (!_go) //只要_go字段是false,就等待。
                    Monitor.Wait(_locker); //在等待的时候,锁已经被释放了。
            }

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


为了线程安全,确保所有共享的字段在读取的时候都加锁了。

Work方法会一直阻塞,等待_go字段变成true,Monitor.Wait方法按顺序的做了以下的操作。

1:释放锁_locker;

2:阻塞锁,直到_locker 是”pulsed”。

3:重新在_locker 上获取锁,如果锁已经被其他线程获得,那么线程开始阻塞,直到锁变得可用为止。

复制代码 代码如下:

lock(_locker)
{
    While(!_go)
        Monitor.Wait(_locker); //释放锁
    //已经重新获取了锁。
}


如果我们抛弃该模式,例如移除while循环。_go字段和ReadLine方法等:
复制代码 代码如下:

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("被唤醒了");
        }


那么程序运行的结果又如何呢?

实际上输出是不确定的,有可能你不能显示“被唤醒了”。

主要原因是主线程和Work线程之间存在着竞争关系,如果Wait方法先执行,那么可以正常显示,但是如果Pulse方法先执行,pulse就会丢失,worker线程就会永远的等待。这种行为和AutoResetEvent不同,AutoResetEvent的Set方法有一种记忆的效果,所以即使它在WaitOne方法前调用,它仍然有效。


但是Pulse没有记忆功能,因为你希望自己实现记忆功能,就像我们之前使用_go 标志一样,

这就是为什么Wait和Pulse是通用的原因:使用一个boolean 标志,我们可以实现AutoResetEvent的功能,使用一个integer标志,我们可以实现 CountdownEvent,Semaphore.使用更复杂的结构,我么可以写一些更复杂的构造。

相关文章

  • C#如何更改Word的语言设置

    C#如何更改Word的语言设置

    这篇文章主要为大家详细介绍了C#如何更改Word的语言设置,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-05-05
  • C#递归算法之快速排序

    C#递归算法之快速排序

    快速排序由C.A.R发明,它依据中心元素的值,利用一系列递归调用将数据表划分成越来越小的子表。在每一步调用中,经过多次的交换,最终为中心元素找到最终的位置。
    2016-06-06
  • sort page 排序和分页的小例子

    sort page 排序和分页的小例子

    花了一上午时间,终于写了一个进行排序并且分页的类,下面将代码贴出来,望大家指正。
    2013-05-05
  • c#委托学习示例分享

    c#委托学习示例分享

    委托是一个类,它定义了方法的类型,使得可以将方法当作另一个方法的参数来进行传递,这种将方法动态地赋给参数的做法,可以避免在程序中大量使用If-Else(Switch)语句,同时使得程序具有更好的可扩展性,下面是c#委托示例
    2014-03-03
  • C# InitializeComponent()方法案例详解

    C# InitializeComponent()方法案例详解

    这篇文章主要介绍了C# InitializeComponent()方法案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • C# VB.NET 实现在Word中嵌入多媒体(视频、音频)文件

    C# VB.NET 实现在Word中嵌入多媒体(视频、音频)文件

    Word中可将Office、PDF、txt等文件作为OLE对象插入到文档中,双击该对象可直接访问或编辑该文件,除了以上常见的文件格式对象,也可以插入多媒体文件,如视频、音频等。本篇文章介绍了通过C#实现在Word中插入多媒体文件。感兴趣的可以学习一下
    2021-12-12
  • C#实现控制Windows系统关机、重启和注销的方法

    C#实现控制Windows系统关机、重启和注销的方法

    这篇文章主要介绍了C#实现控制Windows系统关机、重启和注销的方法,涉及C#调用windows系统命令实现控制开机、关机等操作的技巧,非常简单实用,需要的朋友可以参考下
    2015-04-04
  • Unity Sockect实现画面实时传输案例原理解析

    Unity Sockect实现画面实时传输案例原理解析

    Socket是比较常用的一种通信方式,本文通过案例给大家介绍Unity Sockect实现画面实时传输功能,感兴趣的朋友一起看看吧
    2021-08-08
  • C#中DataGridView常用操作实例小结

    C#中DataGridView常用操作实例小结

    这篇文章主要介绍了C#中DataGridView常用操作,以实例形式总结了DataGridView绑定下拉列表、设置默认值、判断复选框是否选中等技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-09-09
  • C#开发微信门户及应用(1) 微信接口使用

    C#开发微信门户及应用(1) 微信接口使用

    这篇文章主要为大家详细介绍了C#开发微信门户及应用第一篇,微信接口的使用方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-06-06

最新评论