using System;
using System.Collections.Concurrent;

namespace IStation
{
    /// <summary>
    /// 内存通道辅助类
    /// </summary>
    public class MemoryQueueHelper<T>
    {
        private static readonly BlockingCollection<T> _queue = new BlockingCollection<T>(new ConcurrentQueue<T>());

        /// <summary>
        /// 推送
        /// </summary>
        public static bool Push(T model)
        {
            _queue.Add(model);
            return true;
        }

        /// <summary>
        /// 获取
        /// </summary>
        public static T Take()
        {
            return _queue.Take();
        }


    }
}