脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → C#教程 → Wait与Pulse模拟同步构造

深入多线程之:用Wait与Pulse模拟一些同步构造的应用详解

 更新时间：2013年05月14日 15:02:59   作者：  
本篇文章是对用Wait与Pulse模拟一些同步构造的应用进行了详细的分析介绍，需要的朋友参考下

你可能在上篇文章中《深入多线程之:双向信号与竞赛的用法分析》注意到了这个模式：两个Waiting 循环都要下面的构造：

复制代码 代码如下:

lock(_locker)
{
        while(!_flag) Monitor.Wait(_locker);
        _flag = false;
}


在这里_flag被另一线程设置为true。这是，从作用上讲，这里在模仿AutoResetEvent。如果我们将 _flag = false;去掉，那么我们就得到了一个基本的ManualResetEvent.

让我们使用Wait和Pulse来为ManualResetEvent完成剩余的代码吧。

复制代码 代码如下:

readonly object _locker = new object();
        bool _signal;

        void WaitOne()
        {
            lock (_locker)
            {
                while (!_signal) Monitor.Wait(_locker);
            }
        }

        void Set()
        {
            lock (_locker) { _signal = true; Monitor.PulseAll(_locker); }
        }

        void Reset() { lock (_locker) _signal = false; }


在这里使用PulseAll，是因为可能有很多阻塞的线程。

如果在WaitOne方法中增加_signal=false就可以简单的模拟AutoResetEvent.例如：

复制代码 代码如下:

void WaitOne()
        {
            lock (_locker)
            {
                while (!_signal) Monitor.Wait(_locker);
                _signal = false; //实现自动关闭功|能
            }
        }

然后在Set方法中，将PulseAll修改为Pulse

Lock(_locker) {_signal = true; Monitor.Pulse(_locker);}

如果使用的是int类型的_signal 标志，那么我们可以得到一个最基本的Semaphore.

Waiting Queues and PulseAll

当多余一个线程在同一个对象上面等待的时候，一个 “等待队列(waiting queue)” 就形成了。

每一次调用Pulse都会释放在”等待队列”头部的一个线程。下面的图形象的展示了这一点：

 

线程调用Monitor.Enter 进入ReadyQueue. 等待获取锁，成功获取锁后，如果正常的执行，那么之后会调用Monitor.Exit退出,

否则如果获取了锁之后发现需要等待其他的线程或者是其他阻塞条件，那么调用Wait方法，就进入了等待队列，

当等待的线程完成并调用Pulse后，处在WaitingQueue头部的线程就被 Pulse了，等待CPU调度 。之后再次进入Ready Queue，重新获取锁。


Countdown

借助Wait和Pulse，我们可以实现CountdownEvent的主要功能。例如：

复制代码 代码如下:

class Countdown
    {
        object _locker = new object();
        int _value; //使用_value来计数

        public Countdown() { }
        public Countdown(int initialCount) { _value = initialCount; }

        public void Singnal() { AddCount(-1); } //将计数减一

        public void AddCount(int amount)
        {
            lock (_locker)
            {
                _value += amount; //将计数增加或减少
                if (_value <= 0) Monitor.PulseAll(_locker);//如果value<=0,说明所有等待的任务都完成了。
            }
        }

        public void Wait()
        {
            lock (_locker)
            {
                //只要计数 > 0 就等待。
                while (_value > 0)
                {
                    Monitor.Wait(_locker);
                }
            }
        }
}


这和我们上次的代码几乎一致，只是这次我们的阻塞条件基于一个整型_value标志。

相关文章

  • C#计算字符串相似性的方法

    C#计算字符串相似性的方法

    这篇文章主要介绍了C#计算字符串相似性的方法,实例分析了C#计算字符串相似性的原理与算法实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-07-07
  • C#简单的通用基础字典实现方法

    C#简单的通用基础字典实现方法

    这篇文章主要介绍了C#简单的通用基础字典实现方法,包含了字典的索引、记录、回调与查询等技巧,需要的朋友可以参考下
    2014-12-12
  • C# SQLite序列操作实现方法详解

    C# SQLite序列操作实现方法详解

    这篇文章主要介绍了C# SQLite序列操作实现方法,结合实例形式详细分析了C#实现SQLite序列操作的具体步骤与相关操作技巧,需要的朋友可以参考下
    2017-07-07
  • C#实现Json转Unicode的方法

    C#实现Json转Unicode的方法

    这篇文章主要介绍了C#实现Json转Unicode的方法,可实现输入为带有json格式的文本，输出正常文本的功能,需要的朋友可以参考下
    2014-09-09
  • C#自定义导出数据到Excel的类实例

    C#自定义导出数据到Excel的类实例

    这篇文章主要介绍了C#自定义导出数据到Excel的类,实例分析了C#操作Excel的技巧,非常具有实用价值,需要的朋友可以参考下
    2015-03-03
  • C#使用Exchange实现发送邮件

    C#使用Exchange实现发送邮件

    最近项目中需要用到exchange的操作,所以本文就参照msdn弄了一个简单的C#操作类,实现了发送邮件和拉取收件箱的功能,感兴趣的小伙伴可以了解下
    2023-10-10
  • 深入学习C#网络编程之HTTP应用编程（上）

    深入学习C#网络编程之HTTP应用编程（上）

    这篇文章主要介绍了如何学习C#网络编程之HTTP应用编程的相关知识，文中讲解的非常细致，代码帮助大家更好的理解和学习，感兴趣的朋友可以了解下
    2020-06-06
  • C# FileStream简单介绍和使用

    C# FileStream简单介绍和使用

    这篇文章主要为大家详细介绍了C# FileStream基本功能和使用，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-05-05
  • Unity实现旋转扭曲图像特效

    Unity实现旋转扭曲图像特效

    这篇文章主要为大家详细介绍了Unity实现旋转扭曲图像特效，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-02-02
  • C#中Class的实例化过程详解

    C#中Class的实例化过程详解

    文章详细阐述了C#中类的成员,包括静态字段、静态构造函数、实例字段等的初始化顺序,在无继承情况下,实例化分为声明时初始化和构造函数中初始化两种,分别有明确的执行顺序,需要的朋友可以参考下
    2024-09-09

最新评论