为什么要放弃使用Thread.Sleep

2019-11-14 16:07:33

字体：大中小

来源：转载

供稿：网友

前言

此文并不是说要完全放弃使用Thread.Sleep，而是要说明在符合哪些情况下使用！

场景

很多时候，我们会需要一个定时服务来处理业务。

但并不是死死的每隔N分钟执行一次那种，而是在一次处理完后，算好下一次处理的时间点。

当到达此时间点，触发程序重新开始执行代码。

普遍做法

普遍的情况下，都是使用while(true){Thread.Sleep()}来实现，废话不多话，看代码版本1：

class PRogram    {        static void Main(string[] args)        {            var workLists = new List<string>() { "任务1", "任务2", "任务3", "任务4" };            foreach (var task in workLists)            {                var thread = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(Work.DoWork));                thread.Start(task);            }                  }    }

class Work    {        public static void DoWork(object target)        {            var taskType = target as string;            var interval = 1 * 60 * 1000;//处理失败，1分钟后重试            var maxTimes = 5;            var retryTimes = 0;            while (true)            {                while (retryTimes < maxTimes)                {                    var ok = Proccess(taskType);                    if (ok)                    {                        retryTimes = maxTimes;                    }                    else                    {                        retryTimes++;                        System.Threading.Thread.Sleep(interval);                    }                }                var tim = GetTotalMillisecondsForNext();//计算离下一次开始处理的时间                                System.Threading.Thread.Sleep(tim);//挂起一段时间后，重新唤醒                retryTimes = 0;            }        }        private static bool Proccess(string taskType)        {            Console.WriteLine("开始执行处理：{0}", taskType);            return true;        }        private static int GetTotalMillisecondsForNext()        {            //这里根据自己的业务来决定            return 2 * 1000;        }    }

代码简单易懂。

分析

版本1中，循环强制创建线程，并使用System.Threading.Thread.Sleep(tim)来挂起线程，然后重新唤醒。

这种方式不好之处在于：占用系统线程资源，是一种浪费。如同占着茅坑不拉屎！线程是一种十分宝贵的资源，创建，销毁，切换都是相当耗性能的。

当Sleep的时候，就等于说：现在我不用，但是你也别想用。你要用？自己去Create一个。

有的人说，Sleep的时候不占用CPU啊！对，是不占用CPU ，但是占着线程资源,阻碍系统的线程调度!

可以参考下这文章

Threads are a limited resource, they take approximately 200,000 cycles to create and about 100,000 cycles to destroy. By default they reserve 1 megabyte of virtual memory for its stack and use 2,000-8,000 cycles for each context switch. This makes any waiting thread a huge waste.

改进

　　使用System.Timers.Timer来改进我们的程序。当执行处理业务的代码时，首先把timer停止，处理完毕后，算好一次执行的时间点，赋给timer并启动，看代码版本2

class Program    {        static void Main(string[] args)        {            var workLists = new List<string>() { "任务1", "任务2", "任务3", "任务4" };            Parallel.ForEach(workLists,                new ParallelOptions() { MaxDegreeOfParallelism = 3 },                (task) => { new Work2() { TaskType = task }.DoWork(); });            Console.ReadLine();        }    }

 class Work2    {        private Timer _workTimer;        public string TaskType { get; set; }        public void DoWork()        {            _workTimer = new System.Timers.Timer();            _workTimer.Interval = 1000;            _workTimer.Elapsed += new ElapsedEventHandler(TimerHanlder);            _workTimer.Start();        }        private void TimerHanlder(object sender, ElapsedEventArgs e)        {            _workTimer.Stop();            var interval = 1 * 60 * 1000;//处理失败，1分钟后重试            var maxTimes = 5;            var retryTimes = 0;            while (retryTimes < maxTimes)            {                var ok = Proccess();                if (ok)                {                    retryTimes = maxTimes;                }                else                {                    retryTimes++;                    System.Threading.Thread.Sleep(interval);                }            }            var times = GetTotalSecondsForNext();            Console.WriteLine("{0}秒后重新执行", times);            _workTimer.Interval = times * 1000;//计算离下一次开始处理的时间            _workTimer.Start();        }        private bool Proccess()        {            Console.WriteLine("开始执行处理：{0}", TaskType);            return true;        }        private int GetTotalSecondsForNext()        {            //这里根据自己的业务来决定            return 3;        }    }