时间:2021-05-19
你可能在上篇文章中《深入多线程之:双向信号与竞赛的用法分析》注意到了这个模式:两个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标志。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
一、前期基础知识储备(1)线程同步的定义:多线程之间的同步。(2)多线程同步原因:一个多线程的程序如果是通过Runnable接口实现的,则意味着类中的属性将被多
用多线程模拟电影售票过程(Java实训),供大家参考,具体内容如下实训目的:多线程的实现、线程同步实训要求:总票数和售票窗口数由键盘输入,用每个线程处理一个窗口
Java中CountDownLatch进行多线程同步详解CountDownLatch介绍在前面的Java学习笔记中,总结了Java中进行多线程同步的几个方法:1
最近捣鼓了一下多线程的同步问题,发现其实C#关于多线程同步事件处理还是很灵活,这里主要写一下,自己测试的一些代码,涉及到了AutoResetEvent和Manu
在多线程开发中,常常遇到希望一组线程完成之后在执行之后的操作,java提供了一个多线程同步辅助类,可以完成此类需求:类中常见的方法:其中构造方法:CountDo