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

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

news 2025/7/14 5:28:18

🔍 本篇概要

  • 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.dtcms.com/a/276859.html

相关文章：

  • QCustomPlot绘图保存成PDF文件
  • 网络安全的基本练习
  • 北京-4年功能测试2年空窗-报培训班学测开-第四十九天
  • 行测速算之假设分配法
  • ROS2中的QoS（Quality of Service）详解
  • v-show和v-if的区别
  • 算法复杂度分析：大O表示法详解
  • 婚后才明白，原来结婚真需要一点冲动！
  • 编程与数学 03-001 计算机组成原理 04_非数值数据表示与校验码
  • 解码冯・诺依曼：操作系统是如何为进程 “铺路” 的？
  • 002_Claude模型与定价
  • java进阶（二）+学习笔记
  • Qt 3D模块加载复杂模型
  • Cesium初探-CallbackProperty
  • 开发语言中关于面向对象和面向过程的笔记
  • 打造你的专属智能生活：鸿蒙系统自定义场景开发全流程详解
  • VISUALBERT：一个简单且高效的视觉与语言基线模型
  • 微信小程序案例 - 本地生活（首页）
  • 代码随想录|图论|15并查集理论基础
  • 算法学习笔记：18.拉斯维加斯算法 ——从原理到实战，涵盖 LeetCode 与考研 408 例题
  • RFCOMM协议详解：串口仿真与TCP/IP协议栈移植技术——面试高频考点与真题解析
  • 1.2.3_2 TCP/IP模型
  • Java小白-设计模式
  • 动态规划理论基础，LeetCode 509. 斐波那契数
  • 012_PDF处理与文档分析
  • jenkins使用Jenkinsfile部署springboot+docker项目
  • 011_视觉能力与图像处理
  • Docker 搭建本地Harbor私有镜像仓库
  • Rerank模型
  • 【Linux学习笔记】认识信号和信号的产生