如何将单个文件句柄绑定至多IOCP句柄以拆分读写请求？

核心前提说明 #

Windows IOCP允许将同一个文件句柄关联到多个完成端口队列，但所有IO操作必须使用重叠(Overlapped)结构，且每个操作的重叠结构可携带自定义上下文信息，用于后续完成端口线程识别操作类型。

步骤1：创建两个独立IOCP队列（R和W） #

通过CreateIoCompletionPort创建分别对应读、写的完成端口：

HANDLE iocpRead = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 0); // 读队列R
HANDLE iocpWrite = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 0); // 写队列W

步骤2：绑定文件句柄F至两个IOCP队列 #

调用两次CreateIoCompletionPort，将文件句柄分别关联到读、写队列，同时通过CompletionKey标记操作类型：

// 绑定到读IOCP R，标记为READ_OP
CreateIoCompletionPort(F, iocpRead, (ULONG_PTR)"READ_OP", 0);
// 绑定到写IOCP W，标记为WRITE_OP
CreateIoCompletionPort(F, iocpWrite, (ULONG_PTR)"WRITE_OP", 0);

步骤3：实现读线程T1（轮询模式） #

采用非阻塞调用GetQueuedCompletionStatus（超时设为0），主动轮询读队列的完成事件，同时加入短暂休眠避免CPU空转：

DWORD WINAPI ReadThreadProc(LPVOID param) {
    HANDLE iocpRead = (HANDLE)param;
    DWORD bytesTransferred;
    ULONG_PTR completionKey;
    LPOVERLAPPED overlapped;

    while (true) {
        // 非阻塞轮询，立即返回结果
        BOOL result = GetQueuedCompletionStatus(
            iocpRead,
            &bytesTransferred,
            &completionKey,
            &overlapped,
            0
        );

        if (result && overlapped != NULL) {
            // 处理读完成逻辑
            ProcessReadCompleted(bytesTransferred, overlapped);
            // 释放动态分配的重叠结构
            delete overlapped;
        } else if (GetLastError() != WAIT_TIMEOUT) {
            // 处理IOCP关闭或错误，退出循环
            break;
        }

        // 轮询间隙休眠，降低CPU占用
        Sleep(1);
    }
    return 0;
}

步骤4：实现写线程T2（等待中断模式） #

使用阻塞式GetQueuedCompletionStatus（超时设为INFINITE），直到有写操作完成事件触发：

DWORD WINAPI WriteThreadProc(LPVOID param) {
    HANDLE iocpWrite = (HANDLE)param;
    DWORD bytesTransferred;
    ULONG_PTR completionKey;
    LPOVERLAPPED overlapped;

    while (true) {
        // 阻塞等待写完成事件
        BOOL result = GetQueuedCompletionStatus(
            iocpWrite,
            &bytesTransferred,
            &completionKey,
            &overlapped,
            INFINITE
        );

        if (result && overlapped != NULL) {
            // 处理写完成逻辑
            ProcessWriteCompleted(bytesTransferred, overlapped);
            // 释放动态分配的重叠结构
            delete overlapped;
        } else {
            // 处理IOCP关闭或错误，退出循环
            break;
        }
    }
    return 0;
}

步骤5：发起读写操作并绑定上下文 #

发起读/写操作时，创建独立的OVERLAPPED结构，指定文件偏移等参数，IO完成事件会自动触发对应IOCP队列的通知：

// 发起读操作，关联读IOCP
OVERLAPPED* readOverlap = new OVERLAPPED{0};
readOverlap->Offset = 0; // 设置文件读取偏移
ReadFile(F, readBuffer, BUFFER_SIZE, NULL, readOverlap);

// 发起写操作，关联写IOCP
OVERLAPPED* writeOverlap = new OVERLAPPED{0};
writeOverlap->Offset = 0; // 设置文件写入偏移
WriteFile(F, writeBuffer, BUFFER_SIZE, NULL, writeOverlap);

关键注意事项 #

• 必须使用重叠IO：所有读写操作必须传入OVERLAPPED结构，否则IOCP无法捕获完成事件。
• 资源管理：动态分配的OVERLAPPED结构需在完成事件处理后释放，避免内存泄漏。
• 线程同步：文件句柄本身线程安全，但读写操作的偏移控制需自行同步（如用互斥量保护文件指针）。
• 退出流程：需先终止所有未完成的IO操作，再关闭IOCP句柄，最后等待线程退出。

内容的提问来源于stack exchange，提问作者LauZyHou