JAVA高级面试进阶训练营视频教程

admin

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

2015-07-16 13:04 13265人阅读 评论(8) 收藏 举报

 分类：

Asp.Net（8） 

版权声明：本文为博主原创文章，未经博主允许不得转载。

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

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

案例：

 

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

 

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

 

[csharp]  view plain  copy

 

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

[csharp]  view plain  copy

 

1. //启动发布优质媒体程序  
2. MyNameSpace.BusinessInfoHelper.Instance.Start();  

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

 

在页面中定义全局的锁：

[csharp]  view plain  copy

 

1. private static object lockObject= new Object();  

 

在方法 中这样调用：

[csharp]  view plain  copy

 

1. lock(lockObject)  
2.   
3. {  
4.   
5. //........  
6.   
7. }  

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