当前位置： 首页 > news >正文

一扇门铃，万向感应——用 eventfd 实现零延迟通信

news 2025/7/14 5:30:16

🔍 本篇概要

  • eventfd 是 Linux 提供的一种轻量级事件通知机制。你可以把它想象成一个“计数器盒子”。
  • 它里面维护的是一个64位的计数器。
  • 写入：往盒子里放一些数字（比如 1、5、10），表示有几件事发生了。
  • 读取：从盒子里取出数字，每取一次就减少一个（或者一次性全拿走）。

它非常适合用来做：

  • 多线程/进程之间的通信。
  • 异步通知（如 epoll 配合使用）。
  • 控制并发资源访问（类似信号量）。

在这里插入图片描述

一· 🛠 如何创建 eventfd？

如下：

#include <sys/eventfd.h>
int efd = eventfd(initval, flags);

解释：

参数名含义
initval初始化值（初始计数器数值）
flags标志位（可选，影响行为）
  • 这里对于initval是给它设置初始值，如果不write写入，计数器就是这个初始值，否者就是write写入的那个值。

二.🎯 eventfd 的所有标志详解（Flags）

下面是 eventfd() 支持的所有标志：

标志名含义是否推荐使用
EFD_SEMAPHORE以信号量方式工作（每次读取减 1）✅ 推荐
EFD_CLOEXEC执行 exec 时自动关闭描述符✅ 推荐
EFD_NONBLOCK设置为非阻塞模式✅ 视需求而定
EFD_SHARED_FCNTL_FLAGS允许在 fork 后共享文件锁（Linux 4.7+）⚠️ 较少用
0（默认）默认行为（不带任何标志）✅ 可用

详解 (通俗解释通俗易懂版本)

1️⃣ EFD_SEMAPHORE —— 类似信号量

效果：

启用这个标志后，每次 read() 会把计数器减去 1，并返回 1。

🧠 比如：

你有一个糖果罐子，里面有 5 颗糖：

  • 不加这个标志 → 第一个人来，把 5 颗都拿走了。
  • 加了这个标志 → 每个人只能拿 1 颗，共 5 个人能拿到。

下面我们代码演示下：

#include <sys/eventfd.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <errno.h>int main() {int efd = eventfd(5, EFD_SEMAPHORE| EFD_NONBLOCK); // 启用两个标志uint64_t val;for (int i = 0; i < 6; ++i) {ssize_t s = read(efd, &val, sizeof(val));if (s == -1) {if (errno == EAGAIN|EWOULDBLOCK)printf("No more events.\n");elseperror("read");} else {printf("Read: %llu\n", (unsigned long long)val);}}close(efd);return 0;
}

效果如下：

在这里插入图片描述

  • 这里我们往文件里写了个5；也就可以理解成它的计数器被从一开始的0变成了5；而我们设置了semaphore模式，也就是每次计数器都会自动减一（一般如果设置了这个（在允许的条件下），此时每次read读出来的都是1）。
  • 然后我们又设置了非阻塞模式(nonblock)，也就是不会阻塞，因此看到了上面的效果。

2️⃣ EFD_CLOEXEC —— 自动关闭（exec 时）

效果：

当你调用 exec()（运行新程序）时，这个 eventfd 描述符会自动关闭，防止被新程序继承。

🧠 比如：

你在执行一个新的程序，不想让这个程序看到你之前的“糖果罐子”，那就加上这个标志。

efd = eventfd(0, EFD_CLOEXEC); // exec 时自动关闭
  • 这里我们一般使用的时候默认加上就好。

3️⃣ EFD_NONBLOCK —— 非阻塞读写

效果：

设置为非阻塞模式后：

  • 如果当前没有数据可读，read() 不会等待，而是立即返回错误码 EAGAIN，如果缓冲区满了，write() 也不会等待，而是立即返回 EAGAIN。

🧠 比如：

你去看糖果罐子，如果里面没糖了，你不等，直接离开。

演示下：

#include <sys/eventfd.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <errno.h>int main() {int efd = eventfd(0, EFD_NONBLOCK);uint64_t val;
ssize_t s = read(efd, &val, sizeof(val));
if (s == -1 && errno == EAGAIN) {printf("现在没有事件发生\n");
}return 0;
}

效果：

发现如果设置了：

在这里插入图片描述

  • 直接返回-1，然后查看错误码即可判断是非阻塞模式。

如果没设置：

在这里插入图片描述

  • 发现一直阻塞住。

