C#多線程等待所有子線程結(jié)束的示例
在使用多線程過(guò)程中,可能會(huì)遇到在一些情況下必須等待子線程全部執(zhí)行結(jié)束后主線程才進(jìn)行下一步,
做法如下:
//在使用多線程過(guò)程中,可能會(huì)遇到在一些情況下必須等待子線程全部執(zhí)行結(jié)束后主線程才進(jìn)行下一步,做法如下 List<ManualResetEvent> manualEvents = new List<ManualResetEvent>();//創(chuàng)建線程等待集合 for (int i = 0; i < 64; i++) //WaitHandles 的數(shù)目必須少于或等于 64 個(gè),所以最大線程數(shù)為64 { MB m = new MB();//自定義類,用于傳參 m.mre= new ManualResetEvent(false); m.ID = i; manualEvents.Add(m.mre); ThreadPool.QueueUserWorkItem(ThreadMethod, m); } WaitHandle.WaitAll(manualEvents.ToArray());//等待所有線程結(jié)束 Console.WriteLine("Thread Finished!");
private static void ThreadMethod(object obj) { MB m = (MB)obj; Thread.Sleep(1000);//等待1秒,用于模擬系統(tǒng)在處理事情 m.mre.Set();//將事件設(shè)置為終止?fàn)顟B(tài) Console.WriteLine("Thread execute:" + m.ID); }
以上方法在處理時(shí)當(dāng)線程數(shù)超過(guò)64時(shí)報(bào)錯(cuò) WaitHandles 的數(shù)目必須少于或等于 64 個(gè),所以最大線程數(shù)為64
解決方法如下:
using (var countdown = new MutipleThreadResetEvent(list.Count)) { for (int i = 0; i < list.Count; i++) { //開啟N個(gè)線程,傳遞MutipleThreadResetEvent對(duì)象給子線程 Param p = new Param(); p.countdown = countdown; p.Path = pa[i]; ThreadPool.QueueUserWorkItem(MyHttpRequest, p); } //等待所有線程執(zhí)行完畢 countdown.WaitAll(); }
public class MutipleThreadResetEvent: IDisposable { private readonly ManualResetEvent done; private readonly int total; private long current; /// <summary> /// 構(gòu)造函數(shù) /// </summary> /// <param name="total">需要等待執(zhí)行的線程總數(shù)</param> public MutipleThreadResetEvent(int total) { this.total = total; current = total; done = new ManualResetEvent(false); } /// <summary> /// 喚醒一個(gè)等待的線程 /// </summary> public void SetOne() { // Interlocked 原子操作類 ,此處將計(jì)數(shù)器減1 if (Interlocked.Decrement(ref current) == 0) { //當(dāng)所以等待線程執(zhí)行完畢時(shí),喚醒等待的線程 done.Set(); } } /// <summary> /// 等待所以線程執(zhí)行完畢 /// </summary> public void WaitAll() { done.WaitOne(); } /// <summary> /// 釋放對(duì)象占用的空間 /// </summary> public void Dispose() { ((IDisposable)done).Dispose(); } }
以上就是C#多線程等待所有子線程結(jié)束的示例的詳細(xì)內(nèi)容,更多關(guān)于c# 多線程等待子線程結(jié)束的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
C# UDP網(wǎng)絡(luò)通信的實(shí)現(xiàn)示例
UDP協(xié)議是互聯(lián)網(wǎng)上使用最廣泛的傳輸協(xié)議之一,具有簡(jiǎn)單、高效和不可靠的特點(diǎn),本文主要介紹了C# UDP網(wǎng)絡(luò)通信的實(shí)現(xiàn)示例,具有一定的參考價(jià)值,感興趣的可以了解一下2024-06-06通過(guò)?C#/VB.NET?代碼將?Excel?工作表拆分為單獨(dú)的文件
這篇文章主要介紹了通過(guò)C#/VB.NET代碼將Excel工作表拆分為單獨(dú)的文件,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下2022-09-09C#中實(shí)現(xiàn)PriorityQueue優(yōu)先級(jí)隊(duì)列的代碼
這篇文章主要介紹了C#中PriorityQueue優(yōu)先級(jí)隊(duì)列的實(shí)現(xiàn),構(gòu)造初始化這部分主要介紹關(guān)鍵的字段和方法,比較器的初始化以及堆的初始化,需要的朋友可以參考下2021-12-12C#實(shí)現(xiàn)打印與打印預(yù)覽功能的思路及代碼
這篇文章主要介紹了C#實(shí)現(xiàn)打印與打印預(yù)覽功能的思路及代碼,有需要的朋友可以參考一下2013-12-12C#實(shí)現(xiàn)繪制鼠標(biāo)的示例代碼
這篇文章主要為大家詳細(xì)介紹了如何利用C#實(shí)現(xiàn)繪制鼠標(biāo)的效果,文中的示例代碼講解詳細(xì),對(duì)我們學(xué)習(xí)C#有一定的幫助,感興趣的小伙伴可以跟隨小編一起了解一下2022-12-12C#ComboBox控件“設(shè)置 DataSource 屬性后無(wú)法修改項(xiàng)集合”的解決方法
這篇文章主要介紹了C#ComboBox控件“設(shè)置 DataSource 屬性后無(wú)法修改項(xiàng)集合”的解決方法 ,需要的朋友可以參考下2019-04-04