网狐棋牌（一） ServerKernel中的IQueueService接口分析(1)

bcsx

关键代码解析：

1 // 开始服务
2 bool __cdecl CQueueService::StartService()
3 {
4    //效验参数
5    ASSERT(m_bService==false);
6    ASSERT(m_hCompletionPort==NULL);
7    ASSERT(m_pIQueueServiceSink!=NULL);
8
9    //建立完成端口
10    //! 需要追踪一下这里的完成端口句柄
11    //! 首先分析这里的创建，INVALID_HANDLE_VALUE表示没有关联任何文件句柄，也就是
12    //! 说不存在某个实现某个操作完成以后系统自动给这个完成端口post一个完成消息的概念
13    //! 然后这里用限制工作线程数是1，也就是同意时刻只会有一条线程受到完成消息
14    m_hCompletionPort=CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,NULL,1);
15    if (m_hCompletionPort==NULL) throw TEXT("队列对象完成端口创建失败");
16
17    //启动线程
18    if (m_QueueServiceThread.InitThread(m_hCompletionPort)==false) throw TEXT("队列对象线程初始化失败");
19    if (m_QueueServiceThread.StartThead()==false) throw TEXT("队列对象线程启动失败");
20
21    //设置参数
22    m_bService=true;
23
24    return true;
25}
m_QueueServiceThread.InitThread(m_hCompletionPort);
他悄悄的给完成端口句柄扔给了服务线程，偶们去看看服务线程拿这玩意干了啥，，，
// 运行函数
bool CQueueServiceThread::RepetitionRun()
{
    //效验参数
    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;

        //获取数据
        tagDataHead DataHead;
        bool bSuccess=pQueueService->GetData(DataHead,m_cbBuffer,sizeof(m_cbBuffer));
        ASSERT(bSuccess==true);

        //处理数据
        if (bSuccess==true) pQueueService->OnQueueServiceThread(DataHead,m_cbBuffer,DataHead.wDataSize);

        return true;
    }

    return false;
}