安全关闭无限期运行的线程

Question

首先，我意识到如果我的代码处于循环中，我可以在我希望线程关闭时使用do while 循环来检查变量集，但在这种情况下这是不可能的（看起来):

DWORD WINAPI recv thread (LPVOID random) {
    recv(ClientSocket, recvbuffer, recvbuflen, 0);
    return 1;
}

在上面，recv() 是一个阻塞函数。 （如果格式不正确，请原谅我。这是我在手机上能做的最好的事情。）

我将如何终止这个线程，因为它从不关闭但从不循环？

谢谢， ~P

Answer 1

在其他解决方案中，您可以

a) 为套接字设置超时并通过在适当的循环中检查返回值和/或错误来正确处理超时：

setsockopt(ClientSocket,SOL_SOCKET,SO_RCVTIMEO,(char *)&timeout,sizeof(timeout))

b) 关闭套接字，recv(..) 从阻塞状态返回错误。

Answer 2

你可以在 recv() 之前使用 poll 来检查是否有东西要接收。

struct pollfd poll;
int res;

poll.fd = ClientSocket;
poll.events = POLLIN;
res = poll(&poll, 1, 1000); // 1000 ms timeout

if (res == 0)
{
    // timeout
}
else if (res == -1)
{
    // error
}
else
{
    // implies (poll.revents & POLLIN) != 0
    recv(ClientSocket, recvbuffer, recvbuflen,0); // we can read ...
} 

Answer 3

我处理这个问题的方法是永远不要在 recv() 内部阻塞——最好将套接字设置为非阻塞模式，但是当你知道套接字当前有一些字节可供读取。

这就引出了下一个问题：如果你不在 recv() 内部阻塞，你如何防止 CPU 旋转？这个问题的答案是使用正确的参数调用 select()（或 poll()），这样你就会阻塞在那里，直到套接字有字节准备好接收 recv()。

然后是第三个问题：如果您的线程现在在 select() 中被阻塞（可能永远），我们是不是又回到了原来的问题？不完全是，因为现在我们可以实现self-pipe trick 的变体。特别是，因为 select()（或 poll()）可以同时“监视”多个套接字，我们可以告诉调用阻塞，直到两个套接字中的任何一个有数据可供读取。然后，当我们想要关闭线程时，主线程所要做的就是向第二个套接字发送一个字节的数据，这将导致 select() 立即返回。当线程看到是第二个socket准备好读取时，应该退出响应，这样主线程对WaitForSingleObject(theThreadHandle)的阻塞调用就会返回，然后主线程就可以清理干净了，没有任何风险竞争条件。

最后一个问题是：如何设置一个套接字对，以便您的主线程可以在其中一个套接字上调用 send()，而您的 recv 线程将看到发送的数据出现在另一个套接字上？在 POSIX 下很容易，有一个 socketpair() 函数可以做到这一点。在 Windows 下，socketpair() 不存在，但您可以滚动您自己的实现，如 here 所示。