Masuit.Tools/Masuit.Tools.Abstractions/Systems/ConcurrentLimitedQueue.cs

using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;

namespace Masuit.Tools.Systems;

/// <summary>
/// 定长队列
/// </summary>
/// <typeparam name="T"></typeparam>
public class ConcurrentLimitedQueue<T> : ConcurrentQueue<T>
{
    /// <summary>
    /// 长度
    /// </summary>
    public int Limit { get; set; }

    /// <summary>
    /// 定长队列
    /// </summary>
    /// <param name="limit"></param>
    public ConcurrentLimitedQueue(int limit)
    {
        Limit = limit;
    }

    /// <summary>
    /// 定长队列
    /// </summary>
    /// <param name="list"></param>
    public ConcurrentLimitedQueue(IEnumerable<T> list) : base(list)
    {
        Limit = list.Count();
    }

    /// <summary>
    ///
    /// </summary>
    /// <param name="list"></param>
    /// <returns></returns>
    public static implicit operator ConcurrentLimitedQueue<T>(List<T> list)
    {
        return new ConcurrentLimitedQueue<T>(list);
    }

    /// <summary>
    /// 入队
    /// </summary>
    /// <param name="item"></param>
    public new void Enqueue(T item)
    {
        while (Count >= Limit)
        {
            TryDequeue(out _);
        }

        base.Enqueue(item);
    }
}