使用隊列(Queue)解決簡單的並發問題

有一個場景：一個搶購的項目，假設有5件商品，誰先搶到誰可以買，但是如果此時此刻（這里的此時此刻假設是相同的時間），有100人去搶這個商品，如果使用平時的方法會出現什么情況呢？你懂的，這里所說是就是有關並發的問題。

平時我們去超市購物去結賬的時候就是排隊，這里我們先讓搶購人排好隊，按時間，誰先點擊的搶購按鈕誰就排在前面，這樣就形成了一個隊列，然后我們再對這個隊列處理，這樣就不會出現並發的問題了。（至少可以處理這樣簡單的並發，這里不討論太復雜的並發）

案例：

 

要求：有一個發布文章的接口，每發布一篇文章，調用一下接口。（這里不用批量發布，為了講解這個）

 

建立一個這樣的處理程序類，BusinessInfoHelper.cs

 

namespace MyNameSpace

{
    //隊列臨時類
    public class QueueInfo
    {
        public string medias { get; set; }
        public string proids { get; set; }
        public string host { get; set; }
        public string userid { get; set; }
        public string feedid { get; set; }
    }

    public class BusinessInfoHelper
    {
        #region 解決發布時含有優質媒體時，前台頁面卡住的現象
        //原理：利用生產者消費者模式進行入列出列操作

        public readonly static BusinessInfoHelper Instance = new BusinessInfoHelper();
        private BusinessInfoHelper()
        { }

        private Queue<QueueInfo> ListQueue = new Queue<QueueInfo>();

        public void AddQueue(string medias, string proids, string host, string userid, string feedid) //入列
        {
            QueueInfo queueinfo = new QueueInfo();

            queueinfo.medias = medias;
            queueinfo.proids = proids;
            queueinfo.host = host;
            queueinfo.userid = userid;
            queueinfo.feedid = feedid;
            ListQueue.Enqueue(queueinfo);
        }

        public void Start()//啟動
        {
            Thread thread = new Thread(threadStart);
            thread.IsBackground = true;
            thread.Start();
        }

        private void threadStart()
        {
            while (true)
            {
                if (ListQueue.Count > 0)
                {
                    try
                    {
                        ScanQueue();
                    }
                    catch (Exception ex)
                    {
                        LO_LogInfo.WLlog(ex.ToString());
                    }
                }
                else
                {
                    //沒有任務，休息3秒鍾
                    Thread.Sleep(3000);
                }
            }
        }

        //要執行的方法
        private void ScanQueue()
        {
            while (ListQueue.Count > 0)
            {
                try
                {
                    //從隊列中取出
                    QueueInfo queueinfo = ListQueue.Dequeue();

                    //取出的queueinfo就可以用了，里面有你要的東西
                    //以下就是處理程序了
                    //。。。。。。

                }
                catch (Exception ex)
                {
                    throw;
                }
            }
        }


        #endregion
    }
}

 

以上頁面寫好后，在程序開始運行時就得啟動這個線程去不停的處理任務，那么我們在Global的Application_Start里可以這樣寫：

//啟動發布優質媒體程序
MyNameSpace.BusinessInfoHelper.Instance.Start();

有一個問題出來了，如果我處理完隊列中的一條記錄后，想返回這條記錄的ID，這個程序好像不能完成，我就使用了另一個方法 Lock方法 ，把方法鎖定，具體的如下，

 

在頁面中定義全局的鎖：

private static object lockObject= new Object();

 

在方法 中這樣調用：

lock(lockObject)

{

//........

}

如果不使用第二種方法的全局鎖，不知各位大俠有沒有好的解決辦法，如果有，可以跟貼，非常感謝！