.Net基于Thread实现自旋锁的三种方式

基于Thread.SpinWait实现自旋锁

实现原理:基于Test--And--Set原子操作实现
使用一个数据表示当前锁是否已经被获取 0表示未被索取，1表示已经获取 获取锁时会将_lock的值设置为1 然后检查修改前的值是否等于0，

优点：

• 不使用Thread.SpinWait方法,重试的方法体会为空，CPU会使用它的最大性能来不断的进行赋值和比较指令，会浪费很大的性能,Thread.SpinWait提示CPU当前正在自旋锁的循环中，可以休息若干个时间周期
• 使用自旋锁需要注意的问题，自旋锁保护的代码应该在非常短的时间内执行完成，如果时间过长，其他线程不断重试导致影响其他线程进行

缺点：

当前实现没有考虑到公平性，如果多个线程同时获取锁失败，按时间顺序第一个获取锁的线程不一定会在释放锁后第一个获取成功，

代码实现：

public static class ThreadSpinWaitDemo
    {
        private static int _lock = 0;
        private static int _counterA = 0;
        private static int _counterB = 0;

        public static void IncrementCounters()
        {
            while (Interlocked.Exchange(ref _lock, 1) != 0)
            {
                Thread.SpinWait(1);
            }

            ++_counterA;
            ++_counterB;
            Interlocked.Exchange(ref _lock, 0);
        }

        public static void GetCounters(out int counterA, out int counterB)
        {
            while (Interlocked.Exchange(ref _lock, 1) != 0)
            {
                Thread.SpinWait(1);
            }
            counterA = _counterA;
            counterB = _counterB;
            Interlocked.Exchange(ref _lock, 0);

        }
    }

基于SpinWaite实现自旋锁

特性是SpinOnce方法的次数，如果在一定次数以内并且当前逻辑核心所大于1，则调用Thread.SpinWait函数；如果超过一定次数或者当前环境逻辑核心数等于1，则交替使用
Thread.Sleep(0)和Thread.Yield函数，表示切换到其他线程，如果再超过一定次数，则让当前线程休眠
SpinWaite解决Thread.SpinWait中的两个问题

• 如果自旋锁运行时间超长，SpinWaite可以提示操作系统切换到其他线程或者让当前线程进入休眠状态，
• 如果当前环境只有一个核心逻辑，SpinWaite不会执行Thread.SpinWait函数，而是直接提示操作系统切换到其他线程，

public static class ThreadSpinOnceDemo
    {
        private static int _lock = 0;
        private static int _counterA = 0;
        private static int _counterB = 0;

        public static void IncrementCounters()
        {
            var spinWait = new SpinWait();
            while (Interlocked.Exchange(ref _lock, 1) != 0)
            {
                spinWait.SpinOnce();
            }

            ++_counterA;
            ++_counterB;
            Interlocked.Exchange(ref _lock, 0);
        }

        public static void GetCounters(out int counterA, out int counterB)
        {
            var spinWait = new SpinWait();
            while (Interlocked.Exchange(ref _lock, 1) != 0)
            {
                spinWait.SpinOnce();
            }
            counterA = _counterA;
            counterB = _counterB;
            Interlocked.Exchange(ref _lock, 0);

        }
    }

基于SpinLock实现自旋锁

封装了SpinWaite的逻辑

SpinLock代码实现

public class ThreadSpinLockDemo
    {
        private static SpinLock _spinLock = new SpinLock();
        private static int _counterA = 0;
        private static int _counterB = 0;

        public static void IncrementCounters()
        {
            bool lockTaken = false;
            try
            {
                _spinLock.Enter(ref lockTaken);
                ++_counterA;
                ++_counterB;
            }
            finally
            {
                if (lockTaken)
                {
                    _spinLock.Exit();
                }
            }
        }

        public static void GetCounters(out int counterA, out int counterB)
        {
            bool lockTaken = false;
            try
            {
                _spinLock.Enter(ref lockTaken);
                counterA = _counterA;
                counterB = _counterB;
            }
            finally
            {
                if (lockTaken)
                {
                    _spinLock.Exit();
                }
            }
        }
    }

简述 Thread.Sleep(0)和Thread.Yield的区别

• 在Windows系统中 Thread.Sleep调用系统提供的SleepEx函数，Thread.Yield函数调用的是系统提供的SwitchToThread方法，
• 区别在于SwitchToThread函数只会切换到当前核心逻辑关联的待运行队列的线程，不会切换到其他核心逻辑关联的线程上，而SleepEx函数会切换到任意逻辑核心关联的待运行队列中的线程，并且让当前线程在指定时间内无法重新进入待运行队列(如果线程为0 那么线程可以立刻重新进入待运行队列)
• 在Linux和OSX中 Thread.Sleep函数在休眠时间不为0时会调用pthread类库提供的pthread_cond_timedWait函数，在休眠时间为0时会调用sched_yield函数，Thread.Yield同样会调用sched_yield函数 sched_yield在windows和osx系统中没有区别，都只会切换到当前和逻辑核心关心的待运行队列中的线程，不会切换到其他核心逻辑关联的线程上。在unix系统上调用系统提供的sleep函数并传入0 会直接忽略返回

以上就是.Net基于Thread实现自旋锁的三种方式的详细内容，更多关于.Net自旋锁的资料请关注我们其它相关文章！