(精华)2020年12月23日 .NET Core 多线程底层详解(混合锁)

举报
愚公搬代码 发表于 2021/10/19 22:33:06 2021/10/19
【摘要】 混合锁的特征是在获取锁失败后像自旋锁一样重试一定的次数,超过一定次数之后(.NET Core 2.1 是30次)再安排当前进程进入等待状态 混合锁的好处是,如果第一次获取锁失败,但其他线程马上释放了锁,...

混合锁的特征是在获取锁失败后像自旋锁一样重试一定的次数,超过一定次数之后(.NET Core 2.1 是30次)再安排当前进程进入等待状态

混合锁的好处是,如果第一次获取锁失败,但其他线程马上释放了锁,当前线程在下一轮重试可以获取成功,不需要执行毫秒级的线程调度处理;而如果其他线程在短时间内没有释放锁,线程会在超过重试次数之后进入等待状态,以避免消耗 CPU 资源,因此混合锁适用于大部分场景

internal sealed class SimpleHybridLock : IDisposable
{
    //基元用户模式构造使用
    private int m_waiters = 0;

    //基元内核模式构造
    private AutoResetEvent m_waiterLock = new AutoResetEvent(false);

    public void Enter()
    {
        //指出该线程想要获得锁
        if (Equals(Interlocked.Increment(ref m_waiters), 1))
        {
            //无竞争,直接返回
            return;
        }

        //另一个线程拥有锁(发生竞争),使这个线程等待
        //线程会阻塞,但不会在CPU上“自旋”,从而节省CPU
        //这里产生较大的性能影响(用户模式与内核模式之间转换)
        //待WaitOne返回后,这个线程拿到锁
        m_waiterLock.WaitOne();
    }

    public void Leave()
    {
        //该线程准备释放锁
        if (Equals(Interlocked.Decrement(ref m_waiters), 0))
        {
            //无线程等待,直接返回
            return;
        }

        //有线程等待则唤醒其中一个
        //这里产生较大的性能影响(用户模式与内核模式之间转换)
        m_waiterLock.Set();
    }

    public void Dispose()
    {
        m_waiterLock.Dispose();
    }
}

  
 
  • 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
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
public static class MonitorSample
{
    private static readonly object Lock = new object();
    private static int _counterA = 0;
    private static int _counterB = 0;
    public static void IncrementCounterA()
    {
        var lockObj = Lock;
        var lockTaken = false;
        try
        {
            // 获取锁
            Monitor.Enter(lockObj, ref lockTaken);

            // 锁保护
            {
                _counterA++;
                _counterB++;
            }
            
        }
        finally
        {
            // 释放锁
            if(lockTaken) Monitor.Exit(lockObj);
        }
    }

    public static void IncrementCounterB()
    {
        lock (Lock)
        {
            _counterA++;
            _counterB++;
        }
    }
}

  
 
  • 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
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37

图示:
在这里插入图片描述
在这里插入图片描述

文章来源: codeboy.blog.csdn.net,作者:愚公搬代码,版权归原作者所有,如需转载,请联系作者。

原文链接:codeboy.blog.csdn.net/article/details/108394779

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。