- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
Kqueue 在内核和用户空间之间提供高效的输入和输出事件管道。因此,可以修改事件过滤器以及接收未决事件,同时每次主事件循环迭代仅使用对 kevent(2) 的单个系统调用。这与效率较低的较旧的传统轮询系统调用(例如 poll(2) 和 select(2))形成对比,尤其是在轮询大量文件描述符上的事件时
听起来不错。我的服务器以 FreeBSD 为目标,我正在处理大量的网络套接字 fd——对它们全部使用 select() 并确定从谁那里读取数据。我宁愿使用 kevent() 调用来获得更高的性能,因为这就是它的用途!
我读过 man page for kevent on FreeBSD here但这对我来说很神秘,我找不到很好的资源来解释它。使用 kevent 替换 select 的示例可以解决我的问题,也可以帮助我更好地了解如何使用 kevent()。
最佳答案
首先,创建新的kqueue:
int kq=kqueue();
现在在kq中注册你的fd:
struct kevent kev;
kev.ident=your_fd;
kev.flags=EV_ADD | EV_CLEAR;
kev.filter=EVFILT_READ;
kev.fflags=0;
kev.data=0;
kev.udata=&your_data;
int res=kevent(kq,&kev,1,0,0,0);
最后,等待数据到达您的套接字:
struct kevent res_kevs[5];
int res=kevent(kq,0,0,res_kevs,5,0);
返回后,res_kevs[i].ident
将包含套接字的描述符,res_kevs[i].data
- 准备读取的字节数。
有关更多详细信息和功能,请参阅 man kevent。
关于c - 如何用 kevent() 替换 select() 以获得更高的性能?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5756402/
我想用信号通知工作线程 - 它应该停止等待事件并检查一些全局条件。我在 Linux 上使用 epoll_pwait,我想在 Mac OS 上执行相同的操作。 但是kqueue(2)手册说: EVFIL
更改列表中的无效项(或设置了 EV_RECEIPT 的项)将导致 kevent 返回设置了 EV_ERROR 标志的结果。还有什么其他条件会导致该标志? Google 搜索显示 EV_RECEIPT
假设我们有一个像这样的简单程序: int fd; kq = kqueue(); EV_SET(&kev, fd, EVFILT_VNODE, EV_ADD, 0, 0, NULL); kevent(k
我需要设计一个“等待事件对象”的东西,它可以接受不透明的事件对象并能够阻塞,直到其中一个事件被发出信号。它应该适用于 MacOS/Linux/Windows。所以对于 Linux/Windows 来说
我有一个 kevent ev 和一个 int sock = socket(...)。当我执行 ev.ident == sock 时,g++47 警告我 warning: comparison betw
我尝试在文件上使用 kqeue 和 kevent,当我的文件被修改时,我将更新我的软件。当我的文件被删除时,我删除了我软件中的链接。 所以我初始化kqueue void myfct(char * pa
来自Kqueue Wikipedia Page : Kqueue 在内核和用户空间之间提供高效的输入和输出事件管道。因此,可以修改事件过滤器以及接收未决事件,同时每次主事件循环迭代仅使用对 keven
我正在分析一个程序,其中绝大多数 (86%) 的时间花在两个运行时函数上:kevent 和 selectgo。我理解select,但是我不知道kevent是什么(所以我不知道从哪里开始优化): Sho
我有一堆文件描述符的列表,我已经为这些文件描述符创建了 kevent,我正在尝试弄清楚是否有任何方法可以获取准备好进行读取或写入访问的文件描述符的数量。 有什么方法可以获取“就绪”文件描述符的列表,就
这在 Swift 3.1 中有效,但是一旦我切换到 Xcode 9,它就会停止编译。这是示例代码: let kq: Int32 = 0 let changelist: UnsafePointer! =
在我的应用程序中,我需要监视新文件的目录。流量非常大,每秒至少会出现数百个新文件。目前我正在使用这种想法的繁忙循环: while True: time.sleep(0.2) if len(os
我有一个监听单个 UDP 套接字的线程,但也需要偶尔唤醒以执行其他任务。这些任务由时间的流逝或其他线程上的事件触发。我目前的设计是使用 select() 超时值作为调度定时器,当我需要从另一个线程唤醒
我正在将curl集成到基于kqueue的异步I/O事件循环中。 libcurl 具有出色的 API,可用于集成到应用程序事件循环中。 您为 libcurl 提供两个回调,一个用于设置计时器(用于限制请
今天我将一些代码从 select() 移植到 kqueue(),我注意到 kevent() 似乎没有 select() 的“异常设置”功能的模拟。 也就是说,select()的函数签名是: int s
我是一名优秀的程序员,十分优秀!