C#多執行緒之Parallel中 類似於for的continue,break的方法
阿新 • • 發佈:2018-12-27
C#多執行緒之Parallel中 類似於for的continue,break的方法
好久沒寫東西了,終於找到點知識記錄下。。。
利用ParallelLoopState物件來控制Parallel.For函式的執行,ParallelLoopState物件是由執行時在後臺建立的:
Parallel.For(1, 100, (i, ParallelLoopState) =>{...});
這個物件有兩個函式,Stop和Break,可以分別用來控制Parallel.For的執行。
呼叫Stop,表示Parallel.For的執行立刻停止,無論其他執行單元是否達到停止的條件。而如果我們使用Break,則表示滿足條件的當前執行單元立刻停止,而對於其他執行單元,其中滿足停止條件也會通過Break停止,其他未滿足停止條件的則會繼續執行下去,從而全部執行完畢,自然停止。當所有執行單元停止後,Parallel.For函式才停止執行並退出。
break類似於for的continue,而stop就類似於for的break。
Parallel.For(1, 100, (i, ParallelLoopState) => { // 當某一個迴圈單元的數大於30, // 則跳出當前執行單元,等待其他執行單元結束 // 所有執行單元結束後退出Parallel.For的執行 if (i > 30) { // 跳出當前執行單元 ParallelLoopState.Break(); return;//不加return,可能會發生該程序資源未釋放。 } });
Parallel.For(1, 100, (i, ParallelLoopState) => { // 當某一個迴圈單元的數大於30, // 則停止Parallel.For的執行 if ( i > 30) { // 停止並退出Parallel.For ParallelLoopState.Stop(); return; } });
Parallel.ForEach中ParallelLoopState物件的函式也採用相同的方式呼叫:
Parallel.ForEach(elements, (element, ParallelLoopState) =>
{
if (element == "")
{
ParallelLoopState.Break();
return;
}
});