從前面的 CNestTaskScheduler 的使用方法中可以發現，采用嵌套任務調度，可以很方便地將一個大區間拆分成更多的小區間，將各個拆分后的區間放入分布式隊列中，然后各個線程再從分布式隊列中取出相應的區間進行處理。

對于一個 for 循環來說，通常處理的都是一個區間，因此也可以使用任務調度的方式將其拆分成更小的區間進行并行化執行。下面就利用嵌套任務調度的方法來實現一個 Parall_For 功能。

1. ??????? 區間的描述： CRange 類

要實現對區間的分拆功能，使用一個類 CRange 來描述區間。在實際情況中，區間通常可以由兩個整數表示區間開始和結束位置，也可以由兩個迭代器變量來表示區間開始和結束位置。不過 CRange 是一個抽象接口類，它并不定義區間的開始和結束位置，區間的開始和結束位置由繼承它的類去定義。 CRange 類用 C++ 定義如下：

class CRange {

protected:

??? CNestTaskScheduler ? * m_pTaskScheduler ;

public:

??? CRange (){};

??? CRange ( CNestTaskScheduler * p );

??? void SetTaskScheduler ( CNestTaskScheduler * p );

??? CNestTaskScheduler * GetTaskScheduler ();

?

??? virtual CRange * Split () = 0;

};

在 CRange 類中，最重要的一個接口是 Split() 接口，這個接口負責將一個區間拆分成兩個區間，一個區間繼續存放在原來的 CRange 對象中，另外一個區間存放在返回的 CRange 對象中。如果返回值為 NULL ，表明原來的區間不需要進行分拆。

CRange 類本身是一個接口類，用它主要是作為 Parallel_For() 函數的接口函數， Parallel_For() 函數的原型如下：

void Parallel_For(CRange *pRange );

由于 Split() 是一個純虛函數，因此傳給 Parallel_For() 函數的參數必須是一個繼續了 CRange 類的派生類的實例。

2. ??????? 對 CRange 對象的處理過程

對于每個 CRange 對象， Parallel_For() 中需要對它進行處理，處理是通過任務調度器中的任務入口函數來處理的，處理過程如下圖所示：

?

圖 4 ? CRange 對象的處理過程

上面的處理過程可以用 C++ 代碼實現如下：

/** ?? CRange 的任務處理入口函數

?

???????? @param ? void *pArg - 實際為一個 CRange 指針

???????? @return ? unsigned int WINAPI - CAPI_FAILED 表示失敗， CAPI_SUCCESS 表示成功 ??

*/

unsigned int WINAPI RangeProcessTask(void *pArg)

{

??? CRange * pRange = ( CRange *) pArg ;

?

??? if ( pRange == NULL )

??? {

??????? return CAPI_FAILED ;

??? }

?

??? CRange * pNewRange = pRange -> Split ();

??? if ( pNewRange == NULL )

??? {

??????? delete pRange ;

?????? ? return CAPI_SUCCESS ;

??? }

?

??? CNestTaskScheduler * pTaskSched = pRange -> GetTaskScheduler ();

?

??? pNewRange -> SetTaskScheduler ( pTaskSched );

?

??? TASK t1 , t2 ;

??? t1 . pArg = ( void *) pRange ;

??? t1 . func = RangeProcessTask ;

??? t2 . pArg = ( void *) pNewRange ;

?? ? t2 . func = RangeProcessTask ;

?

??? pTaskSched -> SpawnLocalTask ( t1 );

??? pTaskSched -> SpawnTask ( t2 );

?

??? return CAPI_SUCCESS ;

}

?

3. ? Parall_For 的處理流程

有了上面的 RangeProcessTask() 函數后，就可以用它作為嵌套任務調度器的任務入口函數，以實現 Parallel_For 功能。

在 Parallel_For() 中，主要實現對 CRange 對象的任務調度處理，需要將參數 pRange 作為根任務傳入到任務調度器中進行處理。

Parallel_For() 的處理過程如下：

?

圖 5 ? Parallel_For 的處理過程

Parallel_For() 的代碼如下：

/** ?? 并行 for 循的處理函數

??? 將一個 CRange 進行并行處理

?

???????? @param ? CRange *pRange - CRange 指針 ????

???????? @return ? void - 無 ?

*/

void Parallel_For(CRange *pRange )

{

??? CNestTaskScheduler ? * p = new CNestTaskScheduler ;

??? TASK ??? task ;

?

??? task . func = RangeProcessTask ;

??? task . pArg = pRange ;

?

??? pRange -> SetTaskScheduler ( p );

?

??? p -> BeginRootThread ( task );

?

??? delete p ;

}

用動態任務調度器實現Parallel_For