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<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)
{
//........
}
以上是本文的全部内容,希望对大家进一步学习队列有所帮助
您可能感兴趣的文章:
- 让Win2008+IIS7+ASP.NET支持10万并发请求
- c#实现服务器性能监控并发送邮件保存日志
- C#线程执行超时处理与并发线程数控制实例
- c#编写的高并发数据库控制访问代码
- 在ASP.NET 2.0中操作数据之二十一:实现开放式并发
- 在ASP.NET 2.0中操作数据之四十四:DataList和Repeater数据排序(三)
- 在ASP.NET 2.0中操作数据之四十五:DataList和Repeater里的自定义Button
- 在ASP.NET 2.0中操作数据之四十六:使用SqlDataSource控件检索数据
- 在ASP.NET 2.0中操作数据之四十七:用SqlDataSource控件插入、更新、删除数据
- 在ASP.NET 2.0中操作数据之四十八:对SqlDataSource控件使用开放式并发
- c#调用COM组件
- C#实现把指定数据写入串口
- C#中抽象方法与虚拟方法的区别
- c#中虚函数的相关使用方法
- C#实现多线程的同步方法实例分析
- C#中尾递归的使用、优化及编译器优化
- C#通用邮件发送类分享
- C#中this的用法集锦
- C#.NET获取拨号连接的宽带连接方法
- C#实现AddRange为数组添加多个元素的方法
- C#中Equality和Identity浅析
- C#生成饼形图及添加文字说明实例代码
- C#判等对象是否相等的方法汇总
- C#简单的向量用法实例教程
- C#实现基于链表的内存记事本实例
- C#托管堆对象实例包含内容分析
- C#实现按照指定长度在数字前补0方法小结
- C# 通过 inline-asm 解决嵌入x86汇编
- C#虚方法的声明和使用实例教程
- C#获取文件夹及文件的大小与占用空间的方法