完成端口模型可以让我们基于传递overlapped数据的思想分解异步操作,让操作系统帮我们做线程间的数据传递。基于这个思想,可以把bsdsocket改造成异步模型,尽管这样做效率上意义不大,但对于想模拟ms完成端口都网络模型的人来说,可以小圆梦想了。
- static HANDLE g_hiocp;
- static DWORD WINAPI worker(LPVOID pvd);
- static const int BUF_LEN = 256;
- struct myPerIoData
- {
- OVERLAPPED ov;
- char bf[BUF_LEN];
- };
- int _tmain(int argc, _TCHAR* argv[])
- {
- g_hiocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,NULL,0);
- CreateThread(NULL,0,worker,NULL,0,NULL);
- BOOL bgqcs;
- DWORD transed;
- DWORD comkey;
- myPerIoData* pov;
- int cnt = 0;
- while (true)
- {
- transed = 0;
- pov = NULL;
- bgqcs = GetQueuedCompletionStatus(g_hiocp,&transed,&comkey,(LPOVERLAPPED*)&pov,INFINITE);
- if (NULL == pov)
- {
- printf("sorry,you lost your snake/n");
- break;
- }
- printf("%s/n",pov->bf);
- delete pov;
- }
- return 0;
- }
- DWORD WINAPI worker( LPVOID pvd )
- {
- int cnt = 0;
- while (true)
- {
- Sleep(3000);
- ++cnt;
- if (cnt <= 5)
- {
- myPerIoData* pov = new myPerIoData;
- memset(pov,0,sizeof(myPerIoData));
- sprintf_s(pov->bf,BUF_LEN,"yes,it's snake : %d",cnt);
- PostQueuedCompletionStatus(g_hiocp,0,NULL,&pov->ov);
- }
- else
- {
- PostQueuedCompletionStatus(g_hiocp,0,NULL,NULL);
- }
- }
- return 0L;
- }
static HANDLE g_hiocp; static DWORD WINAPI worker(LPVOID pvd); static const int BUF_LEN = 256; struct myPerIoData { OVERLAPPED ov; char bf[BUF_LEN]; }; int _tmain(int argc, _TCHAR* argv[]) { g_hiocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,NULL,0); CreateThread(NULL,0,worker,NULL,0,NULL); BOOL bgqcs; DWORD transed; DWORD comkey; myPerIoData* pov; int cnt = 0; while (true) { transed = 0; pov = NULL; bgqcs = GetQueuedCompletionStatus(g_hiocp,&transed,&comkey,(LPOVERLAPPED*)&pov,INFINITE); if (NULL == pov) { printf("sorry,you lost your snake/n"); break; } printf("%s/n",pov->bf); delete pov; } return 0; } DWORD WINAPI worker( LPVOID pvd ) { int cnt = 0; while (true) { Sleep(3000); ++cnt; if (cnt <= 5) { myPerIoData* pov = new myPerIoData; memset(pov,0,sizeof(myPerIoData)); sprintf_s(pov->bf,BUF_LEN,"yes,it's snake : %d",cnt); PostQueuedCompletionStatus(g_hiocp,0,NULL,&pov->ov); } else { PostQueuedCompletionStatus(g_hiocp,0,NULL,NULL); } } return 0L; }
程序输出是这样的:
- yes,it's snake:1
- yes,it's snake:2
- yes,it's snake:3
- yes,it's snake:4
- yes,it's snake:5
- sorry,you lost your snake