IO多路复用之epoll

一、epoll函数族

1. 函数epoll_creat: 该函数生成一个epoll专用的文件描述符

#include <sys/epoll.h>
int epoll_creae(int size);  //epoll上能关注的最大描述符数

 

2. epoll_ctl:用于控制某个epoll文件描述符事件,可以注册、修改、删除

#include <sys/epoll.h>
int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); 

参数:

  • efd:epoll_create函数的返回值
  • op:对该监听红黑树所做操作
  • fd:待监听的fd
  • event:struct epoll_event 结构体
typedef union epoll_data 
{void*      ptr;int        fd;  //对应监听的fduint32_t   u32;uint64_t   u64;
} epoll_data_t;struct epoll_event 
{uint32_t     events;      /* epoll事件 */epoll_data_t data;        /* 用户数据 */
};

 

3. 等待IO事件发生 - 可以设置阻塞的函数

#include <sys/epoll.h>
int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);

参数:

  • efds:epoll_create函数的返回值
  • events:传出参数【数组】满足监听条件的哪些fd结构体
  • maxevents:数组元素的总个数(1024) struct epoll_events [1024]:

 

二、LT和ET模式

epoll对文件描述符的操作方式有两种工作模式:LT模式(Level Trigger,水平触发) 和ET模式(Edge Trigger,边缘触发)。

  •  LT模式:当epoll_wait检测到其上有事件发生并将此事件通知应用程序后,应用程序可以不立即处理该事件,这样,当应用程序下一次调用epoll_wait时,epoll_wait还会向应用程序通告此事件,直到该事件被处理。((缓冲区剩余未读尽的数据会导致epoll_wait返回. )
  • ET模式:当epoll_wait检测到其上有事件发生并将此事件通知应用程序后,应用程序必须立即处理该事件,因为后续的epoll_wait调用将不在向应用程序通告此事件。

1. 水平触发
 对于读操作

  • 只要缓冲内容不为空,LT模式返回读就绪。

 对于写操作

  • 只要缓冲区还不满,LT模式会返回写就绪。

2. 边缘触发
 对于读操作

  • 当缓冲区由不可读变为可读的时候,即缓冲区由空变为不空的时候。
  • 当有新数据到达时,即缓冲区中的待读数据变多的时候。
  • 当缓冲区有数据可读,且应用进程对相应的描述符进行EPOLL_CTL_MOD 修改EPOLLIN事件时。

对于写操作

  • 当缓冲区由不可写变为可写时。
  • 当有旧数据被发送走,即缓冲区中的内容变少的时候。
  • 当缓冲区有空间可写,且应用进程对相应的描述符进行EPOLL_CTL_MOD 修改EPOLLOUT事件时。

三、代码清单

1. 测试代码

#include <stdio.h>
#include <stdlib.h>
#include <sys/epoll.h>
#include <errno.h>
#include <unistd.h>#define MAXLINE 10int main(int argc, char *argv[])
{int efd, i;int pfd[2];pid_t pid;char buf[MAXLINE], ch = 'a';pipe(pfd);pid = fork();if (pid == 0)  //子写{             close(pfd[0]);while (1) {     for (i = 0; i < MAXLINE/2; i++) //aaaa\nbuf[i] = ch;buf[i-1] = '\n';ch++;for (; i < MAXLINE; i++) //bbbb\nbuf[i] = ch;buf[i-1] = '\n';ch++;write(pfd[1], buf, sizeof(buf)); //aaaa\nbbbb\nsleep(5);}close(pfd[1]);} else if (pid > 0)  //父读{       struct epoll_event event;struct epoll_event resevent[10];  //epoll_wait就绪返回eventint res, len;close(pfd[1]);efd = epoll_create(10);event.events = EPOLLIN | EPOLLET;    // ET 边沿触发//event.events = EPOLLIN;            // LT 水平触发 (默认)event.data.fd = pfd[0];epoll_ctl(efd, EPOLL_CTL_ADD, pfd[0], &event);while (1) {res = epoll_wait(efd, resevent, 10, -1);printf("res %d\n", res);if (resevent[0].data.fd == pfd[0]) {len = read(pfd[0], buf, MAXLINE/2);write(STDOUT_FILENO, buf, len);}}close(pfd[0]);close(efd);} else {perror("fork");exit(-1);}return 0;
}

 

 


 

 

  •  

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/385501.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

26. 删除排序数组中的重复项

给定一个排序数组&#xff0c;你需要在原地删除重复出现的元素&#xff0c;使得每个元素只出现一次&#xff0c;返回移除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须在原地修改输入数组并在使用 O(1) 额外空间的条件下完成。 示例 1: 给定数组 nums [1,1,2], …

Leetcode 31. Pow(x, n) 解题报告

class Solution {public:double myPow(double x, int n) {double res 1.0;for(int i n; i ! 0; i / 2){if(i % 2 ! 0)res * x;x * x;}return n < 0 ? 1 / res : res;} };

572. 另一个树的子树

给定两个非空二叉树 s 和 t&#xff0c;检验 s 中是否包含和 t 具有相同结构和节点值的子树。s 的一个子树包括 s 的一个节点和这个节点的所有子孙。s 也可以看做它自身的一棵子树。 示例 1: 给定的树 s: 3/ \4 5/ \1 2给定的树 t&#xff1a; 4 / \1 2返回 true&#x…

二叉树中序遍历的三种方法

二叉树是一种重要的数据结构&#xff0c;对二叉树的遍历也很重要。这里简单介绍三种二叉树中序遍历的方法。二叉树的中序遍历就是首先遍历左子树&#xff0c;然后访问当前节点&#xff0c;最后遍历右子树。对于下面的二叉树&#xff0c;中序遍历结果如下&#xff1a; 结果&…

reverse函数:反转容器内容

reverse函数可以反转一个容器中的内容&#xff0c;包含在<algorithm>库中。 1、函数原型 reverse函数等同于下面的代码&#xff1a; template <class BidirectionalIterator> void reverse (BidirectionalIterator first, BidirectionalIterator last) {while ((…

服务器框架

一、Reactor模式 Reactor模式&#xff0c;它要求主线程&#xff08;I/O处理单元&#xff09;只负责监听文件描述符上是否有事件发生&#xff0c;有的话就立即将该事件通知工作线程&#xff08;逻辑单元&#xff09;。除此之外&#xff0c;主线程&#xff08;I/O处理单元&#…

使用CreateFile读写文件

微软提供了强大的文件读写操作的编程接口&#xff0c;所以可以通过调用API函数实现文件的读写操作。这里通过CreateFile函数来实现。 要对文件进行读写操作&#xff0c;首先要调用CreateFile函数打开或者创建文件&#xff0c;函数具体格式如下&#xff1a; HANDLE CreateFile(…

Leetcode 9. 回文数(Palindrome Number)

判断一个整数是否是回文数。回文数是指正序&#xff08;从左向右&#xff09;和倒序&#xff08;从右向左&#xff09;读都是一样的整数。 示例 1: 输入: 121 输出: true示例 2: 输入: -121 输出: false 解释: 从左向右读, 为 -121 。 从右向左读, 为 121- 。因此它不是一个…

使用CreateThread函数创建线程

线程是进程中的一个实体&#xff0c;是被系统独立调度和分派的基本单位。一个进程可以拥有多个线程&#xff0c;但是一个线程必须有一个进程。线程自己不拥有系统资源&#xff0c;只有运行所必须的一些数据结构&#xff0c;但它可以与同属于一个进程的其它线程共享进程所拥有的…

Leetcode 16. 最接近的三数之和(3Sum Closest)

解法一&#xff1a; class Solution { public:int threeSumClosest(vector<int>& nums, int target) {int closest nums[0] nums[1] nums[2];int diff abs(closest - target);sort(nums.begin(), nums.end());for (int i 0; i < nums.size() - 2; i) {int…

BMP格式详解

BMP&#xff08;全称Bitmap&#xff09;是Windows操作系统中的标准图像文件格式&#xff0c;可以分成两类&#xff1a;设备相关位图&#xff08;DDB&#xff09;和设备无关位图&#xff08;DIB&#xff09;&#xff0c;使用非常广。它采用位映射存储格式&#xff0c;除了图像深…

Leetcode 5. 最长回文子串(Longest Palindromic Substring)

推荐理由&#xff1a;暴力解法太 naive&#xff0c;中心扩散不普适&#xff0c;Manacher 就更不普适了&#xff0c;是专门解这个问题的方法。而用动态规划我认为是最有用的&#xff0c;可以帮助你举一反三的方法。 补充说明&#xff1a;Manacher 算法有兴趣的朋友们可以了解一…

请求转发与请求重定向的区别

请求转发&#xff1a; 请求转发&#xff0c;即request.getRequestDispatcher().forward()&#xff0c;是一种服务器的行为&#xff0c;客户端只有一次请求&#xff0c;服务器端转发后会将请求对象保存&#xff0c;地址栏中的URL地址不会改变&#xff0c;得到响应后服务器端再将…

StringBuilder详解

1、简介 StringBuilder和StringBuffer一样&#xff0c;都是继承自抽象类AbstractStringBuilder类&#xff0c;也是一个可变的字符序列。StringBuilder和StringBuffer非常相似&#xff0c;甚至有互相兼容的API&#xff0c;不过&#xff0c;StringBuilder不是线程安全的&#xf…

【线程】互斥锁

一、互斥锁 1. 函数原型 pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr); pthread_mutex_destroy(pthread_mutex_t *mutex); 分析&#xff1a; pthread_mutex_t 类型&#xff0c;其本质是一个结构体&#xff0c;为简化…

