010 异步I/O处理 002

● 异步I/0
　　○ 使用设备内核对象
　　○ 使用事件内核对象 提醒同步以及交互
　　○ 可提醒I/O 不可跨线程的
　　○ I/O完成端口

　　⊙ 使用事件内核对象 提醒同步以及交互

　　

#include <Windows.h>
int main()
{
    //异步操作最大的好处就是不会阻塞
    HANDLE hFile = CreateFile(TEXT("Demo.txt"), GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ, nullptr, OPEN_ALWAYS, FILE_FLAG_OVERLAPPED, nullptr);
    if (hFile != INVALID_HANDLE_VALUE)
    {
        //Read
        BYTE bReadBuffer[100] = { 0 };
        OVERLAPPED oRead = { 0 };
        oRead.hEvent = CreateEvent(nullptr, TRUE, FALSE, TEXT("ReadEvent")); //事件内核对象
        ReadFile(hFile, bReadBuffer, sizeof(bReadBuffer), nullptr, &oRead);

        //Write
        BYTE bWriteBuffer[10] = { 1,2,3,4,5,6,7,8,9,0 };
        OVERLAPPED oWrite = { 0 };
        oWrite.hEvent = CreateEvent(nullptr, TRUE, FALSE, TEXT("WriteEvent")); //事件内核对象
        ReadFile(hFile, bWriteBuffer, sizeof(bWriteBuffer), nullptr, &oWrite);

        //Do Same ....
        //其他的线程
        HANDLE hOverLapped[2] = { 0 };
        hOverLapped[0] = oRead.hEvent;
        hOverLapped[1] = oWrite.hEvent;

        while (true)
        {
            DWORD dwCase = WaitForMultipleObjects(2, hOverLapped, FALSE, INFINITE);
            switch (dwCase - WAIT_OBJECT_0)
            {
            case 0:
                //读完成
                break;
            case 1:
                //写完成
                break;
            }
        }
    }
    else
    {
        //GetLastError();
    }
    
    return 0;
}

　　⊙ 可提醒的I/O 不可跨线程

#include <Windows.h>

VOID CALLBACK FileIOCompletionReadRoutine(
    _In_        DWORD dwErrorCode,
    _In_        DWORD dwNumberOfBytesTransfered,
    _Inout_        LPOVERLAPPED lpOverladded
    )
{
    MessageBox(nullptr, TEXT("Read"), TEXT("Read"), MB_OK);
}

int main()
{
    //发送请求
    //做自己的事情
    //判断请求是否完成

    //发送请求 -》完成后，操作系统提醒我
    //可提醒I/0操作
    //APC
    //工厂（进程）-》工人（线程）
    //                    APC机制 当线程空闲的时候（前提） -》 APC列表中的事情（自动执行）
    //                            线程为可提醒的窗台下
    //        就是线程空闲的时候
    //MessageBox        -》   阻塞（闲下来） 不是可提醒状态
    //Wait Sleep 函数 可提醒的状态


    HANDLE hFile = CreateFile(TEXT("Demo.txt"), GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ, nullptr, OPEN_ALWAYS, FILE_FLAG_OVERLAPPED, nullptr);
    
    if (hFile != INVALID_HANDLE_VALUE)
    {
        const UINT uLen = 255;
        BYTE bReadBuf[uLen] = { 0 };
        OVERLAPPED oRead = { 0 };
        oRead.Offset = 5;
        ReadFileEx(hFile, bReadBuf, uLen, &oRead, FileIOCompletionReadRoutine);

        SleepEx(100, TRUE);
        //DWORD WINAPI SleepEx(
        //    _In_ DWORD dwMilliseconds,
        //    _In_ BOOL  bAlertable
        //    );

        //干自己的事情 Do Some......
        //运行程序 没有弹出消息框
        //SleepEx    Wait 可以使线程成为空闲状态
        //while (10)
        //{
        //    Sleep(100);
        //}
    }


    return 0;
}