1

我的主线程创建了多个 I/O 工作线程。然后我通过执行以下操作从我的主线程发起一个 I/O 请求：

{
    ...
    IoRequest *pIoRequest = new IoRequest(m_socket);
    pIoRequest->SetBuffer(vecCommandData); // vector of BYTEs
    pIoRequest->SetOperationType(OP_TYPE_SEND);
    WSASend(m_socket, pIoRequest->GetWsaBuffer(), 1, NULL, 0, pIoRequest, NULL);
    ...
}

在我的一个 I/O 工作线程中的某个时刻，请求已完成，并且我的 IoRequest 对象的缓冲区中填充了有效的响应数据。

DWORD WINAPI WorkerThreadProc(LPVOID lpParameter)
{
    IoCompletionPort *pIocp = reinterpret_cast<IoCompletionPort*>(lpParameter);    
    ...
    while (true)
    {
        BOOL bReturn = pIocp->GetStatus(&ulCompletionKey, &dwNumberOfBytesTransferred, (LPOVERLAPPED*)&pIoRequest);
        ...
        switch (pIoRequest->GetOperationType())
        {
        ...
        case OP_TYPE_RECEIVE_DATA:
            {
                ...
                // the requested I/O operation has completed and pIoRequest's buffer now contains valid response data!
                break;
            } 
        ...
        }
    }

    return 0;
}

如何在调用 WSASend() 后将我的主线程置于警报等待状态，并使其在准备好时接收响应数据？

4

1 回答 1

2

在 IOCP 服务器中，它通常是 GetQueuedCompletionStatus()。

于 2012-08-06T12:06:30.457 回答