C# lock

时间:2025-03-13 21:37:01

一. 为什么要lock,lock了什么?

当我们使用线程的时候,效率最高的方式当然是异步,即各个线程同时运行,其间不相互依赖和等待。但当不同的线程都需要访问某个资源的时候,就需要同步机制了,也就是说当对同一个资源进行读写的时候,我们要使该资源在同一时刻只能被一个线程操作,以确保每个操作都是有效即时的,也即保证其操作的原子性。lock是C#中最常用的同步方式,格式为lock(objectA){codeB} 。

lock(objectA){codeB} 看似简单,实际上有三个意思,这对于适当地使用它至关重要:
1. objectA被lock了吗?没有则由我来lock,否则一直等待,直至objectA被释放。
2. lock以后在执行codeB的期间其他线程不能调用codeB,也不能使用objectA。
3. 执行完codeB之后释放objectA,并且codeB可以被其他线程访问。

二. lock(this)怎么了?

我们看一个例子:

  1. using System;
  2. using System.Threading;
  3. namespace Namespace1
  4. {
  5. class C1
  6. {
  7. private bool deadlocked = true;
  8. //这个方法用到了lock,我们希望lock的代码在同一时刻只能由一个线程访问
  9. public void LockMe(object o)
  10. {
  11. lock (this)
  12. {
  13. while(deadlocked)
  14. {
  15. deadlocked = (bool)o;
  16. Console.WriteLine("Foo: I am locked :(");
  17. Thread.Sleep(500);
  18. }
  19. }
  20. }
  21. //所有线程都可以同时访问的方法
  22. public void DoNotLockMe()
  23. {
  24. Console.WriteLine("I am not locked :)");
  25. }
  26. }
  27. class Program
  28. {
  29. static void Main(string[] args)
  30. {
  31. C1 c1 = new C1();
  32. //在t1线程中调用LockMe,并将deadlock设为true(将出现死锁)
  33. Thread t1 = new Thread(c1.LockMe);
  34. t1.Start(true);
  35. Thread.Sleep(100);
  36. //在主线程中lock c1
  37. lock (c1)
  38. {
  39. //调用没有被lock的方法
  40. c1.DoNotLockMe();
  41. //调用被lock的方法,并试图将deadlock解除
  42. c1.LockMe(false);
  43. }
  44. }
  45. }

复制代码

在t1线程中,LockMe调用了lock(this), 也就是Main函数中的c1,这时候在主线程中调用lock(c1)时,必须要等待t1中的lock块执行完毕之后才能访问c1,即所有c1相关的操作都无法完成,于是我们看到连c1.DoNotLockMe()都没有执行。

lock 是锁定lock里面的代码段,保证代码段不会被同时执行,而不是锁定lock(c1) 的c1,c1.DoNotLockMe()里面不执行到lock(this)里面的代码,所以不会有影响,至于为什么第一段代码中的方法不执行,是因为主程序那里有一个lock(c1),c1对象在前面已经被申请了互斥锁,所以主程序lock里面代码,需要等待支线程解开c1的互斥锁,所以一直不执行。如果把c1.DoNotLockMe()放在lock(c1)前面, 就会被执行

但是正常情况下都不会lock(this) 而以下面的形式

  1. class C1
  2. {
  3. private bool deadlocked = true;
  4. private object locker = new object();
  5. //这个方法用到了lock,我们希望lock的代码在同一时刻只能由一个线程访问
  6. public void LockMe(object o)
  7. {
  8. lock (locker)
  9. {
  10. while(deadlocked)
  11. {
  12. deadlocked = (bool)o;
  13. Console.WriteLine("Foo: I am locked :(");
  14. Thread.Sleep(500);
  15. }
  16. }
  17. }
  18. //所有线程都可以同时访问的方法
  19. public void DoNotLockMe()
  20. {
  21. Console.WriteLine("I am not locked :)");
  22. }
  23. }