(C#)使用队列(Queue)解决简单的并发问题

(C#)使用队列(Queue)解决简单的并发问题 

2015-07-16 13:04 13265人阅读 评论(8) 收藏 举报
 分类：

版权声明：本文为博主原创文章，未经博主允许不得转载。

有一个场景：一个抢购的项目，假设有5件商品，谁先抢到谁可以买，但是如果此时此刻（这里的此时此刻假设是相同的时间），有100人去抢这个商品，如果使用平时的方法会出现什么情况呢？你懂的，这里所说是就是有关并发的问题。

平时我们去超市购物去结账的时候就是排队，这里我们先让抢购人排好队，按时间，谁先点击的抢购按钮谁就排在前面，这样就形成了一个队列，然后我们再对这个队列处理，这样就不会出现并发的问题了。（至少可以处理这样简单的并发，这里不讨论太复杂的并发）

案例：

要求：有一个发布文章的接口，每发布一篇文章，调用一下接口。（这里不用批量发布，为了讲解这个）

建立一个这样的处理程序类，BusinessInfoHelper.cs

[csharp] view plain copy
 
  1. namespace MyNameSpace   
  2.   
  3. {  
  4.     //队列临时类  
  5.     public class QueueInfo  
  6.     {  
  7.         public string medias { get; set; }  
  8.         public string proids { get; set; }  
  9.         public string host { get; set; }  
  10.         public string userid { get; set; }  
  11.         public string feedid { get; set; }  
  12.     }  
  13.   
  14.     public class BusinessInfoHelper  
  15.     {  
  16.         #region 解决发布时含有优质媒体时，前台页面卡住的现象  
  17.         //原理：利用生产者消费者模式进行入列出列操作  
  18.   
  19.         public readonly static BusinessInfoHelper Instance = new BusinessInfoHelper();  
  20.         private BusinessInfoHelper()  
  21.         { }  
  22.   
  23.         private Queue<QueueInfo> ListQueue = new Queue<QueueInfo>();  
  24.   
  25.         public void AddQueue(string medias, string proids, string host, string userid, string feedid) //入列  
  26.         {  
  27.             QueueInfo queueinfo = new QueueInfo();  
  28.   
  29.             queueinfo.medias = medias;  
  30.             queueinfo.proids = proids;  
  31.             queueinfo.host = host;  
  32.             queueinfo.userid = userid;  
  33.             queueinfo.feedid = feedid;  
  34.             ListQueue.Enqueue(queueinfo);  
  35.         }  
  36.   
  37.         public void Start()//启动  
  38.         {  
  39.             Thread thread = new Thread(threadStart);  
  40.             thread.IsBackground = true;  
  41.             thread.Start();  
  42.         }  
  43.   
  44.         private void threadStart()  
  45.         {  
  46.             while (true)  
  47.             {  
  48.                 if (ListQueue.Count > 0)  
  49.                 {  
  50.                     try  
  51.                     {  
  52.                         ScanQueue();  
  53.                     }  
  54.                     catch (Exception ex)  
  55.                     {  
  56.                         LO_LogInfo.WLlog(ex.ToString());  
  57.                     }  
  58.                 }  
  59.                 else  
  60.                 {  
  61.                     //没有任务，休息3秒钟  
  62.                     Thread.Sleep(3000);  
  63.                 }  
  64.             }  
  65.         }  
  66.   
  67.         //要执行的方法  
  68.         private void ScanQueue()  
  69.         {  
  70.             while (ListQueue.Count > 0)  
  71.             {  
  72.                 try  
  73.                 {  
  74.                     //从队列中取出  
  75.                     QueueInfo queueinfo = ListQueue.Dequeue();  
  76.   
  77.                     //取出的queueinfo就可以用了，里面有你要的东西  
  78.                     //以下就是处理程序了  
  79.                     //。。。。。。  
  80.   
  81.                 }  
  82.                 catch (Exception ex)  
  83.                 {  
  84.                     throw;  
  85.                 }  
  86.             }  
  87.         }  
  88.  
  89.  
  90.         #endregion  
  91.     }  
  92. }  

以上页面写好后，在程序开始运行时就得启动这个线程去不停的处理任务，那么我们在Global的Application_Start里可以这样写：

[csharp] view plain copy
 
  1. //启动发布优质媒体程序  
  2. MyNameSpace.BusinessInfoHelper.Instance.Start();  


有一个问题出来了，如果我处理完队列中的一条记录后，想返回这条记录的ID，这个程序好像不能完成，我就使用了另一个方法 Lock方法 ，把方法锁定，具体的如下，

在页面中定义全局的锁：

[csharp] view plain copy
 
  1. private static object lockObject= new Object();  

在方法 中这样调用：

[csharp] view plain copy
 
  1. lock(lockObject)  
  2.   
  3. {  
  4.   
  5. //........  
  6.   
  7. }  


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

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/chengjun/p/5833867.html