程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#入門知識 >> C#多線程處置多個隊列數據的辦法

C#多線程處置多個隊列數據的辦法

編輯:C#入門知識

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#法式設計有所贊助。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved