我們在用C# 開發程式時,經常會使用的多線程,實現多任務的處理。一般常用的方法是新建多個線程,進行處理。 今天我分享一個採用線程池的方式來實現的實例。對有需要的朋友做個借鑒。 實例: Winform using System; using System.Collections.Generic; us ...
我們在用C# 開發程式時,經常會使用的多線程,實現多任務的處理。一般常用的方法是新建多個線程,進行處理。
今天我分享一個採用線程池的方式來實現的實例。對有需要的朋友做個借鑒。
實例: Winform
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Threading; namespace MultiThreading { /// <summary> /// 此實例:為SDP軟體快速開發平臺中使用到的真實方法 /// </summary> public partial class Form1 : Form { /// <summary> /// 私有:線程同步信號 /// </summary> private ManualResetEvent cmdWaiter; /// <summary> /// 委托更新進度條 /// </summary> private delegate void updateBar(); /// <summary> /// 結束提示委托 /// </summary> private delegate void showEnd(); /// <summary> /// 任務隊列 /// 註意:此任務隊列 需要用戶自動來定義 /// 實例中採用 string 來處理 /// </summary> private List<string> taskList = new List<string>(); /// <summary> /// 構造函數 /// </summary> public Form1() { InitializeComponent(); } /// <summary> /// 頁面初始化載入 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void Form1_Load(object sender, EventArgs e) { // 阻塞當前線程 cmdWaiter = new ManualResetEvent(false); // 啟動線程池 ThreadPool.QueueUserWorkItem(new WaitCallback(this.On_ThreadEvent)); } /// <summary> /// 線程處理事務 /// </summary> /// <param name="obj"></param> private void On_ThreadEvent(object obj) { while (true) { try { // 阻塞當前線程,等待解除指令 this.cmdWaiter.WaitOne(); // 執行我們需要處理的事務 for (int k = 0; k < taskList.Count; k++) { Run_MyBusiness(taskList[k]); // 休息指定的毫秒 Thread.Sleep(50); } // 清除隊列數據 this.taskList.Clear(); this.On_EndLog(); this.cmdWaiter.Reset(); } catch (Exception e) { string strError = e.Message.ToString(); this.taskList.Clear(); this.cmdWaiter.Reset(); } } } /// <summary> /// 執行我們自己的業務 /// </summary> /// <param name="str"></param> private void Run_MyBusiness(string str) { // 委托更新 updateBar updateDelegate = new updateBar(On_Update); this.Invoke(updateDelegate); } /// <summary> /// 開始按鈕 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btn_Start_Click(object sender, EventArgs e) { this.taskList = new List<string>(); for (int i = 1; i < 1001; i++) { this.taskList.Add(i.ToString()); } this.txt_log.Text = "開始:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + Environment.NewLine; this.pg_Bar.Value = 0; this.pg_Bar.Maximum = this.taskList.Count; // 解除阻塞 this.cmdWaiter.Set(); } /// <summary> /// 更新進度條 /// </summary> private void On_Update() { this.pg_Bar.Value = this.pg_Bar.Value + 1; } private void On_EndLog() { showEnd endDeg = new showEnd(On_UpdateTextBox); this.Invoke(endDeg); } private void On_UpdateTextBox() { string runStr = "結束:" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); this.txt_log.Text = this.txt_log.Text + runStr; } } }View Code
運行效果:
下載地址:多線程實例 DEMO