SKMC.API-v3/SKMC.API/Common/Types/MessageQueue.cs

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

namespace SKMC.Api.Common.Types
{
    public class MessageQueue<T>
    {

        private static MessageQueue<T> instance;

        private readonly BlockingQueue<T> queue = new BlockingQueue<T>();

        private MessageQueue() { }

        public static MessageQueue<T> Instance()
        {
            if (instance == null) instance = new MessageQueue<T>();
            return instance;
        }

        public int Count { get => queue.Count; }

        public void Put(T t)
        {
            queue.Add(t);
        }

        public T Get()
        {
            return queue.Take();
        }

        public void Clear()
        {
            while (queue.Count > 0)
            {
                Get();
            }
        }
    }
}