using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading;using System.Threading.Tasks;namespace SuiBao.Utility
{    ///阻塞隊(duì)列（BlockingQueue）是一個(gè)支持兩個(gè)附加操作的隊(duì)列。這兩個(gè)附加的操作是：在隊(duì)列為空時(shí)，獲取元素的線程會(huì)等待隊(duì)列變?yōu)榉强铡．?dāng)隊(duì)列滿時(shí)，存儲(chǔ)元素的線程會(huì)等待隊(duì)列可用。阻塞隊(duì)列常用于生產(chǎn)者和消費(fèi)者的場景，生產(chǎn)者是往隊(duì)列里添加元素的線程，消費(fèi)者是從隊(duì)列里拿元素的線程。阻塞隊(duì)列就是生產(chǎn)者存放元素的容器，而消費(fèi)者也只從容器里拿元素。
    
    //阻塞隊(duì)列 需要實(shí)現(xiàn)兩個(gè)功能: 使線程等待與喚醒線程. 具體介紹如下:    // 在極端條件下, 需要掛起線程, 等待隊(duì)列滿足條件后，再去執(zhí)行添加或提取 操作    // 待隊(duì)列滿足了條件之后, 通知線程去繼續(xù)其掛起之前的操作....    //涉及到的技術(shù):    //線程同步(此實(shí)例用到了lock) 與 線程間通信(此示例用到了event)    //
    
    // 可能產(chǎn)生死鎖的分析:    // 在某個(gè)時(shí)刻，隊(duì)列為空或者是已滿, 此時(shí)生產(chǎn)者未能存入數(shù)據(jù)或者還在存入數(shù)據(jù)到隊(duì)列中, 這就會(huì)產(chǎn)生使得隊(duì)列出錯(cuò)    // 如果此時(shí), 消費(fèi)者對(duì)隊(duì)列在進(jìn)行操作就會(huì)產(chǎn)生死鎖...由于之前的生產(chǎn)者的操作使得隊(duì)列出了問題并沒有釋放鎖, 此時(shí)就會(huì)造成死鎖    // 這是從預(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);
        }        // 入隊(duì)加鎖
        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();
            }
        }        // 出隊(duì)加鎖
        public T DeQueue(int waitTime)
        {            bool _queueEmpty = false;
            T item = default(T);            while (true)
            {                lock (this._inner_queue)
                {                    // 判斷隊(duì)列中是否有元素....
                    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();
        }
    }
}