完成端口(IOCP) 也可以这样用~~呵呵~ 用来充当线程之间的数据队列~

// Test32.cpp : 定义控制台应用程序的入口点。


//




#include "stdafx.h"


#include <stdlib.h>


#include <windows.h>


#include <process.h>


#include <iostream>




HANDLE m_hCompletionPort;






volatile BOOL m_bShutDown;




struct TESTOVERLAPPED






{


OVERLAPPED m_ol;


CHAR szData[512];


};






UINT WINAPI IOWorkerThreadProc(LPVOID pParam)






{


BOOL bError = FALSE;


DWORD dwIoSize = 0;


DWORD dwCmpKey = 0;


LPOVERLAPPED lpOverlapped = NULL;


TESTOVERLAPPED* pOverlapBuff = NULL;






while ( !bError )






{


pOverlapBuff = NULL;


dwCmpKey = 0;


// Get a completed IO request.


BOOL bIORet = GetQueuedCompletionStatus(m_hCompletionPort, &dwIoSize, (LPDWORD) &dwCmpKey, &lpOverlapped, INFINITE);


// Simulate workload (for debugging, to find possible reordering)


//Sleep(20);






// If Something whent wrong..


if (!bIORet)






{


DWORD dwIOError = GetLastError();


if(dwIOError != WAIT_TIMEOUT) // It was not an Time out event we wait for ever (INFINITE)






{




continue;




}


}// if (!bIORet)








if(bIORet && lpOverlapped && dwCmpKey)






{


pOverlapBuff=CONTAINING_RECORD(lpOverlapped, TESTOVERLAPPED, m_ol);


if(pOverlapBuff!=NULL)






{


//pThis->ProcessIOMessage(pOverlapBuff, dwCmpKey, dwIoSize);


printf("ThreaId：0x%x %d %s ",GetCurrentThreadId(),dwCmpKey,pOverlapBuff->szData);


}




delete pOverlapBuff;


}




if((dwCmpKey == NULL) && (pOverlapBuff == NULL) && m_bShutDown)






{


bError = TRUE;


}


}




printf("Thread dead!");




return 0xdead;


}










int _tmain(int argc, _TCHAR* argv[])






{


m_hCompletionPort = CreateIoCompletionPort( INVALID_HANDLE_VALUE, NULL, 0, 0 );




uintptr_t hThread =_beginthreadex(0,0,IOWorkerThreadProc, 0,0, NULL);


hThread =_beginthreadex(0,0,IOWorkerThreadProc, 0,0, NULL);


hThread =_beginthreadex(0,0,IOWorkerThreadProc, 0,0, NULL);




m_bShutDown = FALSE;




for(int i = 0; i < 30; i++)






{


DWORD dwCmpKey = i;


TESTOVERLAPPED * pOverlapBuff = new TESTOVERLAPPED;


memset(pOverlapBuff->szData,0,sizeof(pOverlapBuff->szData));


sprintf(pOverlapBuff->szData,"CMD ID：%d",i);


PostQueuedCompletionStatus(m_hCompletionPort, 0, (ULONG_PTR) &dwCmpKey, &pOverlapBuff->m_ol);


}




m_bShutDown = TRUE;


PostQueuedCompletionStatus(m_hCompletionPort,0,0,0);




getchar();




return 0;


}