C++中如何正确销毁阻塞于epoll的类成员函数线程？

核心问题在于：线程阻塞在epoll_wait时，单纯靠标志位无法让它从阻塞中唤醒，导致析构函数的join()永远等不到线程退出。必须通过唤醒fd强制让epoll_wait返回，这是业界通用的标准做法，具体实现如下：

优先选择eventfd做唤醒通知 #

Linux的eventfd比传统pipe更高效，专门设计用于线程/进程间的事件通知，仅需一个fd就能完成唤醒操作，逻辑更简洁。

具体实现步骤 #

• 添加线程安全的退出标志与唤醒fd：用std::atomic<bool>存储退出标志（保证多线程内存可见性）；初始化eventfd并加入epoll监听列表，监听读事件。
• 析构时触发唤醒：先设置退出标志，再往eventfd写入数据，强制epoll_wait返回。
• 线程函数处理退出逻辑：epoll_wait返回后，先检查退出标志，若为true则退出循环；同时读取唤醒fd的数据，清空事件避免重复触发。

修改后的代码示例 #

#include <atomic>
#include <thread>
#include <sys/epoll.h>
#include <sys/eventfd.h>
#include <errno.h>

class MyClass
{
public:
    MyClass() 
        : exit_flag(false)
    { 
        epoll_fd = epoll_create(0);
        // 创建非阻塞、自动关闭的eventfd
        wake_fd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);
        
        // 将wake_fd加入epoll监听读事件
        epoll_event ev{};
        ev.events = EPOLLIN;
        ev.data.fd = wake_fd;
        epoll_ctl(epoll_fd, EPOLL_CTL_ADD, wake_fd, &ev);

        mythread = std::thread(&MyClass::threadFunc, this);
    }

    void threadFunc()
    {
        epoll_event events[10];
        while (!exit_flag.load(std::memory_order_acquire))
        {
            int numEvents = epoll_wait(epoll_fd, events, 10, -1);
            if (numEvents == -1) {
                // 处理信号打断的情况，继续循环
                if (errno == EINTR) continue;
                break;
            }

            for (int i = 0; i < numEvents; ++i) {
                if (events[i].data.fd == wake_fd) {
                    // 读取eventfd数据，清空事件
                    uint64_t dummy;
                    read(wake_fd, &dummy, sizeof(dummy));
                    continue;
                }
                // 处理业务fd的事件逻辑
                // some processing here
            }
        }
    }

    ~MyClass()
    {
        // 设置退出标志
        exit_flag.store(true, std::memory_order_release);
        // 写入数据唤醒epoll_wait
        uint64_t val = 1;
        write(wake_fd, &val, sizeof(val));
        // 等待线程退出
        mythread.join();
        // 关闭文件描述符
        close(wake_fd);
        close(epoll_fd);
    }

private:
    std::thread mythread;
    int epoll_fd;
    int wake_fd;
    std::atomic<bool> exit_flag;
};

int main()
{
    MyClass inst;
    // some processing
    return 0;
}

关键细节说明 #

• 原子变量内存序：memory_order_acquire和memory_order_release确保退出标志的修改对线程可见，避免编译器优化导致的读写不一致。
• eventfd参数：EFD_NONBLOCK避免读写阻塞，EFD_CLOEXEC防止进程exec时fd泄漏。
• 错误处理：epoll_wait可能被信号打断（errno=EINTR），这种情况无需退出循环，直接继续等待即可。

内容的提问来源于stack exchange，提问作者neuron mac