4️⃣ EFD_SHARED_FCNTL_FLAGS（Linux 4.7+）

效果：

允许多个 fork 出来的子进程共享这个 eventfd 的文件锁状态（很少用）。

🧠 举例理解：

多个小孩一起管理同一个糖果罐子，不会互相干扰。

⚠️ 这个标志只在较新的 Linux 内核中支持，一般用户不需要关心。

因此，这里就不演示，也不常用。

三.综合测试体验下

代码如下：

#include <sys/eventfd.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <errno.h>int main() {int efd = eventfd(5, EFD_SEMAPHORE|EFD_CLOEXEC| EFD_NONBLOCK); // 启用两个标志uint64_t val;for (int i = 0; i < 6; ++i) {ssize_t s = read(efd, &val, sizeof(val));if (s == -1) {if (errno == EAGAIN|EWOULDBLOCK)printf("No more events.\n");elseperror("read");} else {printf("Read: %llu\n", (unsigned long long)val);}}close(efd);return 0;
}

效果：

在这里插入图片描述

  • 这里我们设置了非阻塞，因此最后会看到 NO more events，其次就是计数器写成5，每次读取都减1，然后每次读出的都是1，当最后一次减完0了，然后是非阻塞因此会这样。

如果我们写入的值和eventfd本身初始化的值不同呢（他就会按照写入的来初始化计数器了）：

代码如下：

#include <sys/eventfd.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <errno.h>int main() {int efd = eventfd(5, EFD_SEMAPHORE|EFD_CLOEXEC| EFD_NONBLOCK); // 启用两个标志uint64_t val=10;ssize_t s = write(efd, &val, sizeof(val));for (int i = 0; i < 6; ++i) {ssize_t s = read(efd, &val, sizeof(val));if (s == -1) {if (errno == EAGAIN|EWOULDBLOCK)printf("No more events.\n");elseperror("read");} else {printf("Read: %llu\n", (unsigned long long)val);}}close(efd);return 0;
}
  • 因此当它读完5个1后还会继续读，直到完成10个：

效果：

在这里插入图片描述

如果不设置EFD_SEMAPHORE呢？

代码如下：

#include <sys/eventfd.h>
#include <unistd.h>
#include <stdio.h>
#include <stdint.h>
#include <errno.h>int main()
{int efd = eventfd(5, EFD_CLOEXEC | EFD_NONBLOCK); // 启用两个标志uint64_t val;for (int i = 0; i < 6; ++i){ssize_t s = read(efd, &val, sizeof(val));if (s == -1){if (errno == EAGAIN | EWOULDBLOCK)printf("No more events.\n");elseperror("read");}else{printf("Read: %llu\n", (unsigned long long)val);}}close(efd);return 0;
}
  • 此时它就会一次性都读出来，然后计数器瞬间清零。

效果：

在这里插入图片描述

四.相关问题及使用技巧

相关问题：

问题回答
eventfd 是不是只能用于线程间通信？不是，也可以用于父子进程之间通信
eventfd 能不能和 epoll 一起用？当然可以！这是最常见用法之一
eventfd 和 pipe 有什么区别？eventfd 更轻量，适合简单通知；pipe 适合传输大量数据
eventfd 的最大值是多少？最大值是 0xFFFFFFFFFFFFFFFE（接近 18e18）
eventfd 会不会导致内存泄漏？不会，只要记得 close(efd) 就行

使用技巧：（个人看法）

一般我们可以默认把EFD_CLOEXEC加上；然后对于需求来决定是否加上EFD_NONBLOCK;对于EFD_SEMAPHORE也就是想让一次读完还是多次也是根据自己需求来完成的（常用的也就是这三个）。

五.简单基于eventfd与epoll多线程通知测试

大致测流程：

  • 初始化 eventfd。
  • 初始化 epoll。
  • 将 eventfd 注册到 epoll。
  • 启动多个线程调用 epoll_wait 等待事件。
  • 主线程写入 eventfd 触发事件。
  • 所有监听线程收到事件并处理。

看图：

在这里插入图片描述

源码：

