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

【转】细说.NET中的多线程 (六 使用MemoryBarrier,Volatile进行同步)上一节介绍了使用信号量进行同步,本节主要介绍一些非阻塞同步的方法。本节主要介绍MemoryBarrier,volatile,Interlocked。MemoryBarriers本文简单的介绍一下这两个概念,假设下面的代码: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 usingSystem; .

大家好,又见面了,我是你们的朋友全栈君。

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

MemoryBarriers

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

using System;

class Foo

{

    int _answer;

    bool _complete;

 

    void A()

    {

        _answer = 123;

        _complete = true;

    }

 

    void B()

    {

        if (_complete) Console.WriteLine(_answer);

    }

}

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

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

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

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

using System;

using System.Threading;

class Foo

{

    int _answer;

    bool _complete;

 

    void A()

    {

        _answer = 123;

        Thread.MemoryBarrier();    // Barrier 1

        _complete = true;

        Thread.MemoryBarrier();    // Barrier 2

    }

 

    void B()

    {

        Thread.MemoryBarrier();    // Barrier 3

        if (_complete)

        {

            Thread.MemoryBarrier();       // Barrier 4

            Console.WriteLine(_answer);

        }

    }

}

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

在c#中,下面的操作都会生成MemoryBarrier:

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

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

1

2

3

4

int x = 0;

Task t = Task.Factory.StartNew(() => x++);

t.Wait();

Console.WriteLine(x);    // 1

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

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

1

2

3

4

5

6

7

8

9

10

bool complete = false;

var t = new Thread(() =>

{

    bool toggle = false;

    while (!complete) toggle = !toggle;

});

t.Start();

Thread.Sleep(1000);

complete = true;

t.Join();        // Blocks indefinitely

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

volatile关键字

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

VolatileRead和VolatileWrite

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

1

2

3

4

5

6

7

8

9

10

11

public static bool Read(ref bool location)

{

    bool flag = location;

    Thread.MemoryBarrier();

    return flag;

}

public static void Write(ref bool location, bool value)

{

    Thread.MemoryBarrier();

    location = value;

}

  

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

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

Interlocked

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

 

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

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/158111.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • Python 列表元素字符串转浮点

    Python 列表元素字符串转浮点在网络爬虫或者读取文件中的数据时,很多时候读取出来的数值是字符串形式的,这些字符串形式的数据并不能用来作计算或者更深入的操作,因此我们需要把他们转换为数值的形式。简单粗暴的for循环假设,这里有一个以字符串形式存储数值的列表,具体如下:a=[‘2′,’3.5′,’10’,’88’,’32.66′]我们需要将其转换为浮点的形式,最简单粗暴直接的方法,可以使用…

    2022年6月1日
    44
  • java基础API

    java基础APIJava常用类库1.API(1)ApplicationProgrammingInterface,应用程序接口。是一些预先定义的类和接口,或指软件系统不同组成部分衔接的约定。(2)API说明文档API文档查看方式:第一步选择包,第二步,选择类或接口,第三步查看类和接口的使用说明,右边的区域。右边的区域分为五块,分别为类的定义和功能介绍、属性的介绍、构造器的介绍、构造器的介绍、方法的列表、每个方法的使用详细说明。2、java.lang包(1)这是我们api中最基础的一个包(2)该包下面的

    2022年7月9日
    20
  • qtum量子链官网_币宽BitQuant量化交易系统

    qtum量子链官网_币宽BitQuant量化交易系统全球专业交易所Bithumb Global上线Qtum量子链,开启QTUM交易大赛

    2022年4月22日
    77
  • django配置环境变量_python django框架

    django配置环境变量_python django框架django的环境配置1. 虚拟环境安装pip install virtualenvpip install virtualenvwrapper 扩展包export WORKON_HOME=$HOME/.virtualenvssource /usr/local/bin/virtualenvwrapper.shvi /usr/local/bin/virtualenvwrapper.sh目录下的文件进行修改成python3的路径环境生效:source .bashrc2. 虚拟环境配置mkvirt

    2022年8月11日
    3
  • PM3激活成功教程加密IC卡

    PM3激活成功教程加密IC卡IC卡已经在我们的生活中无处不在了,门禁,电梯,吃饭,洗车,可以说与我们的生活息息相关了。(为了把加密的校园一卡通复制到我的小米手环上,我也是煞费苦心,看网上各种大佬教程)但是如果有一天,你的门禁卡丢了,怎么配呢?跟配钥匙一样的,必须现有原钥匙才可以。那我们今天就看看,如何用PM3来配门禁卡钥匙。准备好门禁母卡和复制的空白卡,复制的全过程是这样的。放原卡-》读卡-》激活成功教程密码-》读出数据-》放新卡-》写入数据-》完成复制!1、连接好PM3硬件设备,运行我们的杀手锏软件PM3的gui版本很多,我们

    2022年6月25日
    59
  • notifyDataSetChanged不生效「建议收藏」

    notifyDataSetChanged不生效「建议收藏」当ListView绑定数据适配器后,数据所对应的对象重新生成,就造成了listview所对应的数据对象不对,当数据改变时notifyDataSetChange则不能生效

    2022年6月29日
    19

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号