一个简单的iocp有关问题，请大家进来看看

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

#include "stdafx.h" #include <Windows.h>

HANDLE myiocp; HANDLE myfile;

OVERLAPPED myol_w = {0}; HANDLE hh; DWORD lend; DWORD wcount = 1;

DWORD WINAPI th(PVOID lp) { printf("进入线程1\n"); DWORD len; ULONG_PTR completionKey; OVERLAPPED *op; while(1) {

GetQueuedCompletionStatus(myiocp,&len,&completionKey,&op,INFINITE); if (completionKey == 3) { break; } switch(completionKey) { case 1: //if (WaitForSingleObject(myol_w.hEvent,0) == WAIT_OBJECT_0) if (WaitForSingleObject(op->hEvent,0) == WAIT_OBJECT_0) { completionKey = 0; FlushFileBuffers(myfile); printf("线程中1——写入完成%u\n",wcount++); } //free(op); break; default: printf("线程中1——完成键无数据\n"); break; } Sleep(1); } printf("线程中1——线程退出\n"); return 0; }

DWORD WINAPI th1(PVOID lp) { printf("进入线程2\n"); DWORD len; ULONG_PTR completionKey; OVERLAPPED *op; while(1) {

GetQueuedCompletionStatus(myiocp,&len,&completionKey,&op,INFINITE); if (completionKey == 3) { break; } switch(completionKey) { case 1: //if (WaitForSingleObject(myol_w.hEvent,0) == WAIT_OBJECT_0) if (WaitForSingleObject(op->hEvent,0) == WAIT_OBJECT_0) { completionKey = 0; FlushFileBuffers(myfile); printf("线程中2——写入完成%u\n",wcount++); } //free(op); break; default: printf("线程中2——完成键无数据\n"); break; } Sleep(1); } printf("线程中2——线程退出\n"); return 0; }

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

//创建IOCP，前三个参数固定，第4个参数为要使用的线程数量，一般为CPU数量。0为 使用系统默认值. myiocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE,NULL,0,0); HANDLE myt = CreateThread(NULL,0,th,NULL,0,NULL); CloseHandle(myt); HANDLE myt1 = CreateThread(NULL,0,th1,NULL,0,NULL); CloseHandle(myt1);

hh = CreateEvent(NULL,false,false,NULL); myol_w.hEvent = hh;

myfile = CreateFile("data.dat",GENERIC_READ|GENERIC_WRITE,

FILE_SHARE_READ|FILE_SHARE_WRITE,NULL,CREATE_ALWAYS,FILE_ATTRIBUTE_NORMA L | FILE_FLAG_OVERLAPPED,NULL); if (myfile == INVALID_HANDLE_VALUE) { printf("创建文件失败"); system("pause"); } LARGE_INTEGER len; len.QuadPart = 1024*1024; SetFilePointerEx(myfile,len,NULL,FILE_BEGIN); SetEndOfFile(myfile); SetFilePointerEx(myfile,len,NULL,FILE_BEGIN);

lend = 0; DWORD for_count = 0; system("pause"); myol_w.Offset = 0;//偏移量 低位。 myol_w.OffsetHigh = 0;//偏移量 高位。 for(int c = 1; c <= 50; ) { //与设备句柄关联，参数1为设备handle，参数2为一个新的iocp的句柄，参 数3为一个完成键可以是任何值，参数4默认0即可. //注意：使用完成键来让线程识别是何种操作时，每次 CreateIoCompletionPort时第一个参数必须不能相同，不然 //GetQueuedCompletionStatus得来的完成键只是第一个进入队列的操 作。 //注：IOCP投递一个IO时是按照先进先出的原则。 //而线程中谁后GetQueuedCompletionStatus却优先调用，从而有可能先 GetQueuedCompletionStatus的线程永远也不会被调用. CreateIoCompletionPort(myfile,myiocp,1,0); for_count++; //if (WriteFile(myfile,wstr,16,&lend,&myol_w)) if (WriteFile(myfile,&c,4,&lend,&myol_w)) { c++; myol_w.Offset += 4;//偏移量 低位。 myol_w.OffsetHigh = 0;//偏移量 高位。 }

Sleep(10); }

printf("等待时间完成。。。。。\n\n"); CloseHandle(myfile); printf("关闭线程\n");

//关闭一个完成端口需要调用PostQueuedCompletionStatus，参数1~4可以为规定 类型的任何值，然后在 //GetQueuedCompletionStatus后判断，从而退出。本例是使用完成键来判断退出. PostQueuedCompletionStatus(myiocp,0,3,0); PostQueuedCompletionStatus(myiocp,0,3,0); system("pause"); return 0; }