相關(guān)UML如下：
添加：
處理
關(guān)鍵代碼解析：
1
//開始服務(wù)
2bool __cdecl CQueueService::StartService()
3
{
4
//效驗(yàn)參數(shù)
5 ASSERT(m_bService==false);
6 ASSERT(m_hCompletionPort==NULL);
7 ASSERT(m_pIQueueServiceSink!=NULL);
8
9 //建立完成端口
10 //! 需要追蹤一下這里的完成端口句柄
11 //! 首先分析這里的創(chuàng)建，INVALID_HANDLE_VALUE表示沒有關(guān)聯(lián)任何文件句柄，也就是
12 //! 說不存在某個(gè)實(shí)現(xiàn)某個(gè)操作完成以后系統(tǒng)自動(dòng)給這個(gè)完成端口post一個(gè)完成消息的概念
13 //! 然后這里用限制工作線程數(shù)是1，也就是同意時(shí)刻只會(huì)有一條線程受到完成消息
14 m_hCompletionPort=CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,NULL,1);
15 if (m_hCompletionPort==NULL) throw TEXT("隊(duì)列對(duì)象完成端口創(chuàng)建失敗");
16
17 //啟動(dòng)線程
18 if (m_QueueServiceThread.InitThread(m_hCompletionPort)==false) throw TEXT("隊(duì)列對(duì)象線程初始化失敗");
19 if (m_QueueServiceThread.StartThead()==false) throw TEXT("隊(duì)列對(duì)象線程啟動(dòng)失敗");
20
21 //設(shè)置參數(shù)
22 m_bService=true;
23
24 return true;
25
}
m_QueueServiceThread.InitThread(m_hCompletionPort);
他悄悄的給完成端口句柄扔給了服務(wù)線程，偶們?nèi)タ纯捶?wù)線程拿這玩意干了啥，，，
//運(yùn)行函數(shù)
bool CQueueServiceThread::RepetitionRun()
{
//效驗(yàn)參數(shù)
ASSERT(m_hCompletionPort!=NULL);
//變量定義
DWORD dwThancferred=0;
OVERLAPPED * pOverLapped=NULL;
CQueueService * pQueueService=NULL;
//等待完成端口
if (GetQueuedCompletionStatus(m_hCompletionPort,&dwThancferred,(PULONG_PTR)&pQueueService,&pOverLapped,INFINITE))
{
//判斷退出
if (pQueueService==NULL) return false;
//獲取數(shù)據(jù)
tagDataHead DataHead;
bool bSuccess=pQueueService->GetData(DataHead,m_cbBuffer,sizeof(m_cbBuffer));
ASSERT(bSuccess==true);
//處理數(shù)據(jù)
if (bSuccess==true) pQueueService->OnQueueServiceThread(DataHead,m_cbBuffer,DataHead.wDataSize);
return true;
}
return false;
}
秘密在此：
GetQueuedCompletionStatus(m_hCompletionPort,&dwThancferred,(PULONG_PTR)&pQueueService,&pOverLapped,INFINITE)
m_hCompletionPort是通過線程參數(shù)傳遞進(jìn)來的，dwThancferred和pQueueService是在之前CQueueService::AddToQueue()中Post過來的參數(shù)，，，
//加入數(shù)據(jù)
bool __cdecl CQueueService::AddToQueue(WORD wIdentifier, void * const pBuffer, WORD wDataSize)
{
CThreadLockHandle LockHandle(&m_ThreadLock);
m_DataStorage.AddData(wIdentifier,pBuffer,wDataSize);
PostQueuedCompletionStatus(m_hCompletionPort,wDataSize,(ULONG_PTR)this,NULL);
return true;
}
數(shù)據(jù)經(jīng)過完成端口在CQueueServiceThread繞一圈以后會(huì)回到CQueueService::OnQueueServiceThread()
//數(shù)據(jù)消息
void CQueueService::OnQueueServiceThread(const tagDataHead & DataHead, void * pBuffer, WORD wDataSize)
{
ASSERT(m_pIQueueServiceSink!=NULL);
try
{
m_pIQueueServiceSink->OnQueueServiceSink(DataHead.wIdentifier,pBuffer,DataHead.wDataSize,DataHead.dwInsertTime);
}
catch () {}
return;
}
這樣隊(duì)列服務(wù)就完成了他的使命，將執(zhí)行的消息，異步的交給指定接口去處理，，，
稍后將對(duì)列隊(duì)列服務(wù)做個(gè)宏觀上的的分析，，，下班時(shí)間到，，，回去繼續(xù)，，，
用一句話來描述QueueService模塊就是：
將隊(duì)列的插入和處理通過關(guān)聯(lián)到完成端口上以實(shí)現(xiàn)在IOCP線程池管理下異步處理；
Add以后投遞完成消息，在完成端口上監(jiān)聽的線程受到消息以后讀取數(shù)據(jù)并處理；