IO模型：阻塞和非阻塞

一、五种IO模型------读写外设数据的方式

  1. 阻塞: 不能操作就睡觉

    在这里插入图片描述

  2. 非阻塞：不能操作就返回错误

    在这里插入图片描述

  3. 多路复用：委托中介监控

    在这里插入图片描述

  4. 信号驱动：让内核如果能操作时发信号，在信号处理函数中操作

    在这里插入图片描述

  5. 异步IO：向内核注册操作请求，内核完成操作后发通知信号

    在这里插入图片描述

二、阻塞与非阻塞

应用层：

​ open时由O_NONBLOCK指示read、write时是否阻塞

​ open以后可以由fcntl函数来改变是否阻塞：

flags = fcntl(fd,F_GETFL,0);
flags |= O_NONBLOCK;
fcntl(fd, F_SETFL, flags);

驱动层：通过等待队列

wait_queue_head_t //等待队列头数据类型init_waitqueue_head(wait_queue_head_t *pwq) //初始化等待队列头wait_event_interruptible(wq,condition)
/*
功能：条件不成立则让任务进入浅度睡眠，直到条件成立醒来wq:等待队列头condition：C语言表达式
返回：正常唤醒返回0，信号唤醒返回非0（此时读写操作函数应返回-ERESTARTSYS）
*/wait_event(wq,condition) //深度睡眠wake_up_interruptible(wait_queue_head_t *pwq)wake_up(wait_queue_head_t *pwq)/*
1. 读、写用不同的等待队列头rq、wq
2. 无数据可读、可写时调用wait_event_interruptible(rq、wq,条件)
3. 写入数据成功时唤醒rq，读出数据成功唤醒wq
*/

示例：
mychar.h

#ifndef MY_CHAR_H
#define MY_CHAR_H#include <asm/ioctl.h>#define MY_CHAR_MAGIC 'c'#define MYCHAR_IOCTL_GET_MAXLEN _IOR(MY_CHAR_MAGIC, 1, int *)
#define MYCHAR_IOCTL_GET_CURLEN _IOR(MY_CHAR_MAGIC, 2, int *)#endif

mychar.c

