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

这篇文章主要介绍了使用队列(Queue)解决简单的并发问题，讲解的很细致，喜欢的朋友们可以了解一下

本文通过实例，更具体的讲解了队列，队列(Queue)代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时，则使用队列。当您在列表中添加一项，称为入队，当您从列表中移除一项时，称为出队。

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

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

案例：

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

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

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里可以这样写：

//启动发布优质媒体程序

MyNameSpace.BusinessInfoHelper.Instance.Start();

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

在页面中定义全局的锁：

private static object lockObject= new Object();

在方法中这样调用：

lock(lockObject)

{

//........

}

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