栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > C/C++/C# > C#教程

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

C#教程 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

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

本文通过实例,更具体的讲解了队列,队列(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 ListQueue = new Queue(); 
 
    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) 
 

 
//........ 
 

以上是本文的全部内容,希望对大家进一步学习队列有所帮助

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/124887.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号