C#并发编程-4 同步

如果程序用到了并发技术，那就要特别留意这种情况：一段代码需要修改数据，同时其他代码需要访问同一个数据。
这种情况就需要考虑同步地访问数据。
如果下面三个条件都满足，就必须用同步来保护共享的数据。

• 多段代码正在并发运行；
  
• 这几段代码在访问（读或写）同一个数据；
  
• 至少有一段代码在修改（写）数据。
  

一 阻塞锁

如果有多个线程需要安全地读写共享数据，这种情况可以考虑使用lock语句。
一个线程进入锁后，在锁被释放之前其他线程是无法进入的：

1. class MyClass
2. {
3.     private readonly object _mutex = new object();
4.     private int _value;
5.     public void Increment()
6.     {
7.         lock (_mutex)
8.         {
9.             _value = _value + 1;
10.         }
11.     }
12. }

复制代码

.NET 框 架 中 还 有 很 多 其 他 类 型 的 锁， 如 Monitor、SpinLock、ReaderWriterLockSlim。
关于lock的使用，有四条重要的准则：

• 限制锁的作用范围：
  要尽量限制锁的作用范围。应该把 lock 语句使用的对象设为私有成员，并且永远不要暴露给非本类的方法。
  每个类型通常最多只有一个锁。如果一个类型有多个锁，可考虑通过重构把它分拆成多个独立的类型。
  lock可以锁定任何引用类型，但是建议为 lock 语句定义一个专用的成员，就像上例中那样。
  
• 文档中明确锁保护的内容；
  
• 锁范围内的代码尽量少：在锁定时执行的代码要尽可能得少。要特别小心阻塞调用。在锁定时不要做任何阻塞操作。
  
• 在控制锁的时候绝不运行随意的代码：
  在锁定时绝不要调用随意的代码。随意的代码包括引发事件、调用虚拟方法、调用委托。
  如果一定要运行随意的代码，就在释放锁之后运行。
  

 
二 异步锁

如果多个代码块需要安全地读写共享数据，并且这些代码块可能使用 await 语句，可以考虑使用SemaphoreSlim。

1. class MyClass1
2. {
3.     private readonly SemaphoreSlim _mutex = new SemaphoreSlim(1);
5.     private int _value;
7.     public async Task DelayAndIncrementAsync()
8.     {
9.         await _mutex.WaitAsync();
10.         try
11.         {
12.             var oldValue = _value;
13.             await Task.Delay(TimeSpan.FromSeconds(oldValue));
14.             _value = oldValue + 1;
15.         }
16.         finally
17.         {
18.             _mutex.Release();
19.         }
20.     }
21. }

复制代码

 
三 阻塞信号

如果需要从一个线程发送信号给另一个线程，可以考虑使用ManualResetEventSlim。
一个ManualResetEventSlim的对象处于这两种状态其中之一：标记的（signaled）或未标记的（unsignaled）。
每个线程都可以把事件设置为signaled 状态，也可以把它重置为 unsignaled 状态。线程也可等待事件变为 signaled 状态。
下面的两个方法被两个独立的线程调用，一个线程等待另一个线程的信号：

1. class MyClass2
2. {
3.     private readonly ManualResetEventSlim _mres = new ManualResetEventSlim();
4.     private int _value;
5.     public int WaitForInitialization()
6.     {
7.         _mres.Wait();
8.         return _value;
9.     }
10.     public void InitializeFromAnotherThread()
11.     {
12.         _value = 13;
13.         _mres.Set();
14.     }
15. }

复制代码

在 .NET 框架中，还有一些线程同步信号类型。ManualResetEvent、AutoResetEvent、CountdownEvent。
 
四 异步信号

需要在代码的各个部分间发送通知，并且要求接收方必须进行异步等待。
如果该通知只需要发送一次，那可用 TaskCompletionSource 异步发送。
发送代码调用TrySetResult，接收代码等待它的 Task 属性：

1. class MyClass3
2. {
3.     private readonly TaskCompletionSource<object> _tcs = new TaskCompletionSource<object>();
4.     private int _value1;
5.     private int _value2;
6.     public async Task<int> WaitForInitializationAsync()
7.     {
8.         await _tcs.Task;
9.         return _value1 + _value2;
10.     }
11.     public void Initialize()
12.     {
13.         _value1 = 13;
14.         _value2 = 17;
15.         _tcs.TrySetResult(null);
16.     }
17. }

复制代码

 
以上。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！