spinwaitlock.cs

破解的飞信源代码

namespace NCindy.Util
{
    using System;
    using System.Runtime.InteropServices;
    using System.Threading;

    [StructLayout(LayoutKind.Sequential)]
    public struct SpinWaitLock
    {
        private const int LockIsFree = 0;
        private const int LockIsOwned = 1;
        private static readonly bool IsSingleCpuMachine;
        private int lockState;
        public void Enter()
        {
            Thread.BeginCriticalRegion();
            while (Interlocked.Exchange(ref this.lockState, 1) != 0)
            {
                while (Thread.VolatileRead(ref this.lockState) == 1)
                {
                    StallThread();
                }
            }
        }

        public void Exit()
        {
            Interlocked.Exchange(ref this.lockState, 0);
            Thread.EndCriticalRegion();
        }

        private static void StallThread()
        {
            if (IsSingleCpuMachine)
            {
                SwitchToThread();
            }
            else
            {
                Thread.SpinWait(1);
            }
        }

        [DllImport("kernel32", ExactSpelling=true)]
        private static extern void SwitchToThread();
        static SpinWaitLock()
        {
            IsSingleCpuMachine = Environment.get_ProcessorCount() == 1;
        }
    }
}