C#多線程處理多個隊列數(shù)據(jù)的方法
更新時間:2015年07月03日 10:16:35 作者:程序猴
這篇文章主要介紹了C#多線程處理多個隊列數(shù)據(jù)的方法,涉及C#線程與隊列的相關(guān)操作技巧,需要的朋友可以參考下
本文實例講述了C#多線程處理多個隊列數(shù)據(jù)的方法。分享給大家供大家參考。具體實現(xiàn)方法如下:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Collections; using System.Windows.Forms; namespace ThredProcessQueue { //用于顯示狀態(tài)的代理方法類型定義 public delegate void DelegateShowStateInfo(string state); /// <summary> /// 測試器 /// </summary> public class QueueTester { private static bool _Exit = false; //標記是否已中斷測試程序 private static Form _OwnerForm; //測試的窗體 private static DelegateShowStateInfo _StateMethod; private static IList _Queue1 = new ArrayList(); //Queue1的數(shù)據(jù) private static IList _Queue2 = new ArrayList(); //Queue2的數(shù)據(jù) private static IList _Queue3 = new ArrayList(); //Queue3的數(shù)據(jù) public static void StopThread() { _Exit = true; _OwnerForm = null; } public static void Testing(Form sender, DelegateShowStateInfo method) { _StateMethod = method; _OwnerForm = sender; _Exit = false; ThreadPool.QueueUserWorkItem(MainTestThread); ThreadPool.QueueUserWorkItem(Queue1Thread); //啟動Queue1線程 ThreadPool.QueueUserWorkItem(Queue2Thread); //啟動Queue2線程 } //測試用的主線程,循環(huán)向隊列1中壓入數(shù)據(jù)。 public static void MainTestThread(object state) { Random R = new Random(1); double V = 0; while (_Exit == false) { //在while(true)里一直對數(shù)據(jù)進行讀取,然后放到queue1中, //與此同時如果queue1中有數(shù)據(jù),則線程1就開啟 //臨時數(shù)據(jù),隨機數(shù) V = R.NextDouble(); _Queue1.Add(V); //把數(shù)據(jù)插入到隊列1 Application.DoEvents(); ShowState(); Thread.Sleep(100);//生成隨機數(shù)太快,為了看清效果,暫停n毫秒 } } //對queue1中的數(shù)據(jù)進行處理,處理后放到queue2中 public static void Queue1Thread(object state) { while (_Exit == false) { while (_Queue1.Count > 0) { //對queue1中的數(shù)據(jù)進行處理,處理后放到queue2中 _Queue2.Add(_Queue1[0]); _Queue1.RemoveAt(0); Application.DoEvents(); ShowState(); } } } //對queue2中的數(shù)據(jù)進行處理,處理后放到queue3中 public static void Queue2Thread(object state) { while (_Exit == false) { while (_Queue2.Count > 0) { //對queue1中的數(shù)據(jù)進行處理,處理后放到queue2中 _Queue3.Add(_Queue2[0]); _Queue2.RemoveAt(0); Application.DoEvents(); ShowState(); } } } //用于監(jiān)視各隊列狀態(tài)的線程 public static void ShowState() { string stateInfo = QueueTester._Queue1.Count.ToString() " -> " QueueTester._Queue2.Count.ToString() " -> " QueueTester._Queue3.Count.ToString(); try { if (_OwnerForm != null) { _OwnerForm.Invoke(_StateMethod, stateInfo); Application.DoEvents(); } } catch { } } } }
希望本文所述對大家的C#程序設(shè)計有所幫助。
相關(guān)文章
使用策略模式實現(xiàn)報警服務(wù)示例詳解(短信報警)
服務(wù)的功能:這個服務(wù)就是能夠?qū)崿F(xiàn)多通路報警的服務(wù),比如郵件報警、客戶端報警、短信報警等,該服務(wù)靈活性還不錯,比較方便擴展2014-01-01Unity UGUI的HorizontalLayoutGroup水平布局組件介紹使用
這篇文章主要為大家介紹了Unity UGUI的HorizontalLayoutGroup水平布局組件介紹使用,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-07-07C#實現(xiàn)根據(jù)給出的相對地址獲取網(wǎng)站絕對地址的方法
這篇文章主要介紹了C#實現(xiàn)根據(jù)給出的相對地址獲取網(wǎng)站絕對地址的方法,涉及C#URL及字符串操作的技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-03-03使用Unity3D實現(xiàn)選中物體消融特效的方法詳解
消融特效中基Shader?Graph實現(xiàn)了消融特效,本文將基于?Shader?實現(xiàn)消融特效,當前實現(xiàn)消融特效的方法主要有?Alpha?測試消融、clip(或?discard)消融,它們的本質(zhì)都是隨機丟棄一些片元,以實現(xiàn)消融效果,文中有詳細代碼示例,需要的朋友可以參考下2023-10-10