在接收另一个线程的套接字上触发EAGAIN

Trigger an EAGAIN on a socket receiving on another thread

本文关键字：EAGAIN 套接字 另一个 线程      更新时间：2023-10-16

假设我有两个线程，主线程和一个专门用于持续侦听标准TCP套接字的线程。现在，假设在某个时刻我想关闭所有东西。在主线程中，我想关闭监听线程正在处理的连接，然后加入线程并结束程序。

然而，这很棘手，因为我不知道如何使侦听线程从对read的调用返回。该调用将不会返回，除非实际接收到某些内容，并且原则上我可能会等待很长很长时间，直到另一个端点决定向我发送一些内容。

当我使用UDP套接字时，我曾经通过从我的环回接口在该端口上发送数据包来解决这个问题，因此触发recvfrom的返回。然而，这是非常不优雅的，它不能在TCP套接字上完成。

我知道另一种解决方法是使用setsockopt设置超时:这样我就可以保证调用最终会返回，但这也不美观，而且效率很低，因为我可能要等待几秒钟才能加入线程。

所以我想知道是否有某种方法可以触发EAGAIN在套接字read调用上，不像我要超时的那个，这样在我的主线程上，我可以在我的套接字描述符上调用一些force_return，在另一个线程上调用read会返回?

我通常通过创建pipe()并在读取线程中使用select()来解决这个问题。读线程必须在TCP套接字和管道的一端同时选择。当你想关闭读取器时，设置一个标志并向管道的另一端写入一些数据。

设置:

#include <unistd.h>
int signalPipe[2];
...
pipe(signalPipe);
读者:

while(running)
{
    FD_ZERO(&fds);
    FD_SET(tcpSocket, &fds);
    FD_SET(signalPipe[0], &fds);
    select(max(tcpSocket, signalPipe[0]) + 1, &fds, NULL, NULL, NULL);
    ...
}

其他线程:

// We want to stop now.
running = false;
write(signalPipe[1], "foo", 3);

相关文章：