libev监视器介绍：libev监视器用法-CSDN博客
libev loop对象介绍：loop对象-CSDN博客
libev ev_loop_fork函数介绍:ev_loop_fork函数-CSDN博客
libev API吐血整理：https://download.csdn.net/download/qq_39466755/90794251?spm=1001.2014.3001.5503
用于解决fork函数导致子进程集成的fd集合失效问题
#include <stdio.h>
#include <unistd.h>
#include <sys/event.h>
#include <fcntl.h>
void child_process(int kq) {
printf("Child: Attempting to use inherited kqueue...\n");
struct kevent events[1];
int n = kevent(kq, NULL, 0, events, 1, NULL); // 无超时等待
printf("Child: kevent returned %d events (expected: 1)\n", n);
}
int main() {
int kq = kqueue();
int pipe_fd[2];
pipe(pipe_fd);
// 监控管道读端
struct kevent ev;
EV_SET(&ev, pipe_fd[0], EVFILT_READ, EV_ADD, 0, 0, NULL);
kevent(kq, &ev, 1, NULL, 0, NULL);
// 触发事件
write(pipe_fd[1], "test", 5);
pid_t pid = fork();
if (pid == 0) {
child_process(kq); // 子进程直接使用继承的 kqueue
_exit(0);
} else {
struct kevent events[1];
int n = kevent(kq, NULL, 0, events, 1, NULL);
printf("Parent: kevent returned %d events\n", n);
}
return 0;
}运行结果
Child: Attempting to use inherited kqueue...
Child: kevent returned 0 events (expected: 1) # 子进程事件丢失！
Parent: kevent returned 1 events # 父进程正常修改代码子进程可以正常接收父进程的fd集合
#include <ev.h>
#include <stdio.h>
#include <unistd.h>
#include <signal.h>
// 管道读端回调
static void pipe_cb(struct ev_loop *loop, ev_io *w, int revents) {
char buf[256];
ssize_t n = read(w->fd, buf, sizeof(buf));
printf("[%s] Received data: %.*s\n",
getpid() == getppid() ? "Parent" : "Child",
(int)n, buf);
}
int main() {
// 忽略 SIGPIPE（防止写入关闭的管道导致进程退出）
signal(SIGPIPE, SIG_IGN);
struct ev_loop *loop = EV_DEFAULT;
int pipe_fd[2];
pipe(pipe_fd);
// 监控管道读端
ev_io pipe_watcher;
ev_io_init(&pipe_watcher, pipe_cb, pipe_fd[0], EV_READ);
ev_io_start(loop, &pipe_watcher);
// 写入数据（触发事件）
write(pipe_fd[1], "hello", 6);
pid_t pid = fork();
if (pid == 0) {
// ---------- 关键修复 ----------
ev_loop_fork(loop); // 重置内核状态
// ------------------------------
printf("Child: Started event loop\n");
ev_run(loop, 0); // 子进程现在能正常接收事件
_exit(0);
} else {
printf("Parent: Started event loop\n");
ev_run(loop, 0);
}
return 0;
}运行结果
Parent: Started event loop
[Parent] Received data: hello # 父进程正常接收
Child: Started event loop
[Child] Received data: hello # 子进程修复后也能接收结合libev接口，父子进程共享循环时的正确用法
struct ev_loop *loop = EV_DEFAULT;
ev_io parent_watcher;
ev_io_init(&parent_watcher, parent_cb, pipe_fd[0], EV_READ);
ev_io_start(loop, &parent_watcher);
pid_t pid = fork();
if (pid == 0) {
// 子进程
ev_loop_fork(loop); // 先重置后端
// 添加子进程独有的监视器
ev_io child_watcher;
ev_io_init(&child_watcher, child_cb, another_fd, EV_WRITE);
ev_io_start(loop, &child_watcher);
ev_run(loop, 0); // 现在能正确处理父/子监视器的事件
} else {
// 父进程继续原逻辑
ev_run(loop, 0);
}代码解析：
libev 使用底层机制（如 epoll/kqueue）来监听文件描述符。当调用 fork() 时，子进程会继承父进程的 epoll 实例，但该实例可能已失效（内核状态与用户态不一致）。ev_loop_fork() 会重建后端（如重新创建 epoll 实例），确保事件循环在子进程中能正常工作。因为struct ev_loop *loop = EV_DEFAULT;已经创建了底层的事件监听机制（如 epoll、kqueue 或 select 等，具体取决于系统支持）。
即使子进程不直接使用 pipe_fd[0]，事件循环本身仍需正确的后端支持。
虽然子进程没有主动使用 parent_watcher（监视 pipe_fd[0]），但该监视器仍存在于 loop 中（因为它是父进程注册的）。未重置的事件循环可能会错误地尝试处理这些继承的监视器，导致未定义行为。
一般情况下都是搭配libev开源库的API函数(ev_fork_init,ev_fork_start等)一起使用：
#include <ev.h>
#include <unistd.h>
#include <stdio.h>
// fork 回调函数
void fork_cb(EV_P_ ev_fork *w, int revents) {
printf("Child process (PID: %d) reinitializing event loop...\n", getpid());
ev_loop_fork(EV_A); // 必须调用，重新初始化子进程的事件循环
}
int main() {
struct ev_loop *loop = EV_DEFAULT;
struct ev_fork fork_watcher;
// 初始化fork监视器
ev_fork_init(&fork_watcher, fork_cb);
ev_fork_start(loop, &fork_watcher); // 启动监视器
printf("Parent process (PID: %d) started. Forking...\n", getpid());
pid_t pid = fork();
if (pid == 0) {
// 子进程：ev_loop_fork已在回调中调用
ev_run(loop, 0); // 子进程事件循环
} else if (pid > 0) {
// 父进程代码
printf("Parent process continues (child PID: %d)\n", pid);
sleep(2); // 模拟父进程工作
} else {
perror("fork failed");
return 1;
}
return 0;
}
