.NetCore 線程安全的ConcurrentQueue 隊列

摘要:最近辦了一件蠢事,我在一個高並發的訂閱事件里對數據庫執行I/O操作 ,坑了自己一把,雖然定時清除了數據,但是跑了一段時間之后還是出問題了,后面就加入了隊列去存儲一段時間的數據,解決了這個問題,操作內存和磁盤不是一個級別的.特別是高並發的情況下,最好別對磁盤進行I/O操作,用不好只能坑了自己.

這里簡單粘一下隊列的使用方法,因為用的是多線程,就選擇了ConcurrentQueue,還有一些別的Queue方法,有興趣可以去搜一下.

ConcurrentQueue<T>隊列是一個高效的線程安全的隊列，是.Net Framework 4.0，System.Collections.Concurrent命名空間下的一個數據結構

 ConcurrentQueue是一個先進先出的隊列,常用的有以下幾個方法:

• Enqueue(T item)  將對象添加到隊列的結尾處
• TryDequeue(out T result)  嘗試移除並返回並發隊列開頭處的對象
• TryPeek(out T result)  嘗試返回開頭處的對象但不將其移除

以下是我封裝的常用類

    public class RingStringBuilder
    {
        private static ConcurrentQueue<RealTimeInfo> concurrentQueue = new ConcurrentQueue<RealTimeInfo>();
        private static int _maxCapacity;//隊列最大值

        public RingStringBuilder(int maxCapacity)
        {
            _maxCapacity = maxCapacity;
        }
        /// <summary>
        /// 根據隊列設置的最大值判斷
        /// 超過最大值，移除隊列第一條，隊列末尾添加一條
        /// 沒超過最大值，一直在隊列尾部添加
        /// </summary>
        /// <param name="info"></param>
        public static void Append(RealTimeInfo info)
        {
            concurrentQueue.Enqueue(info);
            if (concurrentQueue.Count > _maxCapacity)
            {
                concurrentQueue.TryDequeue(out info);
            }
        }
        /// <summary>
        /// 查詢列表
        /// </summary>
        /// <returns></returns>
        public static List<RealTimeInfo> Query()
        {
            return concurrentQueue.ToList();
        }

        /// <summary>
        /// 獲取最后一條數據
        /// </summary>
        /// <returns></returns>
        public static RealTimeInfo GetLastOrDefault()
        {
            return concurrentQueue.LastOrDefault();
        }

        /// <summary>
        /// 獲取第一條數據
        /// </summary>
        /// <param name="info"></param>
        /// <returns></returns>
        public static RealTimeInfo GetFirstOrDefault(out RealTimeInfo info)
        {
            concurrentQueue.TryPeek(out info);
            return info;
        }
    }