我可以使用 std::shared_ptr 在 IOCP 中包装每个 I/O 数据吗？

Question

我正在开发一个使用 IOCP 的客户端应用程序。

我的每个 I/O 数据类派生自 WSAOVERLAPPED：

class IoRequest : public WSAOVERLAPPED
{
...
};

而在执行异步 I/O 操作时，我是这样使用的：

{ // WSASend - this is done in my main thread.
    IoRequest *pIoRequest = new IoRequest;
    pIoRequest->SetSocket(m_socket);
    pIoRequest->SetBuffer(vecCommandData);
    pIoRequest->SetOperationType(OP_TYPE_SEND);
    WSASend(m_socket, pIoRequest->GetWsaBuffer(), 1, NULL, 0, pIoRequest, NULL);
}

{ // WSARecv - this is done in my I/O worker thread.
    GetQueuedCompletionStatus(m_hIocp, &dwNumberOfBytesTransferred, &ulCompletionKey, (LPOVERLAPPED*)&pIoRequest, INFINITE);
    ...
    WSARecv(pIoRequest->GetSocket(), pIoRequest->GetWsaBuffer(), 1, NULL, &(pIoRequest->GetFlags()), pIoRequest, NULL);
    ...
}

我在我的工作线程例程中重用了我的 IoRequest 实例。我想知道，使用 std::shared_ptr 而不是原始指针来管理我的每个 I/O 数据会有什么问题吗？

所以对于 WSASend()，类似于：

std::shared_ptr<IoRequest> spIoRequest(new IoRequest);
spIoRequest->SetSocket(m_socket);
spIoRequest->SetBuffer(vecCommandData);
spIoRequest->SetOperationType(OP_TYPE_SEND);
WSASend(m_socket, spIoRequest->GetWsaBuffer(), 1, NULL, 0, spIoRequest.get(), NULL);

干杯

Answer 1

除非您在某处拥有std::shared_ptr<IoRequest> 的实时实例，否则您的IoRequest 将在完成处理程序接收之前在发送例程结束时被释放。