我們在用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;
}
}
}
運行效果：
下載地址：http://www.sdpsoft.com/demofiles/MultiThreading.rar
uj5u.com熱心網友回復：
感謝分享
uj5u.com熱心網友回復：
用了這個// 阻塞當前執行緒，等待解除指令
this.cmdWaiter.WaitOne();
效果就不好了。成立同步等待了
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/133778.html
標籤：ASP.NET
上一篇：DEV gridColumn VisibleIndex為什么在代碼里面更改不了呢
下一篇：沒有任何行