mysql ppl_浅析pplx库的设计与实现。
主要有三部分組成，threadpool，scheduler，task。
三者關系如上圖示，pplx只著重實現了task部分功能，scheduler跟threadpool只是簡略實現。
threadpool主要依賴boost.asio達到跨平臺的目標，cpprestsdk的 io操作同時也依賴這個threadpool。
pplx提供了兩個版本的scheduler，分別是
linux_scheduler依賴boost.asio.threadpool。
window_schedule依賴win32 ThreadPool。
默認的scheduler只是簡單地將work投遞到threadpool進行分派。
用戶可以根據自己需要，實現scheduler_interface，提供復雜的調度。
每個task關聯著一個_Task_impl實現體，一個_TaskCollection_t(喚醒事件，后繼任務隊列，這個隊列的任務之間的關系是并列的)，還有一個_PPLTaskHandle代碼執行單元。
task，并行執行的單位任務。通過scheduler將代碼執行單元調度到線程去執行。
task提供類似activeobject模式的功能，可以看作是一個future，通過get()同步阻塞等待執行結果。
task提供拓撲模型，通過then()創建后續task，并作為后繼執行任務。注意的是每個task可以接受不限數量的then()，這些后繼任務之間并不串行。例 task().then().then()串行，(task1.then(), task1.then())并行。一個任務在執行完成時，會將結果傳遞給它的所有直接后繼執行任務。
此外，task拓撲除了then()函數外，還可以在執行lambda中添加并行分支，然后可以在后繼任務中同步這些分支。
也就是說后繼任務同步原本task拓撲外的task拓撲才能繼續執行。
1 auto fork0 =
2 task([]()->task{
3 auto fork1 =
4 task([]()->task{
5 auto fork2 =
6 task([](){
7 // do your fork2 work
8
9 });
10 // do your fork1 work
11
12 returnfork2;
13 }).then([](task& frk2){ frk2.wait(); }); // will sync fork2
14 // do your fork0 work
15
16 returnfork1;
17 }).then([](task& frk1){ frk1.wait(); }); // will sync fork1
18 fork0.wait(); // sync fork1, fork2
上面的方式有一個問題，如果里層的fork先完成，將不要阻塞線程，但是外層fork先完成就不得不阻塞線程等待內層fork完成。
所以可以用when_all
task >([]()->task{
std::vector >forks;
forks.push_back( task([]() { /* do fork0 work */}) );
forks.push_back( task([]() { /* do fork1 work */}) );
forks.push_back( task([]() { /* do fork2 work */}) );
forks.push_back( task([]() { /* do fork3 work */}) );
returnwhen_all(std::begin(forks), std::end(forks));
}).then([](taskforks){
forks.wait();
}).wait();
通過上面的方式，也可以在lambda中，將其它task拓撲插入到你原來的task拓撲。
task結束，分兩種情況，完成以及取消。取消執行，只能在執行代碼時通過拋出異常，task并沒有提供取消的接口。任務在執行過程中拋出的異常，就會被task捕捉，并暫存異常，然后取消執行。異常在wait()時重新拋出。下面的時序分析可以看到全過程 。
值得注意的是，PPL中task原本的設計是的有Async與Inline之分的。在_Task_impl_base::_Wait()有一小段注釋說明
// If this task was created from a Windows Runtime async operation, do not attempt to inline it. The
// async operation will take place on a thread in the appropriate apartment Simply wait for the completed
// event to be set.
也就是task除了由scheduler調度到線程池分派執行，還可以強制在wait()函數內分派執行，后繼task也不必再次調度而可以在當前線程繼續分派執行。但是pplx沒有實現
class_TaskCollectionImpl
{
...
void_Cancel()
{
// No cancellation support
}
void_RunAndWait()
{
// No inlining support yet
_Wait();
}
下面是對task的時序分析。
開始的task創建_InitialTaskHandle， 一種只能用于始首的Handle執行單元。
通過then()添加的task，創建_ContinuationTaskHandle，(一種可以入鏈的后繼執行單元)，并暫存起來。
當一個任務在線程池中分派結束時，就會將所有通過then()添加到它結尾的后繼任務一次過向scheduler調度出去。
任務只能通過拋出異常從而自己中止執行，task并暫存異常(及錯誤信息)。
后繼任務被調度到線程池繼續分派執行。
這里順便討論一個開銷，在window版本中，每個task都有一個喚醒事件，使用事件內核對象，都要創建釋放一個內核對象，在高并行任務時，可能會消耗過多內核對象，消耗句柄數。
并且continuation后繼任務，在默認scheduler調度下，不會在同一線程中分派，所有后繼任務都會簡單投遞到線程池。由線程池去決定分派的線程。所以由then()串行起來的任務可能會由不同的線程順序分派，從而產生開銷。因為pplx并沒有實現 Inline功能，所有task都會視作Async重新調度到線程池。
總結
以上是生活随笔為你收集整理的mysql ppl_浅析pplx库的设计与实现。的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： ios跨线程通知_一种基于Metal、V
- 下一篇： ladder怎么读_ladder 是什么