Windows异步I/O详解
#include <windows.h> typedef struct _MYOVERLAPPED {OVERLAPPED ol;
HANDLE hFile;
PBYTE pBuf;
int nIndex;
}MYOVERLAPPED, *PMYOVERLAPPED;
DWORD WINAPI ThreadProc(LPVOID lParam) {
PMYOVERLAPPED pol =nullptr;
HANDLE hIOCP = lParam;
while (TRUE)
{
DWORD dwNum = 0;
ULONG_PTR uCompleteKey = 0;
BOOL bRet = GetQueuedCompletionStatus(
hIOCP,// 检查完成端口有没有待处理任务(有任务完成，通知完成端口处理)
&dwNum,// 实际传输的字节数
&uCompleteKey,// 哪个设备完成了异步操作
(LPOVERLAPPED*)&pol,
INFINITE);
if (bRet == FALSE && ERROR_ABANDONED_WAIT_0 == GetLastError())
{
printf("完成端口被关闭\n");
return 0;
}
if (uCompleteKey == NULL && pol == nullptr)
{
PostQueuedCompletionStatus(hIOCP, NULL, NULL, NULL);
printf("完成端口线程结束!\n");
return 0;
}
for (int i = 0; i < 10; i++)
{
printf("key:%d,%d:%02x \n", uCompleteKey,pol->nIndex, pol->pBuf);
}
printf("读完了！\n");
}
return 0;
}
int main()
{
// 1. 异步IO标记
// 有了这个标记 该文件就变为可等待的内核对象
// 后面的read write函数就变为非阻塞的
HANDLE hFile = CreateFile(L"..\\Debug\\123.exe", GENERIC_READ,
FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, NULL);
// 2. 创建一个完成端口
// 先获取核心数
SYSTEM_INFO si = {};
GetSystemInfo(&si);
HANDLE hIOCP = CreateIoCompletionPort(
INVALID_HANDLE_VALUE,// 创建完成端口,绑定完成端口的时候是文件句柄
NULL,// 创建完成端口的时候是NULL,绑定的时候是完成端口句柄
NULL,// 创建完成端口的时候是NULL,绑定的时候是自己设置的一个值，用来区分绑定的文件是哪个
si.dwNumberOfProcessors);// 完成端口上并行运行的最大线程数，绑定的时候是NULL
// 3.把完成端口和文件绑定，后面这个文件的所有异步操作的通知都交给完成端口
CreateIoCompletionPort(
hFile,
hIOCP,
0x12,// 和hFile绑定的值，也可以是hFile本身
NULL
);
// 4. 创建完成端口的服务线程
for (int i=0;i<si.dwNumberOfProcessors*2;i++)
{
CreateThread(NULL, NULL, ThreadProc, hIOCP, NULL, NULL);
}
// 5. 文件读取
PMYOVERLAPPED pol = new MYOVERLAPPED{};
pol->ol.Offset = 0x100;// 从偏移0x100这个位置开始读
pol->pBuf = new BYTE{};
pol->nIndex = 1;
ReadFile(hFile,
pol->pBuf,
0x1000,
NULL,//实际读取的个数，由OVERLAPPED结构体指定
(LPOVERLAPPED)pol);
PMYOVERLAPPED pol2 = new MYOVERLAPPED{};
pol2->ol.Offset = 0x200;// 从偏移0x100这个位置开始读
pol2->pBuf = new BYTE{};
pol2->nIndex = 2;
ReadFile(hFile,
pol2->pBuf,
0x1000,
NULL,//实际读取的个数，由OVERLAPPED结构体指定
(LPOVERLAPPED)pol2);
// ......干其他事
// 投递一个完成任务
PostQueuedCompletionStatus(hIOCP, NULL, NULL, NULL);
system("pause");
return 0;
}
页:
[1]