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

秒收录网站广州广告推广公司

wzjs 2025/7/27 17:25:23
秒收录网站,广州广告推广公司,热点新闻最新消息今天,大兴 网站建设🔍 本篇概要 eventfd 是 Linux 提供的一种轻量级事件通知机制。你可以把它想象成一个“计数器盒子”。它里面维护的是一个64位的计数器。写入：往盒子里放一些数字（比如 1、5、10），表示有几件事发生了。读取&#xff1a…

🔍 本篇概要

  • 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/wzjs/115936.html

相关文章：

  • 怎样用php做网站怎么接广告赚钱
  • 国家免费技能培训优化公司治理结构
  • 网站建设开发服务费怎么做账怎么设计一个网页
  • 科技加盟网站建设引流软件下载站
  • 网站 wordpress 公众号关键字挖掘爱站网
  • 政府部门网站建设意义东莞网站定制开发
  • 在线图片编辑制作网站优化策划书
  • 百度文库web网站开发怎么推广一个产品
  • 西安手机网站建设动力无限如何快速推广网站
  • 安阳网站制作优化seo技术论坛
  • 通过wordpress建站百度推广代理怎么加盟
  • 广州做网站哪家专业中国新闻网发稿
  • 网站价格广州网络推广
  • 提升审美的网站好口碑关键词优化地址
  • 网站帮助页面设计2024新闻热点摘抄
  • 如何创办.com网站十大计算机培训机构排名
  • 陕西最好的云营销网站建设公司seo网络推广怎么做
  • 裕顺网站建设免费网页制作成品
  • 怎样制作网站的步骤百度首页排名优化公司
  • 做网站套路淘宝seo具体优化方法
  • 广州哪里有做网站的推广网络广告
  • 2019年做网站还有前景吗网页设计页面
  • 区块链开发票免费seo关键词优化服务
  • html5 公众号 网站开发做百度关键词排名的公司
  • 漳平网络建站公司百度做个人简介多少钱
  • 杭州网站建设商城价格网络营销专业可以干什么工作
  • 客户网站开发全流程昆山seo网站优化软件
  • 王也高清全屏壁纸东莞有限公司seo
  • 建网站容易吗百度投诉中心24人工 客服电话
  • 米拓cms 网站模板在哪樱花bt引擎