任務組取消

　　新的Beta1 PPL的其中一個功能就是可以取消正在運行中的任務組。在task_group類型上加入run 和 wait方法是一個新的cancel方法。還有一個相應的is_canceling方法讓你可以檢查在進程中是否完成取消。task_group_status列舉也有一個新的值叫做canceled，讓你檢查取消是否發生。以下的代碼展示了這些新的功能：

　　//declare tasks and run tasks

　　task_group tg;

　　tg.run(([]{printf("consoleWrite0/n");}));

　　tg.run(([]{printf("consoleWrite1/n");}));

　　//cancel tasks   tg.cancel();

　　//check whether tasks are being cancelled

　　bool taskGroupIsCanceling = tg.is_canceling();

　　//check on status of task group

　　task_group_status status = tg.wait();

　　if (status == completed){

　　printf("Tasks were completed successfully/n");

　　}

　　else if (status == canceled){

　　printf("Tasks were canceled during task execution/n");

　　}

　　else{

　　printf("An exception occured during task execution/n");

　　}

　　Combinable 類型

　　達到并行執行編程任務的最大利益的有效形式之一是工作在本地拷貝或是子數據上的每一個并行分支被處理，然后當處理結束后，將結果合并。這個形式可以最大限度的減少資源爭用，而且減少潛在的死鎖和當并行線程試圖更新相同的內存位置時所發生的數據不一致的問題。

　　使用這個形式沒有那么復雜，但是需要很乏味的為每一個使用進行手動編碼。為了簡化形式使用，Visual C++ 2010 Beta 1 添加了combinable模版類型。這個模版參數傳遞到combinable是每個任務將要操作的對象類型。這個類型必須有一個默認的構造器和一個拷貝構造器。通過使用local方法，每個任務訪問它自己的combinable管理資源的拷貝。 當所有任務結束后，通過使用combine 或是 combine_each方法，你可以將所有結果合并到一個結果集中。

　　以下的代碼用三個獨立的任務添加一些元素給一個矢量，然后用兩個合并的方法將結果合并成一個矢量。

　　//declare a combinable vector of integers

　　combinable< vector< int>> v;

　　//add an element to the vector using three separate tasks

　　parallel_invoke(   [&]{ v.local().push_back(1); },

　　[&]{ v.local().push_back(2); },

　　[&]{ v.local().push_back(3); }

　　);

　　//merge the task-local copies using combine_each

　　vector< int> result1;

　　v.combine_each(

　　[&](vector< int>& local)

　　{

　　result1.insert(result1.end(),

　　local.begin(), local.end());

　　}

　　);

　　//merge the task-local copies using combine

　　vector< int> result2 = v.combine(

　　[](vector< int> left, vector< int> right)->vector< int>{

　　left.insert(left.end(), right.begin(), right.end());

　　return left;

　　});

　　要注意的是在最后一行的代碼語句中的lambda表達式的明確返回類型聲明的使用。在lambda表達式中的兩個語句阻止編譯器正確推斷返回類型，所以需要手動聲明。

　　也可以為沒有默認構造器(或是在很多情況下默認構造器的使用是不合適的)的類型使用combinable，通過使用combinable構造器，它是采用了一個發生器功能創建了一些模版參數類型的對象。上面代碼的前面幾行是使用超載發生器構造器而重新編寫的。在這種情況下，發生器功能返回已經包含一個元素的矢量。

　　//declare a combinable vector of integers

　　inable< vector< int>> v([]{return vector< int>(1, 0);});

　　同步

　　Combinable的使用取決于不需要作用在其他任務上的結果的任務。在多重任務的情況下需要分享一個對象，你必須使用更傳統的同步策略。PLL本身帶有三個同步原語——critical_section, reader_writer_lock 和 event。critical_section鎖住內存位置防止沒有鎖的所有任務的訪問。對于內存位置將有很多同時讀取者和少數編寫者，更優化的reader_writer_lock是可用的，允許多重讀取者獲取鎖并同時訪問內存位置。最后的原語是event，用于在任務和線程之間發信號。

　　同步原語在concrt.h標題文件(是PPL的基本標題文件，包含在ppl.h中)中被定義。在concrt.h中定義的大多數類型的目標是圖書館作者，而不是應用程序的開發者，但是任何對深層并行開發感興趣的人都可以自由的調查和使用恰當的來自暴露在外的類型的功能。

　　critical_section類型的API是非常簡單的;你使用一個blocking lock方法來獲取這個鎖，non-blocking try_lock會試圖去獲取這個鎖，如果它可用的話，而且unlock會釋放一個鎖住的critical_section。

　　reader_writer_lock是有一點點的復雜。它添加了兩個方法，lock_read 和try_lock_read，可以支持獲取一個reader lock。Unlock方法和critical_section是一樣的，而且將釋放恰當的基于鎖類型的鎖。

　　最后的同步原語是event，這是手動復位事件(即：事件保持設置直到用外部代碼進行手動復位)。代碼可以通過調用實例wait方法(也是支持一個可選的timeout值)，等待一個單一事件被設置。當沒有timeout被定義的時候，等待的時間是無限的。你可以等待多重事件，通過使用靜態wait_for_multiple，它接受C-style的event pointers。wait_for_multiple方法等待一個單一事件或是所有的事件傳遞到方法調用。以下的代碼等待這兩個事件被設置：

　　event* events[2];

　　events[0] = new event();

　　events[1] = new event();

　　parallel_invoke(

　　[&]{ events[0]->set(); },

　　[&]{ events[1]->set(); }

　　);

　　bool waitForAllEvents = true;

　　event::wait_for_multiple(events, 2, waitForAllEvents);

　　當同時執行很多任務的時候，處理狀態管理是非常艱巨的工作。PPL提供對狀態管理的一種形式的支持，就是每個線程在本地版本的分享對象上進行操作，在程序結束的時候將這些結果合并起來。對于分離狀態管理的情況是不恰當的，PPL以critical_section, reader_writer_lock 和 event的形式提供傳統的同步原語。