如何在单线程中同时轮询消息队列与Socket？

你的场景很典型——单线程需要同时响应两种异步事件：来自内部线程的消息队列通知，以及外部进程的Socket请求。下面是几个实践中常用的方案，按推荐程度排序：

1. 用文件描述符桥接条件变量（最优解） #

核心思路是把条件变量的唤醒事件转化为文件描述符可读事件，这样就能用Linux下的epoll（或BSD的kqueue、跨平台的select/poll）统一监听Socket和这个桥接描述符。最常用的两种桥接方式：

方式A：使用Pipe管道 #

• 提前创建一个匿名Pipe：int pipe_fd[2]; pipe(pipe_fd);
• 线程1的逻辑修改：往消息队列写入数据后，除了调用pthread_cond_signal()，还往Pipe的写端写入一个字节（比如write(pipe_fd[1], "x", 1);，内容无关紧要，只是触发可读事件）
• 线程2的逻辑改造：
  1. 将Socket和Pipe的读端（pipe_fd[0]）加入epoll监听集合
  2. 进入epoll_wait()循环，当收到事件时：
     • 如果是Socket的可读事件：处理外部进程的Socket请求
     • 如果是Pipe读端的可读事件：先把Pipe里的字节读出来（避免重复触发），然后加锁读取消息队列中的数据并处理

方式B：使用Eventfd（更轻量） #

Linux 2.6.27+支持eventfd，它是专门为事件通知设计的轻量级文件描述符，比Pipe更高效（不需要传递实际数据，仅维护一个计数器）：

• 创建eventfd：int efd = eventfd(0, EFD_NONBLOCK);
• 线程1写入消息队列后，调用eventfd_write(efd, 1);增加计数器
• 线程2把efd和Socket加入epoll，收到efd的可读事件时，调用eventfd_read(efd, &cnt);重置计数器，然后加锁处理消息队列

2. 用带超时的条件变量等待（折中方案） #

如果不想引入文件描述符，可以修改线程2的等待逻辑，用pthread_cond_timedwait()替代pthread_cond_wait()：

• 将Socket设置为非阻塞模式（fcntl(sock_fd, F_SETFL, O_NONBLOCK);）
• 线程2的循环逻辑：
  1. 先尝试非阻塞读取Socket的数据，如果有请求就处理
  2. 计算一个短超时时间（比如10ms），调用pthread_cond_timedwait(&cond, &mutex, &timeout)等待消息队列
  3. 如果等待被唤醒（消息队列有数据），就加锁处理消息队列；如果超时，回到步骤1重新检查Socket

⚠️ 注意：这个方案的缺点是响应延迟（Socket请求最多可能等待10ms才被处理），如果超时时间设太短会导致CPU空转率升高，适合对延迟要求不高的场景。

关键注意事项 #

• 消息队列的访问必须加锁：无论是线程1写入还是线程2读取，都要配合互斥锁（pthread_mutex_t）使用，避免数据竞争
• Socket处理要注意边缘触发（ET）和水平触发（LT）的区别：如果用epoll的ET模式，要保证一次性把Socket缓冲区的数据读完；LT模式则可以简化处理，但要避免重复触发
• 资源清理：退出线程时要关闭Pipe/Eventfd和Socket，避免资源泄漏

内容的提问来源于stack exchange，提问作者harsh gupta