關(guān)于數(shù)據(jù)同步的一些思考與改進(jìn)

• 另起一個線程作為定時任務(wù),主要負(fù)責(zé)定時數(shù)據(jù)同步

• 正常情況下,每小時與Github進(jìn)行數(shù)據(jù)同步.

• 一旦網(wǎng)站數(shù)據(jù)被更新,檢查剩余同步時間是否大于30秒.
  ** 如果大于三十秒,強(qiáng)行把計時器剩余時間設(shè)置為30秒.
  ** 如果小于三十秒,不做操作.

• 計時器時間走完,立即同步數(shù)據(jù)到Github.

public class BlogsTimer
{
    private static Stack<int> _upFunnel; //沙漏上部分
    private static Stack<int> _downFunnel; //沙漏下部分
    private static readonly List<Action> TimerEvents; //定時執(zhí)行的事件
    private static bool _timerSwitch; //沙漏開關(guān)
    private static readonly int Speed; //每秒消費(fèi)令牌數(shù)量
    private static Thread _timerThread;
    private static readonly object TimerLock;
    static BlogsTimer()
    {
        _upFunnel = new Stack<int>();
        _downFunnel = new Stack<int>();
        Speed = 1 * 1000;
        TimerEvents = new List<Action>();
        TimerLock = new object();
    }
    //計時器開始
    public static void Start(TimeSpan timeSpan)
    {
        lock (TimerLock)
        {
            _upFunnel.Clear();
            _downFunnel.Clear();
            for (var i = 0; i < timeSpan.TotalSeconds; i++)
            {
                _upFunnel.Push(i);
            }
        }
        _timerSwitch = true;
        _timerThread = new Thread(Consume); //起一個線程消費(fèi)桶里的令牌
        _timerThread.Start();
        LunchEvents(); // 觸發(fā)事件
    }
    public static void Stop()
    {
        _timerSwitch = false;
    }

    //給沙漏注冊定時執(zhí)行事件
    public static void Register(Action timeEvent)
    {
        TimerEvents.Add(timeEvent);
        timeEvent.Invoke();
    }

    //把沙漏加速到指定的時間
    public static void AccelerateTo(TimeSpan timeSpan)
    {
        var accelerateSeconds = timeSpan.TotalSeconds;
        lock (TimerLock)
        {
            if (_upFunnel.Count < accelerateSeconds) //當(dāng)前沙漏中剩余令牌小于設(shè)置中秒數(shù),則返回不加速
                return;
            while (_upFunnel.Count > accelerateSeconds && _upFunnel.Count > 1) //令牌數(shù)大于秒數(shù),則釋放出多余令牌
            {
                _downFunnel.Push(_upFunnel.Pop());
            }
        }
    }
    private static void LunchEvents()
    {
        TimerEvents.ForEach(a => a.Invoke());
    }
    private static void Consume()
    {
        while (_timerSwitch)
        {
            lock (TimerLock)
            {
                if (_upFunnel.TryPop(out var item))
                {
                    _downFunnel.Push(item);
                }
                else
                {
                    LunchEvents();
                    var tempStack = _downFunnel; //旋轉(zhuǎn)沙漏
                    _downFunnel = _upFunnel;
                    _upFunnel = tempStack;
                }
            }
            Thread.Sleep(Speed);
        }
    }
}