c# LazyQueue<T>完成【C#.Net教程】,c#，LazyQueue

有时刻，当使命比较多的时刻，须要做一个行列。当行列数目抵达肯定数目时刻，举行出队并处置惩罚，然则假如很长时候都没有抵达谁人数目呢？那就加一个时候限定，比方30分钟，1000个元素，哪个前提先抵达都邑实行出队操纵。

LazyQueue<T>类的完成：

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


namespace ServerToolServer.Util
{


    /// <summary>
    /// 到指定的秒数或抵达某个数目实行出队
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public class LazyQueue<T>
    {


        /// <summary>
        /// 当前的行列
        /// </summary>
        private Queue<T> _current;


        /// <summary>
        /// 回调，当时候抵达maxSec或_curentQueue抵达maxNum数目时，实行
        /// </summary>
        private Action<T[]> _dequeueAction;


        /// <summary>
        /// 行列的最大数目
        /// </summary>
        private int _maxNum;


        /// <summary>
        /// 监听行列的线程
        /// </summary>
        private Thread _executeThread;


        /// <summary>
        /// 当前秒数
        /// </summary>
        private int _currentSec = 0;


        /// <summary>
        /// 最大秒数，就实行这个要领
        /// </summary>
        private int _maxSec;


        /// <summary>
        /// 组织器
        /// </summary>
        /// <param name="sec">最迟的实行秒数</param>
        /// <param name="num">行列的最大数目</param>
        /// <param name="dequeueAction">出队函数</param>
        public LazyQueue(int sec, int num, Action<T[]> dequeueAction)
        {
            this._maxSec = sec;
            this._maxNum = num;
            this._dequeueAction = dequeueAction;
            this._current = new Queue<T>();
            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();


        }


        /// <summary>
        /// 入队
        /// </summary>
        /// <param name="value"></param>
        public void Enqueue(T value)
        {
            this._current.Enqueue(value);
        }


        /// <summary>
        /// 出队
        /// </summary>
        /// <returns></returns>
        public T Dequeue()
        {
            return this._current.Dequeue();
        }


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


    }
}

以上就是c# LazyQueue<T>完成的内容，更多相关内容请关注ki4网（www.ki4.cn）！