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

   2015-11-04 0
核心提示:本篇文章是对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.使用更复杂的结构,我么可以写一些更复杂的构造。

 
标签: Wait Pulse
反对 0举报 0 评论 0
 

免责声明:本文仅代表作者个人观点,与乐学笔记(本网)无关。其原创性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
    本网站有部分内容均转载自其它媒体,转载目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责,若因作品内容、知识产权、版权和其他问题,请及时提供相关证明等材料并与我们留言联系,本网站将在规定时间内给予删除等相关处理.

  • [微信小程序] 终于可以愉快的使用 async/await
    这篇文章主要是想说一下 怎么在微信小程序中使用async/await从而逃离回调地狱背景最近一直在搞微信小程序 用的语言是TypeScript 小程序的api都是回调形式 用起来就是各种回调嵌套 我个人很不喜欢 所以一直想用async/await之前用TypeScript target到ES2015 可
    02-09
  • ngx_lua_API 指令详解(六)ngx.thread.spawn、ngx.thread.wait、ngx.thread.kill介绍
    ngx_lua_API 指令详解(六)ngx.thread.spawn、
    摘要:通过lua-nginx-module中的ngx.thread同时执行多个任务。ngx_lua中访问多个第三方服务ngx_lua中提供了ngx.socket API,可以方便的访问第三方网络服务。如下面的代码,通过get_response函数从两个(或者更多)的源服务器获取数据,再生成响应发给客户端。l
    02-09
  • 【dart学习】-- Dart之async和await
    一,概述在Dart1.9中加入了async和await关键字,有了这两个关键字,我们可以更简洁的编写异步代码,而不需要调用Future相关的API。他们允许你像写同步代码一样写异步代码和不需要使用Future接口。相当于都Future相关API接口的另一种封装,提供了一种更加简便
    02-09
  • Swift 并行编程现状和展望 - async/await 和参与者模式
    Swift 并行编程现状和展望 - async/await 和参
    这篇文章不是针对当前版本 Swift 3 的,而是对预计于 2018 年发布的 Swift 5 的一些特性的猜想。如果两年后我还记得这篇文章,可能会回来更新一波。在此之前,请当作一篇对现代语言并行编程特性的不太严谨科普文来看待。CPU 速度已经很多年没有大的突破了,硬
    02-09
  • 关于nodejs中的async/await nodejs详解
    作用:将异步转为同步,其实有点语法糖,promise能实现的改为比较同步的方式表现。用法:两个关键字:async:放在函数声明前,用于表示这个函数含有异步过程,且此函数必定返回promise对象await:只能用于async声明了的函数里,如果await的对象是个promise,
    02-09
  • Nodejs中async/await以及Promise的使用
    场景:上传图片注意:try/catch是不能catch住Promise异步异常的其它:Nest.js中上传图片和裁剪async uploadAction (req, res) {try { // 同步调用 await saveFileWithStream(filePath, fileData); // 这里的fileData是Buffer类型} catch (err) { console.lo
    02-09
  • 使用c#的 async/await编写 长时间运行的基于代码的工作流的 持久任务框架
    使用c#的 async/await编写 长时间运行的基于代
    持久任务框架 (DTF) 是基于async/await 工作流执行框架。工作流的解决方案很多,包括Windows Workflow Foundation,BizTalk,Logic Apps, Workflow-Core 和 Elsa-Core。最近我在Dapr 的仓库里跟踪工作流构建块的进展时,深入了解了一下,这个DTFx在Azure 基
    02-09
  • Java使用wait/notify实现线程间通信下篇
    Java使用wait/notify实现线程间通信下篇
    目录1. 当 interrupt() 方法遇到 wait() 方法2. notify() 只通知一个线程3. notifyAll() 唤醒所有线程4. 方法 wait(long)的使用上一节针对wait/notify实现线程间通信的基本概念做了讲解(Java使用wait/notify实现线程间通信上篇),本节继续针对wait/notify实
  • Go语言通过WaitGroup实现控制并发的示例详解
    目录与Channel区别基本使用示例完整代码特别提示多任务示例完整代码与Channel区别Channel能够很好的帮助我们控制并发,但是在开发习惯上与显示的表达不太相同,所以在Go语言中可以利用sync包中的WaitGroup实现并发控制,更加直观。基本使用示例我们将之前的示
  • [C#]SourceGenerator实战: 对任意对象使用await吧!!!
    [C#]SourceGenerator实战: 对任意对象使用await
    [C#]SourceGenerator实战: 对任意对象使用await吧!!!前言本文记录一次简单的 SourceGenerator 实战,最终实现可以在代码中 await 任意类型对象,仅供娱乐,请勿在生产环境中使用!!!关键技术:SourceGenerator在编译时动态生成代码的技术。官方文档:源生成
点击排行