面试题：网络编程中基于epoll的线程安全实现细节

事件注册阶段：
- 使用互斥锁（例如std::mutex在C++中）来保护epoll_ctl函数的调用。在调用epoll_ctl添加、修改或删除事件前，先锁定互斥锁，操作完成后解锁。
```
std::mutex epollMutex;
//...
{
    std::lock_guard<std::mutex> lock(epollMutex);
    epoll_ctl(epollFd, EPOLL_CTL_ADD, sockFd, &epollEvent);
}
```
事件监听阶段：
- 由于epoll_wait本身是线程安全的，但为了避免在监听过程中其他线程对epoll实例进行修改（如添加或删除事件）导致未定义行为，在调用epoll_wait前也可以锁定保护epoll实例的互斥锁。
```
{
    std::lock_guard<std::mutex> lock(epollMutex);
    int numEvents = epoll_wait(epollFd, events, maxEvents, -1);
}
```
事件处理阶段：
- 如果事件处理函数可能会修改epoll实例相关的状态（如处理完某个事件后决定删除该事件对应的文件描述符），同样需要使用互斥锁保护相关操作。
- 可以采用线程池来处理事件，将事件分发给线程池中的线程。每个线程在处理事件时，先获取互斥锁，处理完成后释放。例如在C++中：
```
void handleEvent(int sockFd) {
    std::lock_guard<std::mutex> lock(epollMutex);
    // 处理事件逻辑，如读取数据、写入数据等
    // 如果需要对epoll实例进行操作，如删除该sockFd对应的事件
    epoll_ctl(epollFd, EPOLL_CTL_DEL, sockFd, nullptr);
}
```
数据结构保护：
- 如果有自定义的数据结构来关联epoll事件和其他业务数据，这些数据结构的访问和修改也需要使用互斥锁保护，以确保线程安全。例如，如果有一个std::map<int, std::string>来存储每个文件描述符对应的客户端信息，在访问和修改这个map时需要锁定互斥锁。
```
std::mutex dataMutex;
std::map<int, std::string> clientInfo;
//...
{
    std::lock_guard<std::mutex> lock(dataMutex);
    clientInfo[sockFd] = "Some client information";
}
```

信号处理：

如果服务器需要处理信号（如SIGTERM等），信号处理函数中如果涉及epoll相关操作，同样需要确保线程安全。可以通过设置一个全局标志变量，在信号处理函数中设置该标志，主线程在合适的时机（如epoll_wait返回后）检查该标志并进行相应的安全操作。

volatile sig_atomic_t stopServer = 0;
void signalHandler(int signum) {
    stopServer = 1;
}
// 注册信号处理函数
signal(SIGTERM, signalHandler);
// 在epoll_wait返回后检查标志
int numEvents = epoll_wait(epollFd, events, maxEvents, -1);
if (stopServer) {
    // 进行安全的清理操作，如关闭文件描述符、释放资源等
}

星途面试题库

面试题：网络编程中基于epoll的线程安全实现细节

知识考点

面试题答案