//工作线程

//LOOP循环条件,根据情况设定相应的条件
while(LOOP)
{
BOOL Succes;
P_IOCPDATA IOCPData;//自己定义的数据结构
unsigned long TransByte;
LPWSAOVERLAPPED lpWsaOverlapped;

//获取完成通知
//完成端口的精华就在这里
//通过调用GetQueuedCompletionStatus,线程可以获得原子性的时间段,避免了线程切换的开销
Succes=
GetQueuedCompletionStatus(
hIOCP,
&TransByte,
(unsigned long*)&IOCPData,
&lpWsaOverlapped,
INFINITE);

if(Succes&&NULL!=lpWsaOverlapped&&TransByte)//完全正常
{
IOCPData=(P_IOCPDATA)lpWsaOverlapped;

//根据不同的I/O类型进行不同的处理
switch(IOCPData->IOType)
{
//AcceptEx具有连接和接受的功能
case AcptDone:
{
//有一个AccpetEx完成,再投递一个AccpetEx
PostAccpetEx(NULL);
{
//此段代码可以不调用,未发生错误,不知道为什么,
//如果不调用的话,句柄不会很多,不会超出限制
/*
//更行AccpetEx返回的套节字状态
int ErrorCode;
ErrorCode=
setsockopt(
IOCPData->Socket,
SOL_SOCKET,
SO_UPDATE_ACCEPT_CONTEXT,
(char*)&SocketListen,
sizeof(SocketListen)
);
if(SOCKET_ERROR==ErrorCode)
{
Test();
FreeIOCPData(IOCPData);
continue;
}
*/
}
//绑定AccpetEx返回的套节字到hIOCP
if(hIOCP!=CreateIoCompletionPort((HANDLE)IOCPData->Socket,hIOCP,(unsigned long)IOCPData,0))
{
Test();
FreeIOCPData(IOCPData);
continue;
}
//我写的是一个Web服务器,下面的是Http消息头的分析处理
if(HttpParseHead(IOCPData))
{
Respons(IOCPData);
}
break;

}
//...... 其他处理情况
}
}
//.... 出现错误情况下的处理
}