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

我正在使用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);

干杯

最佳答案

除非您在某个地方有一个std::shared_ptr<IoRequest>的 Activity 实例，否则您的IoRequest将在完成例程接收到它之前在发送例程的末尾释放。