我有一个多线程服务器,它通过这些循环生成新线程:
while(handle->m_run) {
if (handle->m_curThreadCount < handle->m_maxThreads) {
ready = pselect(socket + 1, &readSocket, NULL, NULL, &timeout, NULL);
if (ready != 1)
continue;
DWORD openedSocket = accept(socket, NULL, NULL);
handle->m_threads.emplace_back(std::thread(serverThread, openedSocket, handle));
handle->m_curThreadCount++;
}
}
大多数情况下,这按预期工作,但偶尔 pselect() 不会触发。我用 tcpdump 检查了它,知道数据是发送到服务器的,所以我认为它与主循环有关。
此外,如果在发送数据之前使用 gdb 运行并在 pselect() 上中断,则 pselect() 按预期返回 1。
以这种方式使用 pselect() 有什么问题吗?我应该如何解决这个问题?