ArrayList详解

1、简介 ArrayList是Java集合框架中的一个重要的类&#xff0c;它继承于AbstractList&#xff0c;实现了List接口&#xff0c;是一个长度可变的集合&#xff0c;提供了增删改查的功能。集合中允许null的存在。ArrayList类还是实现了RandomAccess接口&#xff0c;可以对元素进行…

【进程】进程组

一、进程组 1. 进程组 &#xff08;1&#xff09;进程组&#xff0c;也称之为作业&#xff0c;BSD与1980年前后向UNIX中增加的一个新特性&#xff0c;代表一个或多个进程的集合。每个进程都属于一个进程组&#xff0c;在waitpid函数和kill函数的参数中都曾经使用到&#xff0c…

函数wait、waitpid、孤儿进程、僵尸进程

一、函数wait、waitpid 一个进程在终止时会关闭所有文件描述符&#xff0c;释放在用户空间释放的内存&#xff0c;但它的PCB还保留着&#xff0c;内核在其中保存一些信息&#xff1a;如果是正常终止时则保存着退出状态&#xff0c;如果是异常终止则保存着导致该进程终止的信号是…

MySQL中的字符集与字符序

这篇文章详细介绍一下MySQL中的字符集和字符序相关的问题&#xff0c;里里外外地了解一下字符集和字符序的方方面面&#xff0c;同时重点说明一下开发中需要注意的问题。 文章基于MySQL 8.0&#xff0c;也会涉及到5.7版本。主要参考MySQL手册&#xff1a;https://dev.mysql.com…

MySQL中的JSON

从5.7.8开始&#xff0c;MySQL开始支持JSON类型&#xff0c;用于存储JSON数据。 JSON类型的加入模糊了关系型数据库与NoSQL之间的界限&#xff0c;给日常开发也带来了很大的便利。 这篇文章主要介绍一下MySQL中JSON类型的使用&#xff0c;主要参考MySQL手册&#xff1a;https…