c# LazyQueue实现

有时候，当任务比较多的时候，需要做一个队列。当队列数量达到一定数量时候，进行出队并处理，但是如果很长时间都没有达到那个数量呢？那就加一个时间限制，例如30分钟，1000个元素，哪一个条件先达到都会执行出队操作。

LazyQueue类的实现：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;


namespace ServerToolServer.Util
{


    /// 

    /// 到指定的秒数或到达某个数量执行出队
    /// 
    /// 
    public class LazyQueue
    {


        /// 

        /// 当前的队列
        /// 
        private Queue _current;


        /// 

        /// 回调，当时间达到maxSec或_curentQueue达到maxNum数量时，执行
        /// 
        private Action _dequeueAction;


        /// 

        /// 队列的最大数量
        /// 
        private int _maxNum;


        /// 

        /// 监听队列的线程
        /// 
        private Thread _executeThread;


        /// 

        /// 当前秒数
        /// 
        private int _currentSec = 0;


        /// 

        /// 最大秒数，就执行这个方法
        /// 
        private int _maxSec;


        /// 

        /// 构造器
        /// 
        /// 最迟的执行秒数
        /// 队列的最大数量
        /// 出队函数
        public LazyQueue(int sec, int num, Action dequeueAction)
        {
            this._maxSec = sec;
            this._maxNum = num;
            this._dequeueAction = dequeueAction;
            this._current = new Queue();
            this._currentSec = 0;


            _executeThread = new Thread(new ThreadStart(() =>
            {
                while (true)
                {
                    this._currentSec++;
                    if (this._current.Count >= _maxNum || this._currentSec >= _maxSec)
                    {
                        this._dequeueAction.Invoke(this._current.ToArray());
                        
                        ////别忘了清空队列和秒数
                        this._current.Clear();
                        this._currentSec = 0;
                    }
                    ////每秒检测一下队列的数量和秒数
                    Thread.Sleep(1000);
                }
            }));
            this._executeThread.Start();


        }


        /// 

        /// 入队
        /// 
        /// 
        public void Enqueue(T value)
        {
            this._current.Enqueue(value);
        }


        /// 

        /// 出队
        /// 
        /// 
        public T Dequeue()
        {
            return this._current.Dequeue();
        }


        /// 

        /// 清缓存
        /// 
        public void Flush()
        {
            this._maxSec = 0;
            this._maxNum = 0;
            this._currentSec = 0;
            this._dequeueAction = null;
            this._current.Clear();
            this._executeThread.Abort();
        }


    }
}

 以上就是c#  LazyQueue实现的内容，更多相关内容请关注PHP中文网（www.php.cn）！

VisualizeAI

用AI把你的想法变成现实

下载