【转】细说.NET中的多线程 (六使用MemoryBarrier，Volatile进行同步)

矫情吗；* 2023-01-06 01:07 77阅读 0赞

上一节介绍了使用信号量进行同步，本节主要介绍一些非阻塞同步的方法。本节主要介绍MemoryBarrier，volatile,Interlocked。

## MemoryBarriers ##

本文简单的介绍一下这两个概念，假设下面的代码：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 </td> 
 <td> <code>using</code>&nbsp;<code>System;</code> <code>class</code>&nbsp;<code>Foo</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>int</code>&nbsp;<code>_answer;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;<code>_complete;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>void</code>&nbsp;<code>A()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>_answer = 123;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>_complete =&nbsp;</code><code>true</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>void</code>&nbsp;<code>B()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>(_complete) Console.WriteLine(_answer);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

如果方法A和方法B同时在两个不同线程中运行，控制台可能输出0吗？答案是可能的，有以下两个原因：

*  编译器，CLR或者CPU可能会更改指令的顺序来提高性能
 *  编译器，CLR或者CPU可能会通过缓存来优化变量，这种情况下对其他线程是不可见的。

最简单的方式就是通过MemoryBarrier来保护变量，来防止任何形式的更改指令顺序或者缓存。调用Thread.MemoryBarrier会生成一个内存栅栏，我们可以通过以下的方式解决上面的问题：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 </td> 
 <td> <code>using</code>&nbsp;<code>System;</code> <code>using</code>&nbsp;<code>System.Threading;</code> <code>class</code>&nbsp;<code>Foo</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>int</code>&nbsp;<code>_answer;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;<code>_complete;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>void</code>&nbsp;<code>A()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>_answer = 123;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Barrier 1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>_complete =&nbsp;</code><code>true</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Barrier 2</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>void</code>&nbsp;<code>B()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Barrier 3</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>(_complete)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Barrier 4</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(_answer);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

上面的例子中，barrier1和barrier3用来保证指令顺序不会改变，barrier2和barrier4用来保证值变化不被缓存。**一个好的处理方案就是我们在需要保护的变量前后分别加上MemoryBarrier**。

在c\#中，下面的操作都会生成MemoryBarrier：

*  Lock语句(Monitor.Enter,Monitor.Exit)
 *  所有Interlocked类的方法
 *  线程池的回调方法
 *  Set或者Wait信号
 *  所有依赖于信号灯实现的方法，如starting或waiting 一个Task

因为上面这些行为，这段代码实际上是线程安全的：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 </td> 
 <td> <code>int</code>&nbsp;<code>x = 0;</code> <code>Task t = Task.Factory.StartNew(() =&gt; x++);</code> <code>t.Wait();</code> <code>Console.WriteLine(x);&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 1</code> </td> 
 </tr> 
 </tbody> 
</table>

在你自己的程序中，你可能重现不出来上面例子所说的情况。事实上，从msdn上对MomoryBarrier的解释来看，只有对顺序保护比较弱的多核系统才需要用到MomoryBarrier。但是有一点需要注意：多线程去修改变量并且不使用任何形式的锁或者内存栅栏是会带来一定的麻烦的。

下面一个例子能够很好的说明上面的观点(在你的VisualStudio中，选择Release模式，并且Start Without Debugging重现这个问题)：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 </td> 
 <td> <code>bool</code>&nbsp;<code>complete =&nbsp;</code><code>false</code><code>;</code> <code>var</code>&nbsp;<code>t =&nbsp;</code><code>new</code>&nbsp;<code>Thread(() =&gt;</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;<code>toggle =&nbsp;</code><code>false</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>while</code>&nbsp;<code>(!complete) toggle = !toggle;</code> <code>});</code> <code>t.Start();</code> <code>Thread.Sleep(1000);</code> <code>complete =&nbsp;</code><code>true</code><code>;</code> <code>t.Join();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// Blocks indefinitely</code> </td> 
 </tr> 
 </tbody> 
</table>

这个程序永远不会结束，因为complete变量被缓存在了CPU寄存器中。在while循环中加入Thread.MemoryBarrier可以解决这个问题。

## volatile关键字 ##

另外一种更高级的方式来解决上面的问题，那就是考虑使用volatile关键字。Volatile关键字告诉编译器在每一次读操作时生成一个fence，来实现保护保护变量的目的。具体说明可以参见msdn的[介绍][Link 1]

## VolatileRead和VolatileWrite ##

Volatile关键字只能加到类变量中。本地变量不能被声明成volatile。这种情况你可以考虑使用System.Threading.Volatile.Read方法。我们看一下System.Threading.Volatile源码如何实现这两个方法的：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>public</code>&nbsp;<code>static</code>&nbsp;<code>bool</code>&nbsp;<code>Read(</code><code>ref</code>&nbsp;<code>bool</code>&nbsp;<code>location)</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>bool</code>&nbsp;<code>flag = location;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>flag;</code> <code>}</code> <code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>Write(</code><code>ref</code>&nbsp;<code>bool</code>&nbsp;<code>location,&nbsp;</code><code>bool</code>&nbsp;<code>value)</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.MemoryBarrier();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>location = value;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

一目了然，通过MemoryBarrier来实现的，但是他只在读操作的后面和写操作的前面加了MemoryBarrier，那么你应该考虑，如果你先使用Volatile.Write再使用Volatile.Read是不是可能有问题呢？

c\#中ConcurrentDictionary中使用了Volatile类来保护变量，有兴趣的读者可以看看c\#的开发者是如何使用这个方法来保护变量的。

## Interlocked ##

使用MemoryBarrier并不总是一个好的解决方案，尤其在不需要锁的情况下。Interlocked方法提供了一些常用的原子操作来避免前面文章提到的一系列的问题。如使用Interlocked.Increment来替代++，Interlocked.Decrement来替代--。Msdn的[文档][Link 2]中详细的介绍了相关的用法和原理。C\#中的源码里也经常能看见Interlocked相关的使用。

本文介绍了一些除了锁和信号量之外的一些同步方式，欢迎批评与指正。

[Link 1]: https://msdn.microsoft.com/en-us/library/vstudio/x13ttww7%28v=vs.100%29.aspx
[Link 2]: https://msdn.microsoft.com/en-us/library/vstudio/system.threading.interlocked%28v=vs.110%29.aspx