1. 程式人生 > >C#多執行緒之Parallel中 類似於for的continue,break的方法

C#多執行緒之Parallel中 類似於for的continue,break的方法

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;
                }
            });