多執行緒，佇列，先進先出、信號量...

某些場景并發量太高，需要采用佇列輔助，特此備注：多執行緒佇列，先進先出

某些情況也會用到阻塞當前執行緒，等待服務器回傳或者耗時的處理，這種情況，可采用信號量輔助

1 ManualResetEvent allDone = new ManualResetEvent(false);//初始化，開啟阻塞
2 allDone.Reset();//信號量重置，狀態為阻塞
3 allDone.WaitOne(5*1000);//阻塞當前執行緒，最大等待5秒
4 allDone.Set();//釋放信號量，將阻塞的執行緒繼續向下

口水話注解：呼叫了Set方法將事件設為true后，不會去呼叫Reset方法，這將導致事件一直處于true，其它等待的多個執行緒都會得到執行，直到你手動呼叫Reset方法，
相當于你把門打開后，需要手動去關（非自動門），

1 AutoResetEvent ReciveResetEvent = new System.Threading.AutoResetEvent(true);//初始化，未開啟阻塞
2 ReciveResetEvent.WaitOne(30000);//阻塞
3 ReciveResetEvent.Set();//釋放后，自動開啟阻塞
口水話注解：呼叫了Set方法將事件設為true之后，其中一個等待執行緒得到執行后，它會自動呼叫Reset方法，將事件信號設為false，以阻塞其它的執行緒，
相當于放一個執行緒進來，門自動就關了（自動門），

  1 /*
  2     例子：
  3         
  4     //初始化后臺處理訊息執行緒
  5     AsyncQueueDataProcessor<string> asyncQueueDetector = new AsyncQueueDataProcessor<string>();
  6     asyncQueueDetector.ProcessData += AsyncQueue_ProcessData;//事件里處理有資料時
  7     asyncQueueDetector.Start();
  8 
  9     服務啟動后，使用 asyncQueueDetector.AppendData 追加資料到佇列
 10     */
 11 
 12 
 13     /// <summary>
 14     /// 異步處理佇列資料
 15     /// </summary>
 16     /// <typeparam name="T"></typeparam>
 17     public class AsyncQueueDataProcessor<T> : IDisposable
 18     {
 19         #region 成員變數
 20 
 21         /// <summary>
 22         /// 待處理的資料佇列
 23         /// </summary>
 24         ConcurrentQueue<T> DataQueue;
 25 
 26         /// <summary>
 27         /// 資料處理定時器
 28         /// </summary>
 29         Timer processTimer;
 30 
 31         #endregion
 32 
 33         #region 建構式
 34 
 35         /// <summary>
 36         /// 初始化
 37         /// </summary>
 38         /// <param name="intervalMillSecond"></param>
 39         public AsyncQueueDataProcessor(int intervalMillSecond = 120)
 40         {
 41             DataQueue = new ConcurrentQueue<T>();
 42             processTimer = new Timer(intervalMillSecond);
 43             processTimer.Elapsed += ProcessTimer_Elapsed;
 44             processTimer.AutoReset = false;
 45         }
 46 
 47         #endregion
 48 
 49         #region 自定義事件
 50 
 51         /// <summary>
 52         /// 資料拋出時觸發
 53         /// </summary>
 54         public event EventHandler<T> ProcessData;
 55 
 56         #endregion
 57 
 58         #region 公共方法
 59 
 60         /// <summary>
 61         /// 釋放所有資源
 62         /// </summary>
 63         public void Dispose()
 64         {
 65             processTimer.Dispose();
 66             ClearData();
 67         }
 68 
 69         /// <summary>
 70         /// 開始處理資料
 71         /// </summary>
 72         public void Start()
 73         {
 74             processTimer.Start();
 75         }
 76 
 77         /// <summary>
 78         /// 停止處理資料
 79         /// </summary>
 80         public void Stop()
 81         {
 82             processTimer.Stop();
 83         }
 84 
 85         /// <summary>
 86         /// 追加資料到佇列
 87         /// </summary>
 88         /// <param name="data"></param>
 89         public void AppendData(T data)
 90         {
 91             DataQueue.Enqueue(data);
 92         }
 93 
 94         /// <summary>
 95         /// 清空佇列資料
 96         /// </summary>
 97         public void ClearData()
 98         {
 99             do
100             {
101             } while (DataQueue.TryDequeue(out T t));
102         }
103         #endregion
104 
105         #region 事件
106 
107         //處理資料時執行
108         private void ProcessTimer_Elapsed(object sender, ElapsedEventArgs e)
109         {
110             T t;
111             if (DataQueue.TryDequeue(out t))
112             {
113                 if (ProcessData != null)
114                 {
115                     try
116                     {
117                         ProcessData(this, t);
118                     }
119                     catch (Exception exp)
120                     {
121                         Debug.WriteLine($"佇列里面發生了未處理的例外-{exp.Message}\r\n{exp.StackTrace}");
122                     }
123                 }
124             }
125 
126             processTimer.Start();
127         }
128 
129         #endregion
130     }

標籤：C#

上一篇：c# 利用易福門振動模塊VSE002采集振動資料

下一篇：Blazor入門筆記（5）-資料系結