ibcadmin 发表于 2016-8-2 09:39:13

C#队列(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)

{

//........

}


如果不使用第二种方法的全局锁,不知各位大侠有没有好的解决办法,如果有,可以跟贴,非常感谢!




ibcadmin 发表于 2016-8-2 09:41:21

我在学习中

即墨还雀 发表于 2016-8-2 09:42:42

我在打酱油中重生

Amy尾巴 发表于 2016-8-2 13:15:06

666中。。。

edison0745 发表于 2016-8-17 23:52:39

very good
页: [1]
查看完整版本: C#队列(Queue)讲解及应用