winform開發(fā)使用通用多線程基類分享(以隊列形式)
/// <summary>
/// 隊列多線程,T 代表處理的單個類型~
/// </summary>
/// <typeparam name="T"></typeparam>
public abstract class QueueThreadBase<T>
{
#region 變量&屬性
/// <summary>
/// 待處理結果
/// </summary>
private class PendingResult
{
/// <summary>
/// 待處理值
/// </summary>
public T PendingValue { get; set; }
/// <summary>
/// 是否有值
/// </summary>
public bool IsHad { get; set; }
}
/// <summary>
/// 線程數
/// </summary>
public int ThreadCount
{
get { return this.m_ThreadCount; }
set { this.m_ThreadCount = value; }
}
private int m_ThreadCount = 5;
/// <summary>
/// 取消=True
/// </summary>
public bool Cancel { get; set; }
/// <summary>
/// 線程列表
/// </summary>
List<Thread> m_ThreadList;
/// <summary>
/// 完成隊列個數
/// </summary>
private volatile int m_CompletedCount = 0;
/// <summary>
/// 隊列總數
/// </summary>
private int m_QueueCount = 0;
/// <summary>
/// 全部完成鎖
/// </summary>
private object m_AllCompletedLock = new object();
/// <summary>
/// 完成的線程數
/// </summary>
private int m_CompetedCount = 0;
/// <summary>
/// 隊列鎖
/// </summary>
private object m_PendingQueueLock = new object();
private Queue<T> m_InnerQueue;
#endregion
#region 事件相關
/// <summary>
/// 全部完成事件
/// </summary>
public event Action<CompetedEventArgs> AllCompleted;
/// <summary>
/// 單個完成事件
/// </summary>
public event Action<T, CompetedEventArgs> OneCompleted;
/// <summary>
/// 引發(fā)全部完成事件
/// </summary>
/// <param name="args"></param>
private void OnAllCompleted(CompetedEventArgs args)
{
if (AllCompleted != null)
{
try
{
AllCompleted(args);//全部完成事件
}
catch { }
}
}
/// <summary>
/// 引發(fā)單個完成事件
/// </summary>
/// <param name="pendingValue"></param>
/// <param name="args"></param>
private void OnOneCompleted(T pendingValue, CompetedEventArgs args)
{
if (OneCompleted != null)
{
try
{
OneCompleted(pendingValue, args);
}
catch { }
}
}
#endregion
#region 構造
public QueueThreadBase(IEnumerable<T> collection)
{
m_InnerQueue = new Queue<T>(collection);
this.m_QueueCount = m_InnerQueue.Count;
}
#endregion
#region 主體
/// <summary>
/// 初始化線程
/// </summary>
private void InitThread()
{
m_ThreadList = new List<Thread>();
for (int i = 0; i < ThreadCount; i++)
{
Thread t = new Thread(new ThreadStart(InnerDoWork));
m_ThreadList.Add(t);
t.IsBackground = true;
t.Start();
}
}
/// <summary>
/// 開始
/// </summary>
public void Start()
{
InitThread();
}
/// <summary>
/// 線程工作
/// </summary>
private void InnerDoWork()
{
try
{
Exception doWorkEx = null;
DoWorkResult doworkResult = DoWorkResult.ContinueThread;
var t = CurrentPendingQueue;
while (!this.Cancel && t.IsHad)
{
try
{
doworkResult = DoWork(t.PendingValue);
}
catch (Exception ex)
{
doWorkEx = ex;
}
m_CompletedCount++;
int precent = m_CompletedCount * 100 / m_QueueCount;
OnOneCompleted(t.PendingValue, new CompetedEventArgs() { CompetedPrecent = precent, InnerException = doWorkEx });
if (doworkResult == DoWorkResult.AbortAllThread)
{
this.Cancel = true;
break;
}
else if (doworkResult == DoWorkResult.AbortCurrentThread)
{
break;
}
t = CurrentPendingQueue;
}
lock (m_AllCompletedLock)
{
m_CompetedCount++;
if (m_CompetedCount == m_ThreadList.Count)
{
OnAllCompleted(new CompetedEventArgs() { CompetedPrecent = 100 });
}
}
}
catch
{
throw;
}
}
/// <summary>
/// 子類重寫
/// </summary>
/// <param name="pendingValue"></param>
/// <returns></returns>
protected virtual DoWorkResult DoWork(T pendingValue)
{
return DoWorkResult.ContinueThread;
}
/// <summary>
/// 獲取當前結果
/// </summary>
private PendingResult CurrentPendingQueue
{
get
{
lock (m_PendingQueueLock)
{
PendingResult t = new PendingResult();
if (m_InnerQueue.Count != 0)
{
t.PendingValue = m_InnerQueue.Dequeue();
t.IsHad = true;
}
else
{
t.PendingValue = default(T);
t.IsHad = false;
}
return t;
}
}
}
#endregion
#region 相關類&枚舉
/// <summary>
/// dowork結果枚舉
/// </summary>
public enum DoWorkResult
{
/// <summary>
/// 繼續(xù)運行，默認
/// </summary>
ContinueThread = 0,
/// <summary>
/// 終止當前線程
/// </summary>
AbortCurrentThread = 1,
/// <summary>
/// 終止全部線程
/// </summary>
AbortAllThread = 2
}
/// <summary>
/// 完成事件數據
/// </summary>
public class CompetedEventArgs : EventArgs
{
public CompetedEventArgs()
{
}
/// <summary>
/// 完成百分率
/// </summary>
public int CompetedPrecent { get; set; }
/// <summary>
/// 異常信息
/// </summary>
public Exception InnerException { get; set; }
}
#endregion
}
1.從構造函數來看,處理的是一個確定的列表.沒錯.這個多線程只能處理已經確定的列表,你是否會問.可不可以一邊添加,一邊處理呢?(呵呵,可以,請聯系樓主,當然你也可以自己寫,是吧?!)
public QueueThreadBase(IEnumerable<T> collection)
2.提供撤銷的功能
/// <summary>
/// 取消=True
/// </summary>
public bool Cancel { get; set; }
3.提供線程個數修改功能
/// <summary>
/// 線程數
/// </summary>
public int ThreadCount
{
get { return this.m_ThreadCount; }
set { this.m_ThreadCount = value; }
}
4.提供多種事件響應,如單個完成,全部完成的事件
/// <summary>
/// 全部完成事件
/// </summary>
public event Action<CompetedEventArgs> AllCompleted;
/// <summary>
/// 單個完成事件
/// </summary>
public event Action<T, CompetedEventArgs> OneCompleted;
5.提供完成的百分率
/// <summary>
/// 完成事件數據
/// </summary>
public class CompetedEventArgs : EventArgs
{
public CompetedEventArgs()
{
}
/// <summary>
/// 完成百分率
/// </summary>
public int CompetedPrecent { get; set; }
/// <summary>
/// 異常信息
/// </summary>
public Exception InnerException { get; set; }
}
6.提供終止線程的方式,繼續(xù)/單線程終止/全部終止
/// <summary>
/// dowork結果枚舉
/// </summary>
public enum DoWorkResult
{
/// <summary>
/// 繼續(xù)運行，默認
/// </summary>
ContinueThread = 0,
/// <summary>
/// 終止當前線程
/// </summary>
AbortCurrentThread = 1,
/// <summary>
/// 終止全部線程
/// </summary>
AbortAllThread = 2
}
你是否會問?怎么用呢?別急....請看
/// <summary>
/// 下載線程對了.
/// </summary>
public class DownLoadQueueThread:QueueThreadBase<int>
{
/// <summary>
///
/// </summary>
/// <param name="list">下載的列表ID</param>
public DownLoadQueueThread(IEnumerable<int> list):base(list)
{
}
/// <summary>
/// 每次多線程都到這里來,處理多線程
/// </summary>
/// <param name="pendingValue"列表ID></param>
/// <returns></returns>
protected override DoWorkResult DoWork(int pendingID)
{
try
{
//..........多線程處理....
return DoWorkResult.ContinueThread;//沒有異常讓線程繼續(xù)跑..
}
catch (Exception)
{
return DoWorkResult.AbortCurrentThread;//有異常,可以終止當前線程.當然.也可以繼續(xù),
//return DoWorkResult.AbortAllThread; //特殊情況下 ,有異常終止所有的線程...
}
//return base.DoWork(pendingValue);
}
}
用法
總結:
多線程在什么時候都會用到.不用到是你不會用.多線程要一定的編程基礎,如果你覺得有點難度,那你可以學習并且借鑒人家已有的東西.少走彎路,是我們程序員經歷嗷嗷待哺后的心聲.本文以交流態(tài)度和感恩心態(tài),貢獻給有需要的人們.
相關文章
這篇文章主要介紹了C#基于cookie實現的購物車功能,結合完整實例形式分析了C#基于cookie創(chuàng)建購物車的具體步驟與相關技巧,需要的朋友可以參考下2015-12-12
本文詳細講解了C#正則表達式的用法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-04-04
這篇文章主要介紹了基于C#實現手機號碼歸屬地接口調用的相關資料,需要的朋友可以參考下2016-02-02
這篇文章主要介紹了C#實體類轉換的兩種方式小結，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-01-01
這篇文章主要介紹了使用c#同步兩個子目錄文件的方法,大家參考使用吧2014-01-01
為公司系統業(yè)務需要，這幾天了解了一下微信和支付寶掃碼支付的接口，并用c#實現了微信和支付寶掃碼支付的功能。需要的朋友跟隨小編一起看看吧2019-06-06
這篇文章主要為大家詳細介紹了Unity3D Shader實現掃描顯示效果，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-03-03
這篇文章主要介紹了C#實現開機自動啟動設置代碼分享,本文直接給出實現代碼,需要的朋友可以參考下2015-07-07
這篇文章主要介紹了C# WinForm國際化實現的簡單方法，有需要的朋友可以參考一下2014-01-01
這篇文章主要給大家介紹了關于如何利用C#版OpenCV實現圓心求取的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-05-05