eventfd

2023-10-12 22:04
文章标签 eventfd

本文主要是介绍eventfd,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1. 

#include <sys/eventfd.h>
int eventfd(unsigned int initval, int flags); //创建eventfd

参数含义:
initval:创建eventfd时它所对应的64位计数器的初始值;
flags:eventfd文件描述符的标志,可由三种选项组成:EFD_CLOEXEC、EFD_NONBLOCK和EFD_SEMAPHORE。
EFD_CLOEXEC:表示返回的eventfd文件描述符在fork后exec其他程序时会自动关闭这个文件描述符;
EFD_NONBLOCK:设置返回的eventfd非阻塞;
EFD_SEMAPHORE表:表示将eventfd作为一个信号量来使用。
 

2.

例子

#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/eventfd.h>
#include <unistd.h>
/* Definition of uint64_t */#define handle_error(msg)   \do                      \{                       \perror(msg);        \exit(EXIT_FAILURE); \} while (0)int main(int argc, char *argv[])
{int efd, j;uint64_t u;ssize_t s;if (argc < 2){fprintf(stderr, "Usage: %s <num>...\n", argv[0]);exit(EXIT_FAILURE);}efd = eventfd(0, 0);if (efd == -1)handle_error("eventfd");switch (fork()){case 0:for (j = 1; j < argc; j++){printf("Child writing %s to efd\n", argv[j]);u = strtoull(argv[j], NULL, 0);/* strtoull() allows various bases */s = write(efd, &u, sizeof(uint64_t)); // 每次写入会累加if (s != sizeof(uint64_t))handle_error("write");}printf("Child completed write loop\n");exit(EXIT_SUCCESS);default:sleep(2);printf("Parent about to read\n");s = read(efd, &u, sizeof(uint64_t));if (s != sizeof(uint64_t))handle_error("read");printf("Parent read %llu (0x%llx) from efd\n",(unsigned long long)u, (unsigned long long)u);exit(EXIT_SUCCESS);case -1:handle_error("fork");}
}

其他用法,

一个消费者,多个生产的时候,

producer:// 投递请求到链表list_add( global_list, request )// 唤醒消费者处理write(eventfd, &cnt /* 1 */ , 8)

consumer // 添加 eventfd 到监听池epoll_ctl(ep, EPOLL_CTL_ADD, eventfd, &ee);loop:// 等待唤醒epoll_wait(ep, ... );// 读取新添加到列表里的元素个数,并且进行处理;n = read(eventfd, ... )// 遍历链表处理for each global_list:

一个消费者,一个生产者

#include <sys/eventfd.h>
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>int fd;
uint64_t buffer;void threadFunc(void)   //线程函数
{
int t;
while(1)
{t = read(fd,&buffer,sizeof(buffer));       //阻塞等待fd可读,及通知事件发生if(sizeof(buffer) < 8){printf("buffer错误\n");}printf("t = %llu   buffer = %llu\n",t,buffer);if(t == 8){printf("唤醒成功\n");}}    
}int main(void)
{uint64_t buf = 1;int ret;pthread_t tid;if((fd = eventfd(0,0)) == -1)   //创建事件驱动的文件描述符{printf("创建失败\n");}//创建线程if(pthread_create(&tid,NULL,threadFunc,NULL) < 0){printf("线程创建失败\n");}while(1){ret = write(fd,&buf,sizeof(buf));  //通过往fd里写东西来进行事件通知if(ret != 8){printf("写错误\n");}sleep(2);                           //没2s通知一次}return 0;
}

eventfd不支持非亲缘关系进程之间的事件通知,因为 eventfd 使用的内核数据结构属于文件描述符表,而文件描述符表只能在同一进程内共享。

eventfd 和 条件变量.和信号量都差不多, 都是可以通知唤醒

.如果只是简单的事件通知或计数,且不需要对共享资源进行保护,那么 eventfd 可能更为高效

如果需要等待特定条件满足或对共享资源进行保护,那么条件变量可能更适合

使用信号量需要进行加锁、解锁和等待操作,这可能引入一定的开销。尤其是在竞争激烈的场景下,频繁地获取和释放信号量可能导致性能下降

fcnt 给文件加读写锁,也可以用于进程间的同步

这篇关于eventfd的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/198767

相关文章

Nginx基础. eventfd, 异步IO 与epoll的相互协作

关于eventfd. 对于eventfd, 这里只是简单的讲它的功能. 看manpage就足够了, 其中的例子也很容易看懂 eventfd函数可以创建一个efd描述符, 该描述符在内核中维护着一个计数器counter. 在调用eventfd时, 可以传入参数指定内核中维护着的计数器的值. 如果这样调用: int efd = eventfd(0, 0);那么计数器值

从内核看eventfd的实现(基于5.9.9)

前言:eventfd是一种进程/线程通信的机制,他类似信号,不过eventfd只是一种通知机制,无法承载数据(eventfd承载的数据是8个字节),他的好处是简单并且只消耗一个fd。 我们先看个例子感受一下。 #include <sys/eventfd.h>#include <unistd.h>#include <inttypes.h> #include <stdlib.

asio监听eventfd

c++ - Does BOOST asio supports eventfd? like epoll - Stack Overflow asio的官方example并没有asio监听eventfd的例子,但asio支持posix::stream_descriptor,  如果将eventfd包装成posix::stream_descriptor,并注册到io_context里,那就应该支持了。

Linux下使用eventfd实现进程间信号量操作

1 前言 起源来自于单线程epoll_wait内部处理queue的思考,后来发现了linux支持一种自定义事件的fd,查找资料之余又发现了eventfd还有多进程信号灯的用处。。。本文翻译了eventfd的用法,并在文末附带demo进行实践。 2 介绍 eventfd 是 Linux 的一个系统调用,创建一个文件描述符用于事件通知,可在用户态编程使用。事件通知是基于计数器来实现,通过read

Linux中open/eventfd出现Too many open files的解决方法

最近在做Android P蓝牙协议栈的适配,由于原生的android系统在关闭蓝牙时,协议栈所在的进程会退出,所以协议栈中的资源释放做的很不完善,项目开发完成后做开关蓝牙的压力测试,100多次就会crash,原因是semaphore_new失败。 而semaphore_new失败的原因是Too many open files导致eventfd(...)返回INVALID_FD。 event