#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/fs.h>
#include <linux/cdev.h>
#include <linux/wait.h>
#include <linux/sched.h>
#include <asm/uaccess.h>
#include <asm/ioctl.h>#include "mychar.h"#define BUF_LEN 100int major = 11;					//主设备号
int minor = 0;					//次设备号
int char_num = 1;				//设备号数量struct mychar_dev 
{struct cdev mydev;char mydev_buf[BUF_LEN];int curlen;wait_queue_head_t rq;wait_queue_head_t wq;
};
struct mychar_dev gmydev;int mychar_open (struct inode *pnode, struct file *pfile)//打开设备
{pfile->private_data = (void *) (container_of(pnode->i_cdev, struct mychar_dev, mydev));printk("open\n");return 0;
}int mychar_close(struct inode *pnode, struct file *pfile)//关闭设备
{printk("close\n");return 0;
}ssize_t mychar_read (struct file *pfile, char __user *puser, size_t count, loff_t *p_pos) {struct mychar_dev *pmydev = (struct mychar_dev *)pfile->private_data;int size = 0;int ret = 0;/* 判断是否有数据可读 */if(pmydev->curlen <= 0) {if(pfile->f_flags & O_NONBLOCK) { //非阻塞printk("O_NONBLOCK Not Data Read\n");return -1;} else { //阻塞/* 睡眠 当curlen>0 时返回 */ret = wait_event_interruptible(pmydev->rq, pmydev->curlen > 0);if(ret) {return -ERESTARTSYS;}}}// 确定要读取的数据长度，如果请求大于设备当前数据长度，则读取全部可用数据if (count > pmydev->curlen) {size = pmydev->curlen;}else {size = count;}// 将设备数据复制到用户空间缓冲区ret = copy_to_user(puser, pmydev->mydev_buf, size);if(ret) {printk("copy_to_user failed\n");return -1;}// 移动设备内部缓冲区，去除已读取的数据memcpy(pmydev->mydev_buf, pmydev->mydev_buf + size, pmydev->curlen - size);pmydev->curlen -= size;wake_up_interruptible(&pmydev->wq);// 返回实际读取的字节数return size;
}ssize_t mychar_write (struct file *pfile, const char __user *puser, size_t count, loff_t *p_pos) {struct mychar_dev *pmydev = (struct mychar_dev *)pfile->private_data;int size = 0;int ret = 0;if(pmydev->curlen >= BUF_LEN) {if(pfile->f_flags & O_NONBLOCK) { //非阻塞printk("O_NONBLOCK Can Not Write Data\n");return -1;} else { //阻塞ret = wait_event_interruptible(pmydev->wq, pmydev->curlen < BUF_LEN);if(ret) {return -ERESTARTSYS;}}}// 确定要写入的数据长度，如果请求大于设备缓冲区剩余空间，则写入剩余空间大小if (count > BUF_LEN - pmydev->curlen) {size = BUF_LEN - pmydev->curlen;}else {size = count;}// 从用户空间复制数据到设备缓冲区ret = copy_from_user(pmydev->mydev_buf + pmydev->curlen, puser, size);if(ret) {printk("copy_from_user failed\n");return -1;}// 更新设备缓冲区中的数据长度pmydev->curlen += size;/* 唤醒读阻塞 */wake_up_interruptible(&pmydev->rq);// 返回实际写入的字节数return size;
}long mychar_ioctl(struct file *pfile, unsigned int cmd, unsigned long arg) 
{struct mychar_dev *pmydev = (struct mychar_dev *)pfile->private_data;int __user *pret = (int *)arg;int maxlen = BUF_LEN;int ret = 0;switch(cmd) {case MYCHAR_IOCTL_GET_MAXLEN:ret = copy_to_user(pret, &maxlen, sizeof(int));if(ret) {printk("copy_from_user failed\n");return -1;}break;case MYCHAR_IOCTL_GET_CURLEN:ret = copy_to_user(pret, &pmydev->curlen, sizeof(int));if(ret) {printk("copy_from_user failed\n");return -1;}break;default:printk("The is a know\n");return -1;}return 0;
}struct file_operations myops = {.owner = THIS_MODULE,.open = mychar_open,.read = mychar_read,.write = mychar_write,.unlocked_ioctl = mychar_ioctl,
};int __init mychar_init(void) 
{int ret = 0;dev_t devno = MKDEV(major, minor);/* 手动申请设备号 */ret = register_chrdev_region(devno, char_num, "mychar");if (ret) {/* 动态申请设备号 */ret = alloc_chrdev_region(&devno, minor, char_num, "mychar");if(ret){printk("get devno failed\n");return -1;}/*申请成功 更新设备号*/major = MAJOR(devno);}/* 给struct cdev对象指定操作函数集 */cdev_init(&gmydev.mydev, &myops);/* 将struct cdev对象添加到内核对应的数据结构中 */gmydev.mydev.owner = THIS_MODULE;cdev_add(&gmydev.mydev, devno, char_num);/* 初始化 */init_waitqueue_head(&gmydev.rq);init_waitqueue_head(&gmydev.wq);return 0;
}void __exit mychar_exit(void) 
{dev_t devno = MKDEV(major, minor);printk("exit %d\n", devno);/* 从内核中移除一个字符设备 */cdev_del(&gmydev.mydev);/* 回收设备号 */unregister_chrdev_region(devno, char_num);}MODULE_LICENSE("GPL");
module_init(mychar_init);
module_exit(mychar_exit);

testmychar_blockwait.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
#include <sys/ioctl.h>#include "mychar.h"
int main(int argc, char *argv[])
{int fd = -1;char buf[100];if(argc < 2) {printf("The argument is too few\n");return -1;}fd = open(argv[1], O_RDWR);if(fd < 0) {perror("open");return -1;}memset(buf, 'C', sizeof(buf));if ( (write(fd, buf, strlen(buf)) ) < 0 ) {printf("write failed\n");return -1;}close(fd);fd = -1;return 0;
}

testmychar_blockread.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>
#include <sys/ioctl.h>#include "mychar.h"
int main(int argc, char *argv[])
{int fd = -1;char buf[32] = "";int ret = 0;if(argc < 2) {printf("The argument is too few\n");return -1;}fd = open(argv[1], O_RDWR);if(fd < 0) {perror("open");return -1;}if ( (read(fd, buf, sizeof(buf)) ) < 0 ) {printf("read failed\n");return -1;} else {printf("buf = %s\n", buf);}close(fd);fd = -1;return 0;
}

运行结果：
在这里插入图片描述
在这里插入图片描述

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

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

相关文章

【微服务部署】08-监控与告警

【微服务部署】08-监控与告警

文章目录 1. PrometheusOperator1.1 优势1.2 配置脚本1.3 部署脚本 2. Granfana实现监控看板2.1 Granfana核心特性2.2 部署文件 目前Kubernetes中最流行的监控解决方案是使用Prometheus和AlertManager 1. PrometheusOperator 1.1 优势 自动化安装将配置资源化灵活的扩展能力 …
阅读更多...
ctfshow—萌新—杂项1

ctfshow—萌新—杂项1

0x00 前言 CTF 加解密合集CTF Web合集 0x01 题目 0x02 Write Up ed400fbcff269bd9c65292a97488168a 首先这是一个md5&#xff0c;然后在线解密一下&#xff0c;解密站点 https://www.somd5.com/ 解密出来的内容是helloctf 然后去掉ctf就是最终的答案 结果就是flag{hello}…
阅读更多...
023 - STM32学习笔记 - 扩展外部SDRAM（二） - 扩展外部SDRAM实验

023 - STM32学习笔记 - 扩展外部SDRAM（二） - 扩展外部SDRAM实验

023- STM32学习笔记 - 扩展外部SDRAM&#xff08;一&#xff09; - 扩展外部SDRAM实验 本节内容中要配置的引脚很多&#xff0c;如果你用的开发板跟我的不一样&#xff0c;请详细参照STM32规格书中说明对相关GPIO引脚进行配置。 先提前对本届内容的变成步骤进行总结如下&…
阅读更多...
supervisorctl（-jar）启动配置设置NACOS不同命名空间

supervisorctl（-jar）启动配置设置NACOS不同命名空间

背景 由于需要在上海服务器上面配置B测试环境&#xff0c;原本上面已有A测试环境&#xff0c;固需要将两套权限系统分开 可以使用不同的命名空间来隔离启动服务 注&#xff1a;本文章均不涉及公司机密 1、新建命名空间 命名空间默认会有一个public&#xff0c;并且不能删除&a…
阅读更多...
【QT】信号和槽（15）

【QT】信号和槽（15）

前面的内容说了很多不同的控件如何使用&#xff0c;今天来看下QT的核心&#xff0c;信号与槽&#xff08;Signals and slots&#xff09;&#xff01; 简单理解一下&#xff0c;就是我们的信号与槽连接上了之后&#xff0c;发射一个信号给到槽&#xff0c;槽函数接收到了这个信…
阅读更多...
数据库(一) 基础知识

数据库(一) 基础知识

概述 数据库是按照数据结构来组织,存储和管理数据的仓库 数据模型 数据库系统的核心和基础是数据模型&#xff0c;数据模型是严格定义的一组概念的集合。因此数据模型一般由数据结构、数据操作和完整性约束三部分组成。数据模型主要分为三种:层次模型&#xff0c;网状模型和关…
阅读更多...
docker linux（centos 7） 安装

docker linux（centos 7） 安装

这是个目录 1:安装1:手动安装(适用于centos7)之一2:手动安装(适用于centos7)之二3&#xff1a;一键安装docker4:二进制安装1&#xff1a;下载二进制包2&#xff1a;解压3&#xff1a;移动文件4&#xff1a;后台运行docker5&#xff1a;测试 dicker命令表999&#xff1a;遇到的问…
阅读更多...
java解析html

java解析html

目录 场景描述一.引入依赖二.调用接口响应回来的html三.测试代码 场景描述 我调用外部接口&#xff0c;但是返回来的数据是html的格式&#xff0c;所以我就需要进行处理来获得我想要的数据。我使用的是jsoup。 一.引入依赖 <dependency><groupId>org.jsoup</gr…
阅读更多...
Go 使用 Gorm 将操作信息集成到链路跟踪 Jaeger，进行增删改查使用举例，并做可视化UI界面展示（附源码）

Go 使用 Gorm 将操作信息集成到链路跟踪 Jaeger，进行增删改查使用举例，并做可视化UI界面展示（附源码）

Go 使用 Gorm 将操作信息集成到链路跟踪 Jaeger，进行增删改查使用举例（附源码）。 为了增强程序的可观测性，方便问题定位，在发起数据库操作请求时我们也可以调用代码统一集成链路跟踪的能力，Jaeger 是当今比较流行的选择。使用 Gorm 来将操作信息集成到 Jaeger 中。 全面…
阅读更多...
C++笔记之临时变量与临时对象与匿名对象

C++笔记之临时变量与临时对象与匿名对象

C笔记之临时变量与临时对象与匿名对象 code review! 文章目录 C笔记之临时变量与临时对象与匿名对象1.C中的临时变量指的是什么&#xff1f;2.C中的临时对象指的是什么&#xff1f;3.C中临时对象的作用是什么&#xff1f;什么时候要用到临时对象?4.给我列举具体的例子说明临…
阅读更多...
回归预测 | MATLAB实现CSO-ELM布谷鸟算法优化极限学习机多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现CSO-ELM布谷鸟算法优化极限学习机多输入单输出回归预测（多指标，多图）

回归预测 | MATLAB实现CSO-ELM布谷鸟算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现CSO-ELM布谷鸟算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09;效果一览基本介…
阅读更多...
html中如何用vue语法，并使用UI组件库 ，html中引入vue+ant-design-vue或者vue+element-plus

html中如何用vue语法，并使用UI组件库 ，html中引入vue+ant-design-vue或者vue+element-plus

html中如何用vue语法&#xff0c;并使用UI组件库 前言 先说一下本次应用的场景&#xff0c;本次项目中&#xff0c;需要引入github中别人写好的插件&#xff0c;插件比较大&#xff0c;没有方法直接在自己项目中&#xff0c;把别人的项目打包合并生成html&#xff08;类似于前…
阅读更多...
Muscles|Tissue —— 介绍

Muscles|Tissue —— 介绍

BETA —— 此功能仍然在开发测试中&#xff0c;相关文档很少或没有&#xff0c;使用时需注意&#xff1b; 可使用Vellum-based Muscles & Tissue系统&#xff0c;模拟角色的肌肉、组织、及皮肤&#xff1b;可轻易导入模型和动画&#xff0c;并快速配置解算模拟&#xff1b;…
阅读更多...
提高企业会计效率，选择Manager for Mac(企业会计软件)

提高企业会计效率，选择Manager for Mac(企业会计软件)

作为一家企业&#xff0c;良好的财务管理是保持业务运转的关键。而选择一款适合自己企业的会计软件&#xff0c;能够帮助提高会计效率、减少错误和节约时间。在众多的选择中&#xff0c;Manager for Mac(企业会计软件)是一款值得考虑的优秀软件。 首先&#xff0c;Manager for…
阅读更多...
Java流式编程详细介绍

Java流式编程详细介绍

文章目录 1. 流式编程介绍2. 过滤2.1 filter2.2 distinct2.3 limit2.4 sorted2.5 skip 3. 映射3.1 map3.2 flatmap 4 查找4.1 allMatch4.2 anyMatch4.3 noneMatch4.4 findFirst4.5 findAny 5. 归约6. 收集6.1 counting6.2 maxBy,minBy6.3 summingInt、summingLong、summingDoub…
阅读更多...
【jvm】运行时数据区

【jvm】运行时数据区

目录 一、运行时数据区一、作用二、说明三、线程共用与私有区域 一、运行时数据区 一、作用 1.内存是非常重要的系统资源&#xff0c;是硬盘和CPU 的中间仓库及桥梁&#xff0c;承载着操作系统和应用程序的实时运行。JVM内存布局规定了Java在运行过程中内存申请、分配、管理的策…
阅读更多...
分布式集群——搭建Hadoop环境以及相关的Hadoop介绍

分布式集群——搭建Hadoop环境以及相关的Hadoop介绍

系列文章目录 分布式集群——jdk配置与zookeeper环境搭建 分布式集群——搭建Hadoop环境以及相关的Hadoop介绍 文章目录 前言 一 hadoop的相关概念 1.1 Hadoop概念 补充&#xff1a;块的存储 1.2 HDFS是什么 1.3 三种节点的功能 I、NameNode节点 II、fsimage与edits…
阅读更多...
Kubernetes(K8s 1.28.x)部署---超详细

Kubernetes(K8s 1.28.x)部署---超详细

目录 一、基础环境配置&#xff08;所有主机均要配置&#xff09; 1、配置IP地址和主机名、hosts解析 2、关闭防火墙、禁用SELinux 3、安装常用软件 4、配置时间同步 5、禁用Swap分区 6、修改linux的内核参数 7、配置ipvs功能 二、容器环境操作 1、定制软件源 2、安…
阅读更多...
色温曲线坐标轴的选取：G/R、G/B还是R/G、B/G ？

色温曲线坐标轴的选取：G/R、G/B还是R/G、B/G ？

海思色温曲线坐标 Mstar色温曲线坐标 高通色温曲线坐标 联咏色温曲线坐标 查看各家白平衡调试界面&#xff0c;比如海思、Mstart、高通等调试资料&#xff0c;白平衡模块都是以R/G B/G作为坐标系的两个坐标轴&#xff0c;也有方案是以G/R G/B作为坐标系的两个坐标轴。 以G/R G…
阅读更多...
Fooocus启动时modules报错的解决方法

Fooocus启动时modules报错的解决方法

原理&#xff1a;是由于其他程序的安装导致modules的版本不对&#xff0c;先卸载现有版本&#xff0c;再运行run.bat让其自动安装响应的modules版本。 1、cmd运行windows dos终端。 2、将Fooocus_win64_1-1-1035文件夹备份&#xff0c;rename为Fooocus_win64_1-1-1035backup文…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023