using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace SuiBao.Utility
{    ///阻塞隊列（BlockingQueue）是一個支持兩個附加操作的隊列。這兩個附加的操作是：在隊列為空時，獲取元素的線程會等待隊列變?yōu)榉强?。?dāng)隊列滿時，存儲元素的線程會等待隊列可用。阻塞隊列常用于生產(chǎn)者和消費(fèi)者的場景，生產(chǎn)者是往隊列里添加元素的線程，消費(fèi)者是從隊列里拿元素的線程。阻塞隊列就是生產(chǎn)者存放元素的容器，而消費(fèi)者也只從容器里拿元素。
    
    //阻塞隊列 需要實(shí)現(xiàn)兩個功能: 使線程等待與喚醒線程. 具體介紹如下:    // 在極端條件下, 需要掛起線程, 等待隊列滿足條件后，再去執(zhí)行添加或提取 操作    // 待隊列滿足了條件之后, 通知線程去繼續(xù)其掛起之前的操作....    //涉及到的技術(shù):    //線程同步(此實(shí)例用到了lock) 與 線程間通信(此示例用到了event)    //
    
    // 可能產(chǎn)生死鎖的分析:    // 在某個時刻，隊列為空或者是已滿, 此時生產(chǎn)者未能存入數(shù)據(jù)或者還在存入數(shù)據(jù)到隊列中, 這就會產(chǎn)生使得隊列出錯    // 如果此時, 消費(fèi)者對隊列在進(jìn)行操作就會產(chǎn)生死鎖...由于之前的生產(chǎn)者的操作使得隊列出了問題并沒有釋放鎖, 此時就會造成死鎖    // 這是從預(yù)防死鎖的角度來解決死鎖問題
    
    public class BlockQueue<T>
    {        private Queue<T> _inner_queue = null;        private ManualResetEvent _dequeue_wait = null;        public int Count
        {            get { return _inner_queue.Count; }
        }        public BlockQueue(int capacity = -1)
        {            this._inner_queue = capacity == -1 ? new Queue<T>() : new Queue<T>(capacity);            this._dequeue_wait = new ManualResetEvent(false);
        }        // 入隊加鎖
        public void EnQueue(T item)
        {            if (this._IsShutdown == true) throw new InvalidOperationException("服務(wù)未開啟.[EnQueue]");            lock (this._inner_queue)
            {                this._inner_queue.Enqueue(item);                this._dequeue_wait.Set();
            }
        }        // 出隊加鎖
        public T DeQueue(int waitTime)
        {            bool _queueEmpty = false;
            T item = default(T);            while (true)
            {                lock (this._inner_queue)
                {                    // 判斷隊列中是否有元素....
                    if (this._inner_queue.Count > 0)
                    {
                        item = this._inner_queue.Dequeue();                        this._dequeue_wait.Reset();                        //break;                    }                    else
                    {                        if (this._IsShutdown == true)
                        {                            throw new InvalidOperationException("服務(wù)未開啟[DeQueue].");
                        }                        else
                        {
                            _queueEmpty = true;
                        }
                    }
                }                if (item != null)
                {                    return item;
                }                if (_queueEmpty)
                {                    this._dequeue_wait.WaitOne(waitTime);
                }
            }

        }        private bool _IsShutdown = false;        public void Shutdown()
        {            this._IsShutdown = true;            this._dequeue_wait.Set();
        }        public void Clear()
        {            this._inner_queue.Clear();
        }
    }
}