下面是说明问题的最低限度代码:
StringBuilder input = new StringBuilder();
void ToUpper()
{
lock (input)
{
while (true)
{
Monitor.Wait(input);
Console.WriteLine(input.ToString().ToUpper());
}
}
}
public void Run()
{
new Thread(ToUpper) { IsBackground = true }.Start();
// "Avoid" the initial race
Thread.Sleep(100);
while (true)
{
lock (input)
{
input.Clear();
input.Append(Console.ReadLine());
Monitor.Pulse(input);
}
// Thread.Sleep(1);
}
}忽略了已知的初始种族状况,我对脉冲和等待的行为感到惊讶。
以下是我所期望的:
Wait =>,它被推入监视器的等待队列Pulse => -- "ToUpper“线程从等待队列”移动“到就绪队列,以便立即获取锁。lock语句作用域时退出监视器。但是在两个线程中有一次"ToUpper“线程不处理输入,而是主线程立即执行它的处理()。
以下是我的假设:
Pulse不会立即“移动”"ToUpper“线程,从而使就绪队列保持为空。Pulse第二次为零,并释放锁。为了检查这个假设,我强迫主线程不那么急切,让其他线程工作,在本例中添加Thread.Sleep(1) =>,这一切都是“按预期工作”。
因此,这一切归结为Pulse的行为,它可能不会立即将线程从等待队列推送到就绪队列。
,这个问题真的来自于这场可能的比赛吗?还是我错过了另一个微妙的问题呢?
发布于 2013-11-03 12:24:24
您关于添加Thread.Sleep(1)的评论确实是答案。Pulse方法不为等待对象提供任何保证--它只是作为普通线程发布到就绪队列中。对Pulse的调用没有任何跟踪。因此,在调用Pulse之后,应用程序表现为普通的双线程应用程序,就绪队列中有两个线程-- ToUpper线程和 Run线程。因此,如果没有Thread.Sleep(1),就可能发生Run线程首先获得锁的情况(如果没有它,我猜也不太可能)。
我提供的第二个链接中的另一个重要评论是:
Monitor.Pulse的一个重要特性是异步执行,这意味着它本身不会以任何方式阻塞或暂停。
对于这个场景,AutoResetEvent类似乎更合适。此外,在第二环节中,您可以找到一个使用Wait和Pulse的生产者-消费者场景的示例。
https://stackoverflow.com/questions/19752730
复制相似问题