C#使用队列(Queue)解决简单的并发问题
本文通过实例，更具体的讲解了队列，队列（Queue）代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时，则使用队列。当您在列表中添加一项，称为入队，当您从列表中移除一项时，称为出队。
有一个场景：一个抢购的项目，假设有5件商品，谁先抢到谁可以买，但是如果此时此刻（这里的此时此刻假设是相同的时间），有100人去抢这个商品，如果使用平时的方法会出现什么情况呢？你懂的，这里所说是就是有关并发的问题。
平时我们去超市购物去结账的时候就是排队，这里我们先让抢购人排好队，按时间，谁先点击的抢购按钮谁就排在前面，这样就形成了一个队列，然后我们再对这个队列处理，这样就不会出现并发的问题了。（至少可以处理这样简单的并发，这里不讨论太复杂的并发）
案例：
要求：有一个发布文章的接口，每发布一篇文章，调用一下接口。（这里不用批量发布，为了讲解这个）
建立一个这样的处理程序类，BusinessInfoHelper.cs
namespaceMyNameSpace
{
//队列临时类
publicclassQueueInfo
{
publicstringmedias{get;set;}
publicstringproids{get;set;}
publicstringhost{get;set;}
publicstringuserid{get;set;}
publicstringfeedid{get;set;}
}
publicclassBusinessInfoHelper
{
#region解决发布时含有优质媒体时，前台页面卡住的现象
//原理：利用生产者消费者模式进行入列出列操作
publicreadonlystaticBusinessInfoHelperInstance=newBusinessInfoHelper();
privateBusinessInfoHelper()
{}
privateQueue<QueueInfo>ListQueue=newQueue<QueueInfo>();
publicvoidAddQueue(stringmedias,stringproids,stringhost,stringuserid,stringfeedid)//入列
{
QueueInfoqueueinfo=newQueueInfo();
queueinfo.medias=medias;
queueinfo.proids=proids;
queueinfo.host=host;
queueinfo.userid=userid;
queueinfo.feedid=feedid;
ListQueue.Enqueue(queueinfo);
}
publicvoidStart()//启动
{
Threadthread=newThread(threadStart);
thread.IsBackground=true;
thread.Start();
}
privatevoidthreadStart()
{
while(true)
{
if(ListQueue.Count>0)
{
try
{
ScanQueue();
}
catch(Exceptionex)
{
LO_LogInfo.WLlog(ex.ToString());
}
}
else
{
//没有任务，休息3秒钟
Thread.Sleep(3000);
}
}
}
//要执行的方法
privatevoidScanQueue()
{
while(ListQueue.Count>0)
{
try
{
//从队列中取出
QueueInfoqueueinfo=ListQueue.Dequeue();
//取出的queueinfo就可以用了，里面有你要的东西
//以下就是处理程序了
//。。。。。。
}
catch(Exceptionex)
{
throw;
}
}
}
#endregion
}
}
以上页面写好后，在程序开始运行时就得启动这个线程去不停的处理任务，那么我们在Global的Application_Start里可以这样写：
//启动发布优质媒体程序
MyNameSpace.BusinessInfoHelper.Instance.Start();
有一个问题出来了，如果我处理完队列中的一条记录后，想返回这条记录的ID，这个程序好像不能完成，我就使用了另一个方法Lock方法，把方法锁定，具体的如下，
在页面中定义全局的锁：
privatestaticobjectlockObject=newObject();
在方法中这样调用：
lock(lockObject)
{
//........
}
以上是本文的全部内容，希望对大家进一步学习队列有所帮助