#include <iostream>
#include <thread>
#include <vector>
#include <sys/eventfd.h>
#include <sys/epoll.h>
#include <unistd.h>
#include <cstring>
#include <cstdint>
#include <functional>
#include <chrono>// 线程数量
const int THREAD_COUNT = 3;int main() {// 1. 创建 eventfd (初始值为0)int efd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);if (efd == -1) {perror("eventfd");return 1;}// 2. 创建 epoll 实例int epfd = epoll_create1(0);if (epfd == -1) {perror("epoll_create1");close(efd);return 1;}// 3. 将 eventfd 添加进 epollstruct epoll_event ev;ev.events = EPOLLIN;   // 只关心可读事件ev.data.fd = efd;if (epoll_ctl(epfd, EPOLL_CTL_ADD, efd, &ev) == -1) {perror("epoll_ctl: add");close(epfd);close(efd);return 1;}// 4. 创建线程池，每个线程调用 epoll_wait 等待事件std::vector<std::thread> threads;for (int i = 0; i < THREAD_COUNT; ++i) {threads.emplace_back([=]() {std::cout << "Thread [" << std::this_thread::get_id() << "] is waiting for event..." << std::endl;struct epoll_event events[10];while (true) {int n = epoll_wait(epfd, events, 10, -1); // 永远等待if (n == -1) {perror("epoll_wait error");break;}for (int j = 0; j < n; ++j) {if (events[j].data.fd == efd && (events[j].events & EPOLLIN)) {uint64_t u;ssize_t s = read(efd, &u, sizeof(uint64_t));if (s != sizeof(uint64_t)) {perror("read eventfd");continue;}std::cout << "Thread [" << std::this_thread::get_id()<< "] received event, count: " << u << std::endl;}}}});}// 5. 主线程休眠一段时间后发送事件std::this_thread::sleep_for(std::chrono::seconds(3));std::cout << "Main thread is sending event to all workers..." << std::endl;uint64_t u = 1;if (write(efd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) {perror("write eventfd");}// 6. 等待所有线程结束（这里为了简单，实际应优雅退出）std::this_thread::sleep_for(std::chrono::seconds(2)); // 给子线程足够时间响应for (auto& t : threads) {if (t.joinable()) {t.detach(); // 或者 join()}}// 7. 清理资源close(epfd);close(efd);return 0;
}

先看现象：

在这里插入图片描述

解释下：

  • 首先搞三线程，然后往epoll模型的监测fd中加入efd，三个线程都进行监测；如果主线程往efd中写入了1，那么就只会被一个线程读取然后打印出来，其他线程都在epoll这里阻塞；最后全部线程都被终止即结束。

六. 小白总结

下面是博主总结的一张使用图：

在这里插入图片描述

通俗总结:

eventfd 就像一个“计数器盒子”，你可以往里放数字，也可以往外取。通过设置不同的标志（flag），你可以控制它是“一次全拿走”还是“每次拿一个”，还可以让它“不阻塞”、“自动关闭”等等。掌握这些标志，就能灵活运用它来做多线程同步、异步通知等高级功能！

http://www.lryc.cn/news/586639.html

相关文章：

  • 14.使用GoogleNet/Inception网络进行Fashion-Mnist分类
  • 4. 观察者模式
  • Java行为型模式---观察者模式
  • Typecho分类导航栏开发指南：从基础到高级实现
  • 低代码引擎核心技术：OneCode常用动作事件速查手册及注解驱动开发详解
  • Pytorch实现感知器并实现分类动画
  • 深入理解观察者模式：构建松耦合的交互系统
  • 为什么玩游戏用UDP，看网页用TCP？
  • 【C++详解】STL-priority_queue使用与模拟实现，仿函数详解
  • 信息收集实战
  • 【读书笔记】《C++ Software Design》第九章：The Decorator Design Pattern
  • 设计模式：软件开发的高效解决方案(单例、工厂、适配器、代理)
  • 基于无人机 RTK 和 yolov8 的目标定位算法
  • 一文认识并学会c++模板(初阶)
  • AI 助力编程：Cursor Vibe Coding 场景实战演示
  • 基于 Redisson 实现分布式系统下的接口限流
  • 牛客网50题
  • 【C/C++】编译期计算能力概述
  • [Python] -实用技巧篇1-用一行Python代码搞定日常任务
  • python-range函数
  • 校园幸运抽（抽奖系统）测试报告
  • 第七章应用题
  • HT8313功放入门
  • HashMap的原理
  • 数据结构与算法之美：线索二叉树
  • 蒙特卡洛树搜索方法实践
  • 蓝牙调试抓包工具--nRF Connect移动端 使用详细总结
  • 生成式对抗网络（GAN）模型原理概述
  • Java生产带文字、带边框的二维码
  • 牛客：HJ19 简单错误记录[华为机考][字符串]