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


Jan 12 2016

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

首页 » 渗透编程 » (C#)使用队列(Queue)解决简单的并发问题   

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

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

案例:

 

要求:有一个发布文章的接口,每发布一篇文章,调用一下接口。(这里不用批量发布,为了讲解这个)

 

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

 

[csharp] view plaincopy
  1. namespace MyNameSpace   
  2.   
  3. {  
  4.     //队列临时类  
  5.     public class QueueInfo  
  6.     {  
  7.         public string medias { getset; }  
  8.         public string proids { getset; }  
  9.         public string host { getset; }  
  10.         public string userid { getset; }  
  11.         public string feedid { getset; }  
  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 plaincopy
  1. //启动发布优质媒体程序  
  2. MyNameSpace.BusinessInfoHelper.Instance.Start();  


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

 

在页面中定义全局的锁:

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

 

在方法 中这样调用:

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


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

如果您喜欢本博客,欢迎点击图片定订阅到邮箱填写您的邮件地址,订阅我们的精彩内容:

正文部分到此结束

文章标签:这篇文章木有标签

版权声明:若无特殊注明,本文皆为( mOon )原创,转载请保留文章出处。

也许喜欢: «工作队列wait queue() wait_event() interruptible_sleep_on()等应用方法 | KCon 大会的资料»

你肿么看?

你还可以输入 250/250 个字

 微笑 大笑 拽 大哭 亲亲 流汗 喷血 奸笑 囧 不爽 晕 示爱 害羞 吃惊 惊叹 爱你 吓死了 呵呵

评论信息框

这篇文章还没有收到评论,赶紧来抢沙发吧~