深入多线程之:用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标志。
- 深入浅出多线程系列之十三:使用Wait和Pulse 来模拟一些同步构造
- 深入多线程之:Wait与Pulse的使用详解
- 深入浅出多线程系列之五:一些同步构造(下篇)
- 深入浅出多线程系列之五:一些同步构造(上篇)
- 深入分析Android ViewStub的应用详解
- 深入理解js的prototype以及prototype的一些应用
- 孙鑫MFC深入详解 第十五章 多线程(二)
- kafka数据同步Elasticsearch深入详解
- Java【多线程知识总结(9)】Timer类与TimerTask类的应用---模拟定时炸弹
- 详解Linux多线程使用信号量同步
- Enterprise Library深入解析与灵活应用(2): 通过SqlDependency实现Cache和Database的同步
- 多线程 : 使用 wait 和 notify 实现进程间同步通信
- 深入Java基础(四)--哈希表(1)HashMap应用及源码详解
- Spartan6系列之SelectIO深入详解及高级应用简介
- 深入理解Java多线程中的wait(),notify()和sleep()
- 深入分析wait/notify为什么要在同步块内
- elasticsearch-jdbc实现MySQL同步到ElasticSearch深入详解
- 多线程首次项目应用一些细节
- elasticsearch-jdbc实现MySQL同步到ElasticSearch深入详解
- Java多线程wait,notify以及同步锁的运用实例