如何添加網(wǎng)站 ico圖標(biāo),建e室內(nèi)設(shè)計網(wǎng)極簡案例,建立主題網(wǎng)站的順序是,移動互聯(lián)網(wǎng)開發(fā)試卷1.并行循環(huán)基本語法 2.并行循環(huán)原理 3.并行循環(huán)中的異常處理 4.停止 5.中斷1.并行循環(huán)基本語法 C#中的Parallel類(位于 System.Threading.Tasks 命名空間)是.NET提供的并行編程核心工具, 旨在簡化數(shù)據(jù)并行和 任務(wù)并行開發(fā), 充分利用多核CPU資源, 避免手…1.并行循環(huán)基本語法2.并行循環(huán)原理3.并行循環(huán)中的異常處理4.停止5.中斷1.并行循環(huán)基本語法C#中的Parallel類(位于 System.Threading.Tasks 命名空間)是.NET提供的并行編程核心工具,旨在簡化數(shù)據(jù)并行和任務(wù)并行開發(fā),充分利用多核CPU資源,避免手動管理線程的復(fù)雜度;它的核心目標(biāo)是將串行執(zhí)行的任務(wù)(如循環(huán)、獨立方 法)自動拆分為多個并行任務(wù), 復(fù)用線程池線程執(zhí)行,提升CPU密集型任務(wù)的效率1).Parallel.For:并行版for循環(huán) 替代傳統(tǒng)的串行for循環(huán),將循環(huán)迭代拆分為多個并行任務(wù)執(zhí)行,適合遍歷連續(xù)整數(shù)范圍的場景usingSystem;usingSystem.Threading.Tasks;classParallelForDemo{staticvoidMain(){int[]datanewint[10000];// 初始化數(shù)組串行for(inti0;idata.Length;i)data[i]i;// 并行遍歷數(shù)組每個元素乘以2CPU密集型Parallel.For(0,data.Length,i{data[i]*2;// 打印線程ID驗證并行不同迭代可能在不同線程執(zhí)行if(i%10000)Console.WriteLine($迭代{i}線程ID:{System.Threading.Thread.CurrentThread.ManagedThreadId});});Console.WriteLine($第一個元素:{data[0]}, 最后一個元素:{data[9999]});}}2).Parallel.Foreach:并行版foreach替代傳統(tǒng)的串行foreach,遍歷實現(xiàn)了IEnumerable的集合(如 List、數(shù)組、Dictionary),適合遍歷非連續(xù)集合的場景usingSystem;usingSystem.Collections.Generic;usingSystem.Threading.Tasks;classParallelForEachDemo{staticvoidMain(){ListstringfruitsnewListstring{Apple,Banana,Orange,Grape,Mango};// 并行遍歷集合處理每個元素Parallel.ForEach(fruits,fruit{stringupperFruitfruit.ToUpper();Console.WriteLine($處理結(jié)果:{upperFruit}(線程ID:{System.Threading.Thread.CurrentThread.ManagedThreadId}));});}}3).Parallel.Invoke:并行執(zhí)行多個獨立的任務(wù) 用于一次性執(zhí)行多個無返回值、無參數(shù)的獨立方法,適合多任務(wù)并行執(zhí)行場景usingSystem;usingSystem.Threading.Tasks;classParallelDemo{staticvoidMain(){// 并行執(zhí)行兩個獨立方法無需關(guān)注執(zhí)行順序Parallel.Invoke(()CalculateSum(1,1000000),// 任務(wù)1計算1到100萬的和()PrintMessage(Hello Parallel)// 任務(wù)2打印信息);Console.WriteLine(所有并行任務(wù)執(zhí)行完成);}staticvoidCalculateSum(intstart,intend){longsum0;for(intistart;iend;i)sumi;Console.WriteLine($Sum:{sum}(線程ID:{System.Threading.Thread.CurrentThread.ManagedThreadId}));}staticvoidPrintMessage(stringmsg){Console.WriteLine(${msg}(線程ID:{System.Threading.Thread.CurrentThread.ManagedThreadId}));}}2.并行循環(huán)原理并行循環(huán)的原理是分塊減少調(diào)度開銷和線程復(fù)用避免創(chuàng)建成本a.數(shù)據(jù)分區(qū)(分塊)—— 不是均分,而是動態(tài)按需分塊并行循環(huán)首先會將待處理的數(shù)據(jù)集(比如0~999的迭代、List集合)拆分為若干分區(qū)(Chunk),但不是靜態(tài)均分,而是由.NET 的分區(qū)器(Partitioner)動態(tài)調(diào)整-靜態(tài)分區(qū)(適用于迭代執(zhí)行時間均勻的場景)啟動前將數(shù)據(jù)均分(比如1000個迭代,4核CPU拆成4塊,每塊250個),優(yōu)點是分區(qū)開銷小,缺點是如果某塊迭代執(zhí)行慢(比如 處理大數(shù)據(jù)),會導(dǎo)致有的線程閑、有的線程忙(負(fù)載不均)-動態(tài)分區(qū)(Parallel默認(rèn)策略)不提前均分,而是按需分配小批次(比如每次分配10~20個迭代為一個小塊),線程處理完當(dāng)前小塊后,立刻去領(lǐng)取下一 個小塊,直到所有數(shù)據(jù)處理完 ?優(yōu)勢:解決負(fù)載不均問題(比如某塊迭代執(zhí)行慢,其他線程不會等,繼續(xù)領(lǐng)新塊),最大化CPU利用率 b.線程調(diào)度 —— 復(fù)用線程池,而非創(chuàng)建新線程 Parallel循環(huán)不會為每個塊創(chuàng)建新線程,而是復(fù)用.NET線程池(ThreadPool)的工作線程 線程池默認(rèn)有最小線程數(shù)( CPU 核心數(shù))和最大線程數(shù)(默認(rèn) 1023),Parallel會向線程池請求線程,而非手動創(chuàng)建(避 免線程創(chuàng)建/銷毀的昂貴開銷)并行度(同時運行的線程數(shù))默認(rèn)由.NET根據(jù)CPU核心數(shù)、當(dāng)前系統(tǒng)負(fù)載動態(tài)調(diào)整c.執(zhí)行與線程復(fù)用 —— 一個線程處理多個塊 線程與塊不是一一綁定,一個線程處理完一個小塊后,不會銷毀,而是立刻從分區(qū)器領(lǐng)取下一個小塊繼續(xù)執(zhí)行;直到所有小塊 處理完畢,線程才會回到線程池,等待后續(xù)復(fù)用 d.收尾 —— 合并結(jié)果(如有)處理異常-若有共享結(jié)果(比如累加求和),需通過原子操作/鎖-若多個塊拋出異常,會封裝為AggregateException統(tǒng)一拋出3.并行循環(huán)中的異常處理并行循環(huán)中的異常不會立即停止本次迭代,而是停止新的迭代;將trycatch放在并行循環(huán)的外面usingSystem;usingSystem.Threading.Tasks;classParallelExceptionBasic{staticvoidMain(){try{// 并行循環(huán)迭代1和3拋出不同異常Parallel.For(0,5,i{Console.WriteLine($迭代{i}開始執(zhí)行);if(i1)thrownewArgumentException($參數(shù)非法迭代{i});// 業(yè)務(wù)異常1if(i3)thrownewDivideByZeroException($除零錯誤迭代{i});// 業(yè)務(wù)異常2Thread.Sleep(100);// 模擬業(yè)務(wù)邏輯});}// 必須捕獲AggregateException而非單個異常catch(AggregateExceptionaggregateEx){Console.WriteLine($捕獲到{aggregateEx.InnerExceptions.Count}個異常);// 遍歷所有內(nèi)部異常逐個處理foreach(varinnerExinaggregateEx.InnerExceptions){// 區(qū)分異常類型針對性處理switch(innerEx){caseArgumentExceptionargEx:Console.WriteLine($參數(shù)異常{argEx.Message});break;caseDivideByZeroExceptiondivEx:Console.WriteLine($除零異常{divEx.Message});break;default:Console.WriteLine($未知異常{innerEx.Message});break;}}}// 可選捕獲其他非并行循環(huán)的異常比如參數(shù)錯誤catch(Exceptionex){Console.WriteLine($非聚合異常{ex.Message});}}}4.停止Stop是緊急停止—— 不管索引順序,新迭代全不調(diào)度,已開始的迭代也建議盡快退出(而非執(zhí)行完)usingSystem;usingSystem.Threading.Tasks;classParallelBreakVsStop{staticvoidMain(){Console.WriteLine( 測試 Stop() );varresultParallel.For(0,10,(i,state){Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 迭代{i}開始執(zhí)行);if(i5){Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 觸發(fā) Stop());state.Stop();}// 關(guān)鍵檢查IsStopped盡快退出Stop的核心if(state.IsStopped){Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 迭代{i}檢測到Stop立即退出);return;// 不執(zhí)行后續(xù)的500ms延遲}// 若沒檢測IsStopped才會執(zhí)行完500ms這是你覺得沒區(qū)別的常見原因Task.Delay(500).Wait();Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 迭代{i}執(zhí)行完成);});Console.WriteLine($循環(huán)是否完成{result.IsCompleted});Console.WriteLine($最低中斷迭代索引{result.LowestBreakIteration??-1} );}}5.中斷Break是有序中斷—— 保證中斷點前的迭代全執(zhí)行完,只停后面的usingSystem;usingSystem.Threading.Tasks;classParallelBreakVsStop{staticvoidMain(){Console.WriteLine( 測試 Break() );varresultParallel.For(0,10,(i,state){Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 迭代{i}開始執(zhí)行);if(i5){Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 觸發(fā) Break());state.Break();}// 模擬耗時500ms的業(yè)務(wù)邏輯Break下會執(zhí)行完Task.Delay(500).Wait();Console.WriteLine($[{DateTime.Now:HH:mm:ss.fff}] 迭代{i}執(zhí)行完成);});Console.WriteLine($循環(huán)是否完成{result.IsCompleted});Console.WriteLine($最低中斷迭代索引{result.LowestBreakIteration} );}}