WaitUtil.cs 2.0 KB
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace URSoldering.Common
{
    public class WaitUtil
    {
        public delegate bool IsOk();

        /// <summary>
        /// 同步等待,如果等到结果返回true, 超时或出现异常返回false
        /// </summary>
        /// <param name="timeout">超时时间(毫秒)</param>
        /// <param name="isOk">等待</param>
        /// <returns></returns>
        public static bool Wait(int timeout, IsOk isOk)
        {
            try{
                Wait("", timeout, isOk);
                return true;
            }
            catch(TimeoutException te)
            {
                return false;
            }catch(Exception e)
            {
                LogUtil.error("同步等待出现异常:"+ e.Message);
                return false;
            }
        }

        /// <summary>
        /// 同步等待,如果等到结果正常返回, 超时抛出TimeoutException
        /// </summary>
        /// <param name="waitName">等待的名称,超时的时候TimeoutException的消息为:xxx超时</param>
        /// <param name="timeout"></param>
        /// <param name="isOk"></param>
        public static void Wait(string waitName, int timeout, IsOk isOk)
        {
            int waitTime = 0;
            int sleepTime = 10;
            while (true)
            {
                try
                {
                    bool result = isOk();
                    if (result)
                    {
                        return;
                    }
                }
                catch (Exception ex)
                {
                    LogUtil.error("同步等待出现异常:" + ex.Message);
                }
                if (waitTime > timeout)
                {
                    throw new TimeoutException(waitName + "超时");
                }
                Thread.Sleep(sleepTime);
                waitTime = waitTime + sleepTime;
            }
        }
    }
}