本文來(lái)自CSDN博客，轉(zhuǎn)載請(qǐng)標(biāo)明出處：http://blog.csdn.net/hionceshine/archive/2008/11/25/3362669.aspx
摘自《Networking Programming for Microsoft Windows》第八章
“完成端口”模型是迄今為止最為復(fù)雜的一種I/O模型。然而，假若一個(gè)應(yīng)用程序同時(shí)需要管理為數(shù)眾多的套接字，那么采用這種模型，往往可以達(dá)到最佳的系統(tǒng)性能！
從本質(zhì)上說(shuō)，完成端口模型要求我們創(chuàng)建一個(gè)Win32完成端口對(duì)象，通過(guò)指定數(shù)量的線程，對(duì)重疊I/O請(qǐng)求進(jìn)行管理，以便為已經(jīng)完成的重疊I/O請(qǐng)求提供服務(wù)。
使用這種模型之前，首先要?jiǎng)?chuàng)建一個(gè)I/O完成端口對(duì)象，用它面向任意數(shù)量的套接字句柄，管理多個(gè)I/O請(qǐng)求。要做到這一點(diǎn)，需要調(diào)用CreateCompletionPort函數(shù)。
該函數(shù)定義如下：
HANDLE CreateIoCompletionPort(
HANDLE FileHandle,
HANDLE ExistingCompletionPort,
ULONG_PTR CompletionKey,
DWORD NumberOfConcurrentThreads
);
在我們深入探討其中的各個(gè)參數(shù)之前，首先要注意該函數(shù)實(shí)際用于兩個(gè)明顯有別的目的：
1. 用于創(chuàng)建一個(gè)完成端口對(duì)象。
2. 將一個(gè)句柄同完成端口關(guān)聯(lián)到一起。
最開(kāi)始創(chuàng)建一個(gè)完成端口時(shí)，唯一感興趣的參數(shù)便是NumberOfConcurrentThreads（并發(fā)線程的數(shù)量）；前面三個(gè)參數(shù)都會(huì)被忽略。NumberOfConcurrentThreads參數(shù)的特殊之處在于，它定義了在一個(gè)完成端口上，同時(shí)允許執(zhí)行的線程數(shù)量。理想情況下，我們希望每個(gè)處理器各自負(fù)責(zé)一個(gè)線程的運(yùn)行，為完成端口提供服務(wù)，避免過(guò)于頻繁的線程“場(chǎng)景”切換。若將該參數(shù)設(shè)為0，表明系統(tǒng)內(nèi)安裝了多少個(gè)處理器，便允許同時(shí)運(yùn)行多少個(gè)線程！可用下述代碼創(chuàng)建一個(gè)I/O完成端口：
hIOCP = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 0);
該語(yǔ)句的作用是返回一個(gè)句柄，在為完成端口分配了一個(gè)套接字句柄后，用來(lái)對(duì)那個(gè)端口進(jìn)行標(biāo)定（引用）。
一、工作者線程與完成端口
成功創(chuàng)建一個(gè)完成端口后，便可開(kāi)始將套接字句柄與對(duì)象關(guān)聯(lián)到一起。但在關(guān)聯(lián)套接字之前，首先必須創(chuàng)建一個(gè)或多個(gè)“工作者線程”，以便在I/O請(qǐng)求投遞給完成端口對(duì)象后，為完成端口提供服務(wù)。在這個(gè)時(shí)候，大家或許會(huì)覺(jué)得奇怪，到底應(yīng)創(chuàng)建多少個(gè)線程，以便為完成端口提供服務(wù)呢？這實(shí)際正是完成端口模型顯得頗為“復(fù)雜”的一個(gè)方面，因?yàn)榉?wù)I/O請(qǐng)求所需的數(shù)量取決于應(yīng)用程序的總體設(shè)計(jì)情況。在此要記住的一個(gè)重點(diǎn)在于，在我們調(diào)用CreateIoCompletionPort時(shí)指定的并發(fā)線程數(shù)量，與打算創(chuàng)建的工作者線程數(shù)量相比，它們代表的并非同一件事情。早些時(shí)候，我們?cè)ㄗh大家用CreateIoCompletionPort函數(shù)為每個(gè)處理器
都指定一個(gè)線程（處理器的數(shù)量有多少，便指定多少線程）以避免由于頻繁的線程“場(chǎng)景”交換活動(dòng)，從而影響系統(tǒng)的整體性能。CreateIoCompletionPort函數(shù)的NumberOfConcurrentThreads參數(shù)明確指示系統(tǒng)：在一個(gè)完成端口上，一次只允許n個(gè)工作者線程運(yùn)行。假如在完成端口上創(chuàng)建的工作者線程數(shù)量超出n個(gè)，那么在同一時(shí)刻，最多只允許n個(gè)線程運(yùn)行。但實(shí)際上，在一段較短的時(shí)間內(nèi)，系統(tǒng)有可能超過(guò)這個(gè)值，但很快便會(huì)把它減少至事先在CreateIoCompletionPort函數(shù)中設(shè)定的值。那么，為何實(shí)際創(chuàng)建的工作者線程數(shù)量有時(shí)要比CreateIoCompletionPort函數(shù)設(shè)定的多一些呢？這樣做有必要嗎？如先前所述，這主要取決于
應(yīng)用程序的總體設(shè)計(jì)情況。假定我們的某個(gè)工作者線程調(diào)用了一個(gè)函數(shù)，比如Sleep或WaitForSingleObject，但卻進(jìn)入了暫停（鎖定或掛起）狀態(tài)，那么允許另一個(gè)線程代替它的位置。換言之，我們希望隨時(shí)都能執(zhí)行盡可能多的線程；當(dāng)然，最大的線程數(shù)量是事先在CreateIoCompletionPort調(diào)用里設(shè)定好的。這樣一來(lái)，假如事先預(yù)計(jì)到自己的線程有可能暫時(shí)處于停頓狀態(tài)，那么最好能夠創(chuàng)建比CreateIoCompletionPort的NumberOfConcurrentThreads參數(shù)的值多的線程，以便到時(shí)候充分發(fā)揮系統(tǒng)的潛力。一旦在完成端口上擁有足夠多的工作者線程來(lái)為I/O請(qǐng)求提供服務(wù)，便可著手將套接字句柄同完成端口關(guān)聯(lián)到一起。這要求我們?cè)谝粋€(gè)現(xiàn)有的完成端口上，調(diào)用CreateIoCompletionPort函數(shù)，同時(shí)為前三個(gè)參數(shù)——FileHandle，ExistingCompletionPort和CompletionKey——提供套接字的信息。其中， FileHandle參數(shù)指定一個(gè)要同完成端口關(guān)聯(lián)在一起的套接字句柄。ExistingCompletionPort參數(shù)指定的是一個(gè)現(xiàn)有的完成端口。CompletionKey（完成鍵）參數(shù)則指定要與某個(gè)特定套接字句柄關(guān)聯(lián)在一起的“單句柄數(shù)據(jù)”；在這個(gè)參數(shù)中，應(yīng)用程序可保存與一個(gè)套接字對(duì)應(yīng)的任意類型的信息。之所以把它叫作“單句柄數(shù)據(jù)”，是由于它只對(duì)
應(yīng)著與那個(gè)套接字句柄關(guān)聯(lián)在一起的數(shù)據(jù)。可將其作為指向一個(gè)數(shù)據(jù)結(jié)構(gòu)的指針，來(lái)保存套接字句柄；在那個(gè)結(jié)構(gòu)中，同時(shí)包含了套接字的句柄，以及與那個(gè)套接字有關(guān)的其他信息。
根據(jù)我們到目前為止學(xué)到的東西，首先來(lái)構(gòu)建一個(gè)基本的應(yīng)用程序框架。下面闡述了如何使用完成端口模型，來(lái)開(kāi)發(fā)一個(gè)ECHO服務(wù)器應(yīng)用。在這個(gè)程序中，我們基本上按下述步驟行事：
1) 創(chuàng)建一個(gè)完成端口。第四個(gè)參數(shù)保持為0，指定在完成端口上，每個(gè)處理器一次只允許執(zhí)行一個(gè)工作者線程。
2) 判斷系統(tǒng)內(nèi)到底安裝了多少個(gè)處理器。
3) 創(chuàng)建工作者線程，根據(jù)步驟2)得到的處理器信息，在完成端口上，為已完成的I/O請(qǐng)求提供服務(wù)。
4) 準(zhǔn)備好一個(gè)監(jiān)聽(tīng)套接字，在端口5150上監(jiān)聽(tīng)進(jìn)入的連接請(qǐng)求。
5) 使用accept函數(shù)，接受進(jìn)入的連接請(qǐng)求。
6) 創(chuàng)建一個(gè)數(shù)據(jù)結(jié)構(gòu)，用于容納“單句柄數(shù)據(jù)”，同時(shí)在結(jié)構(gòu)中存入接受的套接字句柄。
7) 調(diào)用CreateIoCompletionPort，將自accept返回的新套接字句柄同完成端口關(guān)聯(lián)到一起。通過(guò)完成鍵（CompletionKey）參數(shù)，將單句柄數(shù)據(jù)結(jié)構(gòu)傳遞給CreateIoCompletionPort。
8) 開(kāi)始在已接受的連接上進(jìn)行I/O操作。在此，我們希望通過(guò)重疊I/O機(jī)制，在新建的套接字上投遞一個(gè)或多個(gè)異步WSARecv或WSASend請(qǐng)求。這些I/O請(qǐng)求完成后，一個(gè)工作者線程會(huì)為I/O請(qǐng)求提供服務(wù)，同時(shí)繼續(xù)處理未來(lái)的I/O請(qǐng)求，稍后便會(huì)在步驟3 )指定的工作者例程中，體驗(yàn)到這一點(diǎn)。
9) 重復(fù)步驟5 ) ~ 8 )，直至服務(wù)器中止。
二、完成端口和重疊I/O
將套接字句柄與一個(gè)完成端口關(guān)聯(lián)在一起后，便可以套接字句柄為基礎(chǔ)，投遞發(fā)送與接收請(qǐng)求，開(kāi)始對(duì)I/O請(qǐng)求的處理。接下來(lái)，可開(kāi)始依賴完成端口，來(lái)接收有關(guān)I/O操作完成情況的通知。從本質(zhì)上說(shuō)，完成端口模型利用了Win32重疊I/O機(jī)制。在這種機(jī)制中，象WSASend和WSARecv這樣的Winsock API調(diào)用會(huì)立即返回。此時(shí)，需要由我們的應(yīng)用程序負(fù)責(zé)在以后的某個(gè)時(shí)間，通過(guò)一個(gè)OVERLAPPED結(jié)構(gòu)，來(lái)接收調(diào)用的結(jié)果。在完成端口模型中，要想做到這一點(diǎn)，需要使用GetQueuedCompletionStatus（獲取排隊(duì)完成狀態(tài)）函數(shù)，讓一個(gè)或多個(gè)工作者線程在完成端口上等待。該函數(shù)的定義如下：
BOOL GetQueuedCompletionStatus(
HANDLE CompletionPort,
LPDWORD lpNumberOfBytes,
PULONG_PTR lpCompletionKey,
LPOVERLAPPED* lpOverlapped,
DWORD dwMilliseconds
);
其中，CompletionPort參數(shù)對(duì)應(yīng)于要在上面等待的完成端口。lpNumberOfBytes參數(shù)負(fù)責(zé)在完成了一次I/O操作后（如WSASend或WSARecv），接收實(shí)際傳輸?shù)淖止?jié)數(shù)。lpCompletionKey參數(shù)為原先傳遞進(jìn)入CreateIoCompletionPort函數(shù)的套接字返回“單句柄數(shù)據(jù)”。如我們?cè)缦人觯蠹易詈脤⑻捉幼志浔４嬖谶@個(gè)“鍵”（Key）中。lpOverlapped參數(shù)用于接收完成的I/O操作的重疊結(jié)果。這實(shí)際是一個(gè)相當(dāng)重要的參數(shù)，因?yàn)榭捎盟@取每個(gè)I/O操作的數(shù)據(jù)。而最后一個(gè)參數(shù)，dwMilliseconds，用于指定調(diào)用者希望等待一個(gè)完成數(shù)據(jù)包在完成端口上出現(xiàn)的時(shí)間。假如將其設(shè)為INFINITE，調(diào)用會(huì)無(wú)休止地等待下去。
三、單句柄數(shù)據(jù)和單I/O操作數(shù)據(jù)
一個(gè)工作者線程從GetQueuedCompletionStatus這個(gè)API調(diào)用接收到I/O完成通知后，在lpCompletionKey和lpOverlapped參數(shù)中，會(huì)包含一些必要的套接字信息。利用這些信息，可通過(guò)完成端口，繼續(xù)在一個(gè)套接字上的I/O處理。通過(guò)這些參數(shù)，可獲得兩方面重要的套接字?jǐn)?shù)據(jù)：?jiǎn)尉浔鷶?shù)據(jù)，以及單I/O操作數(shù)據(jù)。其中，lpCompletionKey參數(shù)包含了“單句柄數(shù)據(jù)”，因?yàn)樵谝粋€(gè)套接字首次與完成端口關(guān)聯(lián)到一起的時(shí)候，那些數(shù)據(jù)便與一個(gè)特定的套接字句柄對(duì)應(yīng)起來(lái)了。這些數(shù)據(jù)正是我們?cè)谶M(jìn)行CreateIoCompletionPort API調(diào)用的時(shí)候，通過(guò)CompletionKey參數(shù)傳遞的。如早先所述，應(yīng)用程序可通過(guò)該參數(shù)傳遞任意類型的數(shù)據(jù)。通常情況下，應(yīng)用程序會(huì)將與I/O請(qǐng)求有關(guān)的套接字句柄保存在這里。lpOverlapped參數(shù)則包含了一個(gè)OVERLAPPED結(jié)構(gòu)，在它后面跟隨“單I/O操作數(shù)據(jù)”。我們的工作者線程處理一個(gè)完成數(shù)據(jù)包時(shí)（將數(shù)據(jù)原封不動(dòng)打轉(zhuǎn)回去，接受連接，投遞另一個(gè)線程，等等），這些信息是它必須要知道的。單I/O操作數(shù)據(jù)可以是追加到一個(gè)OVERLAPPED結(jié)構(gòu)末尾的、任意數(shù)量的字節(jié)。假如一個(gè)函數(shù)要求用到一個(gè)OVERLAPPED結(jié)構(gòu)，我們便必須將這樣的一個(gè)結(jié)構(gòu)傳遞進(jìn)去，以滿足它的要求。要想做到這一點(diǎn)，一個(gè)簡(jiǎn)單的方法是定義一個(gè)結(jié)構(gòu)，然后將OVERLAPPED結(jié)構(gòu)作為新結(jié)構(gòu)的第一個(gè)元素使用。舉個(gè)例子來(lái)說(shuō)，可定義下述數(shù)據(jù)結(jié)構(gòu)，實(shí)現(xiàn)對(duì)單I/O操作數(shù)據(jù)的管理：
typedef struct
{
OVERLAPPED Overlapped;
WSABUF DataBuf;
CHAR Buffer[DATA_BUFSIZE];
BOOL OperationType;
}PER_IO_OPERATION_DATA
該結(jié)構(gòu)演示了通常要與I/O操作關(guān)聯(lián)在一起的某些重要數(shù)據(jù)元素，比如剛才完成的那個(gè)I/O操作的類型（發(fā)送或接收請(qǐng)求）。在這個(gè)結(jié)構(gòu)中，我們認(rèn)為用于已完成I/O操作的數(shù)據(jù)緩沖區(qū)是非常有用的。要想調(diào)用一個(gè)Winsock API函數(shù)，同時(shí)為其分配一個(gè)OVERLAPPED結(jié)構(gòu)，既可將自己的結(jié)構(gòu)“造型”為一個(gè)OVERLAPPED指針，亦可簡(jiǎn)單地撤消對(duì)結(jié)構(gòu)中的OVERLAPPED元素的引用。如下例所示：
PER_IO_OPERATION_DATA PerIoData;
// 可像下面這樣調(diào)用一個(gè)函數(shù)
WSARecv(socket, ..., (OVERLAPPED *)&PerIoData);
// 或像這樣
WSARecv(socket, ..., &(PerIoData.Overlapped));
在工作線程的后面部分，等GetQueuedCompletionStatus函數(shù)返回了一個(gè)重疊結(jié)構(gòu)（和完成鍵）后，便可通過(guò)撤消對(duì)OperationType成員的引用，調(diào)查到底是哪個(gè)操作投遞到了這個(gè)句柄之上（只需將返回的重疊結(jié)構(gòu)造型為自己的PER_IO_OPERATION_DATA結(jié)構(gòu)）。對(duì)單I/O操作數(shù)據(jù)來(lái)說(shuō)，它最大的一個(gè)優(yōu)點(diǎn)便是允許我們?cè)谕粋€(gè)句柄上，同時(shí)管理多個(gè)I/O操作（讀/寫，多個(gè)讀，多個(gè)寫，等等）。大家此時(shí)或許會(huì)產(chǎn)生這樣的疑問(wèn)：在同一個(gè)套接字上，真的有必要同時(shí)投遞多個(gè)I/O操作嗎？答案在于系統(tǒng)的“伸縮性”，或者說(shuō)“擴(kuò)展能力”。例如，假定我們的機(jī)器安裝了多個(gè)中央處理器，每個(gè)處理器都在運(yùn)行一個(gè)工作者線程，那么在同一個(gè)時(shí)
候，完全可能有幾個(gè)不同的處理器在同一個(gè)套接字上，進(jìn)行數(shù)據(jù)的收發(fā)操作。
最后要注意的一處細(xì)節(jié)是如何正確地關(guān)閉I/O完成端口—特別是同時(shí)運(yùn)行了一個(gè)或多個(gè)線程，在幾個(gè)不同的套接字上執(zhí)行I/O操作的時(shí)候。要避免的一個(gè)重要問(wèn)題是在進(jìn)行重疊I/O操作的同時(shí)，強(qiáng)行釋放一個(gè)OVERLAPPED結(jié)構(gòu)。要想避免出現(xiàn)這種情況，最好的辦法是針對(duì)每個(gè)套接字句柄，調(diào)用closesocket函數(shù)，任何尚未進(jìn)行的重疊I/O操作都會(huì)完成。一旦所有套接字句柄都已關(guān)閉，便需在完成端口上，終止所有工作者線程的運(yùn)行。要想做到這一點(diǎn)， 需要使用PostQueuedCompletionStatus函數(shù)，向每個(gè)工作者線程都發(fā)送一個(gè)特殊的完成數(shù)據(jù)包。該函數(shù)會(huì)指示每個(gè)線程都“立即結(jié)束并退出”。下面是PostQueuedCompletionStatus函數(shù)的定義：
BOOL PostQueuedCompletionStatus(
HANDLE CompletionPort,
DWORD dwNumberOfBytesTransferred,
ULONG_PTR dwCompletionKey,
LPOVERLAPPED lpOverlapped
);
其中，CompletionPort參數(shù)指定想向其發(fā)送一個(gè)完成數(shù)據(jù)包的完成端口對(duì)象。而就dwNumberOfBytesTransferred、dwCompletionKey和lpOverlapped這三個(gè)參數(shù)來(lái)說(shuō)，每一個(gè)都允許我們指定一個(gè)值，直接傳遞給GetQueuedCompletionStatus函數(shù)中對(duì)應(yīng)的參數(shù)。這樣一來(lái)，一個(gè)工作者線程收到傳遞過(guò)來(lái)的三個(gè)GetQueuedCompletionStatus函數(shù)參數(shù)后，便可根據(jù)由這三個(gè)參數(shù)的某一個(gè)設(shè)置的特殊值，決定何時(shí)應(yīng)該退出。例如，可用dwCompletionPort參數(shù)傳遞0值，而一個(gè)工作者線程會(huì)將其解釋成中止指令。一旦所有工作者線程都已關(guān)閉，便可使用CloseHandle函數(shù)，關(guān)閉完成端口，最終安全退出程序。
注：CreateIoCompletionPort ，PostQueuedCompletionStatus ，GetQueuedCompletionStatus 等函數(shù)的用法說(shuō)明。
Platform SDK: Storage
I/O Completion Ports
I/O completion ports are the mechanism by which an application uses a pool of threads that was created when the application was started to process asynchronous I/O requests. These threads are created for the sole purpose of processing I/O requests. Applications that process many concurrent asynchronous I/O requests can do so more quickly and efficiently by using I/O completion ports than by using creating threads at the time of the I/O request.
I/O完成端口(s)是一種機(jī)制，通過(guò)這個(gè)機(jī)制，應(yīng)用程序在啟動(dòng)時(shí)會(huì)首先創(chuàng)建一個(gè)線程池，然后該應(yīng)用程序使用線程池處理異步I/O請(qǐng)求。這些線程被創(chuàng)建的唯一目的就是用于處理I/O請(qǐng)求。對(duì)于處理大量并發(fā)異步I/O請(qǐng)求的應(yīng)用程序來(lái)說(shuō)，相比于在I/O請(qǐng)求發(fā)生時(shí)創(chuàng)建線程來(lái)說(shuō)，使用完成端口(s)它就可以做的更快且更有效率。
The CreateIoCompletionPort function associates an I/O completion port with one or more file handles. When an asynchronous I/O operation started on a file handle associated with a completion port is completed, an I/O completion packet is queued to the port. This can be used to combine the synchronization point for multiple file handles into a single object.
CreateIoCompletionPort函數(shù)會(huì)使一個(gè)I/O完成端口與一個(gè)或多個(gè)文件句柄發(fā)生關(guān)聯(lián)。當(dāng)與一個(gè)完成端口相關(guān)的文件句柄上啟動(dòng)的異步I/O操作完成時(shí)，一個(gè)I/O完成包就會(huì)進(jìn)入到該完成端口的隊(duì)列中。對(duì)于多個(gè)文件句柄來(lái)說(shuō)，就可以把這些多個(gè)文件句柄合并成一個(gè)單獨(dú)的對(duì)象，這個(gè)可以被用來(lái)結(jié)合同步點(diǎn)？
A thread uses the GetQueuedCompletionStatus function to wait for a completion packet to be queued to the completion port, rather than waiting directly for the asynchronous I/O to complete. Threads that block their execution on a completion port are released in last-in-first-out (LIFO) order. This means that when a completion packet is queued to the completion port, the system releases the last thread to block its execution on the port.
調(diào)用GetQueuedCompletionStatus函數(shù)，某個(gè)線程就會(huì)等待一個(gè)完成包進(jìn)入到完成端口的隊(duì)列中，而不是直接等待異步I/O請(qǐng)求完成。線程（們）就會(huì)阻塞于它們的運(yùn)行在完成端口（按照后進(jìn)先出隊(duì)列順序的被釋放）。這就意味著當(dāng)一個(gè)完成包進(jìn)入到完成端口的隊(duì)列中時(shí)，系統(tǒng)會(huì)釋放最近被阻塞在該完成端口的線程。
When a thread calls GetQueuedCompletionStatus, it is associated with the specified completion port until it exits, specifies a different completion port, or frees the completion port. A thread can be associated with at most one completion port.
調(diào)用GetQueuedCompletionStatus，線程就會(huì)將會(huì)與某個(gè)指定的完成端口建立聯(lián)系，一直延續(xù)其該線程的存在周期，或被指定了不同的完成端口，或者釋放了與完成端口的聯(lián)系。一個(gè)線程只能與最多不超過(guò)一個(gè)的完成端口發(fā)生聯(lián)系。
The most important property of a completion port is the concurrency value. The concurrency value of a completion port is specified when the completion port is created. This value limits the number of runnable threads associated with the completion port. When the total number of runnable threads associated with the completion port reaches the concurrency value, the system blocks the execution of any subsequent threads that specify the completion port until the number of runnable threads associated with the completion port drops below the concurrency value. The most efficient scenario occurs when there are completion packets waiting in the queue, but no waits can be satisfied because the port has reached its concurrency limit. In this case, when a running thread calls GetQueuedCompletionStatus, it will immediately pick up the queued completion packet. No context switches will occur, because the running thread is continually picking up completion packets and the other threads are unable to run.
完成端口最重要的特性就是并發(fā)量。完成端口的并發(fā)量可以在創(chuàng)建該完成端口時(shí)指定。該并發(fā)量限制了與該完成端口相關(guān)聯(lián)的可運(yùn)行線程的數(shù)目。當(dāng)與該完成端口相關(guān)聯(lián)的可運(yùn)行線程的總數(shù)目達(dá)到了該并發(fā)量，系統(tǒng)就會(huì)阻塞任何與該完成端口相關(guān)聯(lián)的后續(xù)線程的執(zhí)行，直到與該完成端口相關(guān)聯(lián)的可運(yùn)行線程數(shù)目下降到小于該并發(fā)量為止。最有效的假想是發(fā)生在有完成包在隊(duì)列中等待，而沒(méi)有等待被滿足，因?yàn)榇藭r(shí)完成端口達(dá)到了其并發(fā)量的極限。此時(shí)，一個(gè)正在運(yùn)行中的線程調(diào)用GetQueuedCompletionStatus時(shí)，它就會(huì)立刻從隊(duì)列中取走該完成包。這樣就不存在著環(huán)境的切換，因?yàn)樵撎幱谶\(yùn)行中的線程就會(huì)連續(xù)不斷地從隊(duì)列中取走完成包，而其他的線程就不能運(yùn)行了。
The best value to pick for the concurrency value is the number of CPUs on the machine. If your transaction required a lengthy computation, a larger concurrency value will allow more threads to run. Each transaction will take longer to complete, but more transactions will be processed at the same time. It is easy to experiment with the concurrency value to achieve the best effect for your application.
對(duì)于并發(fā)量最好的挑選值就是您計(jì)算機(jī)中cpu的數(shù)目。如果您的事務(wù)處理需要一個(gè)漫長(zhǎng)的計(jì)算時(shí)間，一個(gè)比較大的并發(fā)量可以允許更多線程來(lái)運(yùn)行。雖然完成每個(gè)事務(wù)處理需要花費(fèi)更長(zhǎng)的時(shí)間，但更多的事務(wù)可以同時(shí)被處理。對(duì)于應(yīng)用程序來(lái)說(shuō)，很容易通過(guò)測(cè)試并發(fā)量來(lái)獲得最好的效果。
The PostQueuedCompletionStatus function allows an application to queue its own special-purpose I/O completion packets to the completion port without starting an asynchronous I/O operation. This is useful for notifying worker threads of external events.
PostQueuedCompletionStatus函數(shù)允許應(yīng)用程序可以針對(duì)自定義的專用I/O完成包進(jìn)行排隊(duì)，而無(wú)需啟動(dòng)一個(gè)異步I/O操作。這點(diǎn)對(duì)于通知外部事件的工作者線程來(lái)說(shuō)很有用。
The completion port is freed when there are no more references to it. The completion port handle and every file handle associated with the completion port reference the completion port. All the handles must be closed to free the completion port. To close the port handle, call the CloseHandle function.
在沒(méi)有更多的引用針對(duì)某個(gè)完成端口時(shí)，需要釋放該完成端口。該完成端口句柄以及與該完成端口相關(guān)聯(lián)的所有文件句柄都需要被釋放。調(diào)用CloseHandle可以釋放完成端口的句柄。