
C#中的Monitor类和lock语句实际上是同一概念的不同表达方式。lock语句是Monitor类的语法糖,提供了一种更简洁、易用的方式来获取和释放对象的互斥锁。
lock语句本质上是Monitor.Enter和Monitor.Exit的封装。
// lock 语句
lock (obj)
{
// 受保护的代码
}
// 等价于
Monitor.Enter(obj);
try
{
// 受保护的代码
}
finally
{
Monitor.Exit(obj);
}lock语句保证了即使在受保护的代码块中发生异常,锁也会被正确释放,避免死锁。
C# Monitor类的核心功能是什么?
Monitor类提供了一系列静态方法,用于实现线程同步,它允许线程获取对象的独占锁,并提供了线程等待和通知机制。主要功能包括:
true;否则,立即返回false,不会阻塞。TryEnter还有带超时时间的重载版本,允许线程等待一段时间。Enter配对使用。Pulse或PulseAll来唤醒它。必须在持有锁的情况下调用。使用Monitor类时,需要特别注意锁的正确释放。如果忘记调用Exit,或者在Enter和Exit之间发生未处理的异常,可能会导致死锁。这也是为什么lock语句更安全的原因,因为它使用try-finally块来确保锁总是被释放。
什么时候应该使用Monitor类而不是lock语句?
虽然lock语句在大多数情况下更方便、更安全,但Monitor类在某些高级场景下提供了更大的灵活性。例如:
Monitor.TryEnter方法。这在某些需要避免长时间阻塞的场景中很有用。Monitor类的Wait、Pulse和PulseAll方法提供了线程等待和通知机制,可以实现更复杂的线程同步逻辑,例如生产者-消费者模式。一个使用Monitor类实现简单线程同步的例子:
class Example
{
private static readonly object _locker = new object();
private static int _counter = 0;
public static void IncrementCounter()
{
Monitor.Enter(_locker);
try
{
_counter++;
Console.WriteLine($"Thread {Thread.CurrentThread.ManagedThreadId}: Counter = {_counter}");
}
finally
{
Monitor.Exit(_locker);
}
}
public static void Main(string[] args)
{
Thread[] threads = new Thread[5];
for (int i = 0; i < 5; i++)
{
threads[i] = new Thread(IncrementCounter);
threads[i].Start();
}
foreach (Thread thread in threads)
{
thread.Join();
}
Console.WriteLine($"Final Counter Value: {_counter}");
}
}在这个例子中,多个线程同时访问和修改_counter变量。使用Monitor.Enter和Monitor.Exit确保了对_counter的访问是线程安全的。try-finally块保证了即使在IncrementCounter方法中发生异常,锁也会被释放。
Monitor类的Wait(), Pulse(), PulseAll()方法具体如何使用?
Wait、Pulse和PulseAll是Monitor类中用于线程间通信的关键方法,它们允许线程在特定条件下挂起自身,等待其他线程发出信号。以下是它们的具体用法:
Wait(object obj):
Pulse或PulseAll来唤醒它。Wait方法。例如,在生产者-消费者模式中,当缓冲区为空时,消费者线程可以调用Wait方法挂起自身,等待生产者线程向缓冲区添加数据。Wait方法必须在持有锁的情况下调用。调用Wait方法会自动释放锁,允许其他线程访问共享资源。当线程被唤醒后,它会尝试重新获取锁。Pulse(object obj):
Pulse方法通知等待该条件的线程。例如,在生产者-消费者模式中,当生产者线程向缓冲区添加数据后,可以调用Pulse方法唤醒一个等待的消费者线程。Pulse方法必须在持有锁的情况下调用。Pulse方法只会唤醒一个线程,如果有多个线程在等待,只有其中一个会被唤醒。PulseAll(object obj):
PulseAll方法。例如,在某些复杂的并发场景中,可能需要一次性唤醒所有等待的线程。PulseAll方法必须在持有锁的情况下调用。PulseAll方法会唤醒所有等待的线程,这可能会导致竞争,因此需要谨慎使用。一个使用Wait、Pulse实现生产者-消费者模式的例子:
class ProducerConsumer
{
private static readonly object _locker = new object();
private static Queue<int> _queue = new Queue<int>();
private static int _capacity = 5;
public static void Produce()
{
Random random = new Random();
while (true)
{
lock (_locker)
{
while (_queue.Count == _capacity)
{
Console.WriteLine("Producer is waiting, queue is full.");
Monitor.Wait(_locker);
}
int item = random.Next(100);
_queue.Enqueue(item);
Console.WriteLine($"Producer produced: {item}");
Monitor.Pulse(_locker); // 通知一个消费者
}
Thread.Sleep(random.Next(500));
}
}
public static void Consume()
{
Random random = new Random();
while (true)
{
lock (_locker)
{
while (_queue.Count == 0)
{
Console.WriteLine("Consumer is waiting, queue is empty.");
Monitor.Wait(_locker);
}
int item = _queue.Dequeue();
Console.WriteLine($"Consumer consumed: {item}");
Monitor.Pulse(_locker); // 通知一个生产者
}
Thread.Sleep(random.Next(500));
}
}
public static void Main(string[] args)
{
Thread producerThread = new Thread(Produce);
Thread consumerThread = new Thread(Consume);
producerThread.Start();
consumerThread.Start();
Console.ReadKey();
}
}在这个例子中,生产者线程负责向队列中添加数据,消费者线程负责从队列中取出数据。当队列满时,生产者线程会调用Monitor.Wait挂起自身,等待消费者线程消费数据。当队列为空时,消费者线程会调用Monitor.Wait挂起自身,等待生产者线程生产数据。Monitor.Pulse用于通知等待的线程。
以上就是C#的Monitor类和lock语句有何关系?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号