【转】细说.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)
全栈程序员-站长的头像全栈程序员-站长

相关推荐

  • 三门问题的计算机模拟,三门问题是指_数学三门问题

    三门问题的计算机模拟,三门问题是指_数学三门问题三门问题(MontyHallproblem)亦称为蒙提霍尔问题、蒙特霍问题或蒙提霍尔悖论,大致出自美国的电视游戏节目Let’sMakeaDeal。问题名字来自该节目的主持人蒙提·霍尔(MontyHall)。参赛者会看见三扇关闭了的门,其中一扇的后面有一辆汽车,选中后面有车的那扇门可赢得该汽车,另外两扇门后面则各藏有一只山羊。当参赛者选定了一扇门,但未去开启它的时候,节目主持人开启剩下两…

    2022年10月22日
  • cocos2dx三种定时器使用

    cocos2dx三种定时器使用

    2022年1月14日
  • 【PotPlayer】敲好用的本地视频播放器

    【PotPlayer】敲好用的本地视频播放器软件简介PotPlayer是KMPlayer的原作者姜勇囍进入Daum公司后的新一代作品,目前仍有更新。由于采用Delphi编译程序的KMPlayer有一些弊端,姜勇囍为改进播放器本身的一些性能而重新用VC++进行构架。虽然PotPlayer与KMPlayer同属一个开发者的产品,但它与KMPlayer所注重的地方并不同,能够满足不同用户的使用需求。因该软件的官方网站托管于DAUM平台,中国大陆网络可能受防火长城(GFW)影响而无法正常访问。官方网站https://potplayer.daum.

    2022年7月14日
  • idea 全局查找快捷键

    idea 全局查找快捷键对的

    2022年6月29日
  • bzoj2750最短路计数

    bzoj2750最短路计数

    2021年5月26日
  • 手把手教你接入支付宝支付

    手把手教你接入支付宝支付前一久做了支付宝支付,分享一下接入的详细步骤吧,移动端和服务端demo源码已上传至GitHub,要下载的移步至文章末尾。先给出支付宝官方文档:https://docs.open.alipay.com/204/105051/适用场景在App内集成支付宝支付。APP调用支付宝提供的SDK,SDK再调用支付宝APP内的支付模块。如果用户已安装支付宝APP,商家APP会跳转到支付宝中完成支付,支付完…

    2022年5月25日

发表回复

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

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