C#多線程處置多個隊列數據的辦法。本站提示廣大學習愛好者:(C#多線程處置多個隊列數據的辦法)文章只能為提供參考,不一定能成為您想要的結果。以下是C#多線程處置多個隊列數據的辦法正文
本文實例講述了C#多線程處置多個隊列數據的辦法。分享給年夜家供年夜家參考。詳細完成辦法以下:
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Collections; using System.Windows.Forms; namespace ThredProcessQueue { //用於顯示狀態的署理辦法類型定義 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的數據 private static IList _Queue2 = new ArrayList(); //Queue2的數據 private static IList _Queue3 = new ArrayList(); //Queue3的數據 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線程 } //測試用的主線程,循環向隊列1中壓入數據。 public static void MainTestThread(object state) { Random R = new Random(1); double V = 0; while (_Exit == false) { //在while(true)裡一向對數據停止讀取,然後放到queue1中, //與此同時假如queue1中稀有據,則線程1就開啟 //臨時數據,隨機數 V = R.NextDouble(); _Queue1.Add(V); //把數據拔出到隊列1 Application.DoEvents(); ShowState(); Thread.Sleep(100);//生成隨機數太快,為了看清後果,暫停n毫秒 } } //對queue1中的數據停止處置,處置後放到queue2中 public static void Queue1Thread(object state) { while (_Exit == false) { while (_Queue1.Count > 0) { //對queue1中的數據停止處置,處置後放到queue2中 _Queue2.Add(_Queue1[0]); _Queue1.RemoveAt(0); Application.DoEvents(); ShowState(); } } } //對queue2中的數據停止處置,處置後放到queue3中 public static void Queue2Thread(object state) { while (_Exit == false) { while (_Queue2.Count > 0) { //對queue1中的數據停止處置,處置後放到queue2中 _Queue3.Add(_Queue2[0]); _Queue2.RemoveAt(0); Application.DoEvents(); ShowState(); } } } //用於監視各隊列狀態的線程 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#法式設計有所贊助。