Linux 阻塞等待框架

在 Linux 设备驱动开发中,阻塞机制 是处理资源暂时不可用(如设备未准备好数据、缓冲区满等)的核心手段。驱动程序可以将被阻塞的进程设置成休眠状态,然后,在资源可用后,再将该进程唤醒

在 Linux 驱动开发中,休眠(等待)机制分为 简单休眠(使用 wait_event系列宏)和 高级休眠(手动使用 prepare_to_wait/finish_wait),它们的核心区别在于封装程度和灵活性。

其中,"简单休眠"由"高级休眠"封装而来,可以当做"高级休眠"的语法糖。

本质区别对比:
在这里插入图片描述
如何选择?

  • 优先使用简单休眠,比如:只需要等待单一条件、不需要在等待过程中执行额外操作;
  • 当需要实现非标准的唤醒条件(如同时等待多个事件)、需要更精细的性能优化时必须使用高级休眠;
  • 现代内核更推荐使用 wait_event_interruptible 等封装宏。

简单休眠

最佳框架:

ssize_t scullpipe_read(struct file *filp, char __user *buf, size_t count, loff_t *f_pos)
{struct scull_pipe *dev = filp->private_data;int ret;// 检查参数if (count == 0)return 0;if (mutex_lock_interruptible(&dev->lock))return -ERESTARTSYS;// 如果缓冲区为空,进入休眠等待while (read_buffer_empty(dev)) {mutex_unlock(&dev->lock);  // 必须释放锁再休眠if (filp->f_flags & O_NONBLOCK)return -EAGAIN;ret = wait_event_interruptible(dev->inq, !read_buffer_empty(dev));if (ret == -ERESTARTSYS)  // 被信号打断return -ERESTARTSYS;// 被唤醒后再次获取锁再判断if (mutex_lock_interruptible(&dev->lock))return -ERESTARTSYS;}// 此时缓冲区有数据,可以读取ret = copy_data_to_user(dev, buf, count);mutex_unlock(&dev->lock);return ret;
}

高级休眠

最佳框架:

ssize_t mydev_read(struct file *filp, char __user *buf, size_t count, loff_t *ppos)
{struct my_device *dev = filp->private_data;DEFINE_WAIT_FUNC(wait, default_wake_function);ssize_t ret = 0;if (mutex_lock_interruptible(&dev->lock))return -ERESTARTSYS;while (!data_available(dev)){mutex_unlock(&dev->lock);/* 非阻塞模式 */if (filp->f_flags & O_NONBLOCK) return -EAGAIN;if (prepare_to_wait_event(&dev->inq, &wait, TASK_INTERRUPTIBLE))return -ERESTARTSYS;  		// 信号/* 在当前进程挂入等待队列后,再次确认条件*/if (!data_available(dev))schedule();if (signal_pending(current)) {ret = -ERESTARTSYS;  		// 信号break;}if (mutex_lock_interruptible(&dev->lock)){ret = -ERESTARTSYS;break;}}finish_wait(&dev->inq, &wait);if(ret)return ret;// 现在有锁,并且数据有效,下面进行读操作count = min(count, xxx);if (copy_to_user(buf, dev->rp, count) ){mutex_unlock(&dev->lock);return -EFAULT;}mutex_unlock(&dev->lock);return count;
}
  1. DEFINE_WAIT_FUNC(wait, default_wake_function) :定义一个 等待队列项 (wait_queue_entry),并初始化其唤醒回调函数
    当前进程创建一个“代表自己”的等待队列项 ( wait ),并指定当条件满足(通常是资源可用)时如何唤醒自己(通过 default_wake_function 函数)。
    // 源码 (include/linux/wait.h):
    #define DEFINE_WAIT_FUNC(name, function)              \wait_queue_entry_t name = {                       \.private    = current,                        \.func      = function,                        \.entry     = LIST_HEAD_INIT((name).entry),    \}
    
  2. signal_pending(current):检查当前进程 (current) 是否有待处理的信号。实现可中断的睡眠 (TASK_INTERRUPTIBLE)。避免进程在需要响应信号(如 Ctrl+C)时被无谓地阻塞。
    • 返回非零值( true )表示有挂起的信号需要处理。此时,进程不应继续睡眠,而应退出等待循环并返回 -ERESTARTSYS 错误码给用户空间(让用户空间有机会处理信号)。
    • 通常在调用 schedule() 让出 CPU 之前检查,避免信号丢失导致多余阻塞。这也符合现代 Linux 关于"信号优先响应"的设计原则。
  3. prepare_to_wait_event(&dev->inq, &wait, state):准备当前进程进入睡眠状态。核心任务是将等待项 (&wait) 添加到设备的等待队列头 (&dev->inq),并设置当前进程的状态 (根据参数 state,通常是 TASK_INTERRUPTIBLE, 表示可被信号唤醒的睡眠)。
    正式将当前进程“注册”到设备的等待队列 (参数 dev->inq),并标记为睡眠状态,为安全让出 CPU 做准备。
    • 它将等待项 (wait) 安全地(加锁)添加到等待队列 ()。
    // 简化逻辑,kernel/sched/wait.c
    void prepare_to_wait_event(wait_queue_head_t *wq_head, wait_queue_entry_t *wait, int state)
    {unsigned long flags;wait->flags &= ~WQ_FLAG_EXCLUSIVE; 			// 通常是非独占等待spin_lock_irqsave(&wq_head->lock, flags); 	// 获取队列锁if (list_empty(&wait->entry)) 				// 防止重复添加__add_wait_queue(wq_head, wait); 		// 将等待项加入队列尾部set_current_state(state); 		// 设置当前进程状态 (TASK_INTERRUPTIBLE/TASK_UNINTERRUPTIBLE)spin_unlock_irqrestore(&wq_head->lock, flags); // 释放队列锁
    }
    
  4. schedule():主动让出 CPU,触发进程调度。当前进程进入睡眠状态,内核选择另一个就绪进程运行。
    • 调用 schedule() 时,进程状态必须已经是 TASK_INTERRUPTIBLETASK_UNINTERRUPTIBLE(由 prepare_to_wait_event 设置)。调度器根据此状态将进程移出运行队列。
    • 进程在此处“睡着”。
    • 当进程被唤醒时(通常是因为等待的条件满足或有信号到达),执行会从 schedule() 调用之后的下一条语句继续。
  5. finish_wait(&dev->inq, &wait):清理等待状态。将等待项从等待队列中移除,并将当前进程状态设置回 TASK_RUNNING。
    // 简化逻辑,kernel/sched/wait.c
    void finish_wait(wait_queue_head_t *wq_head, wait_queue_entry_t *wait)
    {unsigned long flags;set_current_state(TASK_RUNNING); 			// 重要:恢复为可运行状态if (!list_empty_careful(&wait->entry)) { 	// 如果还在队列里spin_lock_irqsave(&wq_head->lock, flags);list_del_init(&wait->entry); 			// 从等待队列中移除spin_unlock_irqrestore(&wq_head->lock, flags);}
    }
    

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

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

相关文章

PCIe RAS学习专题(3):AER内核处理流程梳理

目录 一、AER内核处理整体流程梳理 二、AER代码重要部分梳理 1、AER初始化阶段 2、中断上半部 aer_irq 3、中断下半部 aer_isr 3.1、aer_isr_one_error 3.2、find_source_device 3.3、aer_process_err_devices 3.4、handle_error_source 3.5、pcie_do_recovery 整体逻…

​HAProxy负载均衡集群概述

前言: 在现代分布式系统中,负载均衡和高可用性是保障服务稳定性和性能的关键技术。HAProxy 作为一款高性能的 TCP/HTTP 负载均衡器,凭借其轻量级、高并发处理能力和灵活的配置机制,成为构建高可用架构的核心组件之一。通过智能的流…

ELN:生物医药科研的数字化引擎——衍因科技引领高效创新

在生物医药研究领域,实验数据的准确记录与管理是科研成败的关键。想象一个场景:某顶尖医学院实验室,研究员小张正为一项抗癌药物实验焦头烂额。纸质记录本中,数据混乱、协作困难,导致实验重复率高达20%。引入衍因科技的…

暑假---作业2

学习目标&#xff1a;xss-1abs 1-8关python美现自动化布尔自注的2、代码进行优化(二分查找)学习内容&#xff1a;1.xss-1abs 1-8关1<h2 align"center">欢迎用户test</h2>2 <script> alert (1)</script&gt<center> <form action&…

【Tensor数据转换】——深度学习.Torch框架

目录 1 Tensor与Numpy 1.1 张量转Numpy 1.2 Numpy转张量 1 Tensor与Numpy 1.1 张量转Numpy 调用numpy()方法可以把Tensor转换为Numpy&#xff0c;此时内存是共享的。 使用copy()方法可以避免内存共享 import torch import numpy as np# tensor转numpy:numpy() def test0…

基于Tranformer的NLP实战(5):BERT实战-基于Pytorch Lightning的文本分类模型

文本分类作为自然语言处理中的基础任务&#xff0c;能够帮助我们将海量医学摘要自动归类到具体疾病领域中。本文将基于NVIDIA NeMo框架&#xff0c;构建一个用于医学疾病摘要分类的深度学习应用&#xff0c;支持将摘要划分为三类&#xff1a;癌症类疾病、神经系统疾病及障碍、以…

14-链路聚合

链路聚合技术 一 链路聚合概述链路聚合定义链路聚合是把多条物理链路聚合在一起&#xff0c;形成一条逻辑链路。应用在交换机、路由器、服务器间链路。分为三层链路聚合和二层链路聚合。二 链路聚合的作用 1. 链路聚合模式静态聚合模式 端口不与对端设备交互信息。选择参考端口…

学习C++、QT---28(QT库中使用QShortcut类对快捷键创建和使用的讲解)

每日一言 所有的努力&#xff0c;都是为了让未来的自己感谢现在的你。 QShortcut 我们的记事本肯定要有通过快捷键对字体的放大和缩小进行控制的功能啊&#xff0c;那么我们这边就这个问题我们需要先学习一下QShortCut 我们这个类就是专门做快捷键的 老样子我们刚开始学习这个…

Web Worker:让前端飞起来的隐形引擎

目录 Web Worker&#xff1a;让前端飞起来的隐形引擎 一、什么是 Web Worker&#xff1f; 1、为什么需要 web worker 2、什么是 web worker 二、基本使用方法 1、创建一个 Worker 文件&#xff08;worker.js&#xff09; 2、主线程引入并使用 三、实战案例&#xff1a;…

关于在VScode中使用git的一些步骤常用命令及其常见问题:

输入 gitee用户 gitee绑定邮箱git config --global user.name "automated-piggy-senior" git config --global user.email "1323280131qq.com"克隆远程库到本地 git clone https://gitee.com/automated-piggy-senior/20250717-test.git常见问题1&#xff1…

LeafletJS 性能优化:处理大数据量地图

引言 LeafletJS 作为一个轻量、灵活的 JavaScript 地图库&#xff0c;以其高效的渲染能力和模块化设计深受开发者喜爱。然而&#xff0c;当处理大数据量&#xff08;如数千个标记、复杂的 GeoJSON 数据或高分辨率瓦片&#xff09;时&#xff0c;LeafletJS 的性能可能面临挑战&…

LLM(Large Language Model)大规模语言模型浅析

参考: https://zhuanlan.zhihu.com/p/7046080918 LLM(Large Language Model)大规模语言模型,是指具有大规模参数和复杂计算结构的机器学习模型。大模型里常说的多少B, B 是 Billion 的缩写&#xff0c;表示 十亿,如DeepSeek满血版 671B(6710亿参数); 大模型本质上是一个使用海量…

【后端】配置SqlSugar ORM框架并添加仓储

目录 1.添加包 2.配置连接字符串 3.配置SqlSugar 3.1.添加基础类 3.2.添加方法 3.2.1.读取配置方法 3.2.2.枚举扩展方法 3.3.添加管理类&#xff08;重要&#xff09; 4.配置仓储 4.1.仓储接口添加 5.注册 6.使用 该文档是配置SqlSugar多租户和加仓储教程。使用 S…

全国高等院校计算机基础教育研究会2025学术年会在西宁成功举办 ——高原论道启新程,数智融合育英才

7 月16日至18日&#xff0c;全国高等院校计算机基础教育研究会2025学术年会在青海西宁隆重召开。大会以“数智融合&#xff0c;创新计算机教育”为主题&#xff0c;汇聚人工智能领域顶尖专家学者、高校校长、产业翘楚及一线教师300 多人&#xff0c;共商人工智能时代计算机基础…

AppTrace:重新定义免填邀请码,解锁用户裂变新高度

​​在移动互联网时代&#xff0c;​用户裂变是App增长的核心引擎&#xff0c;而邀请机制则是裂变的关键驱动力。然而&#xff0c;传统的邀请码机制——依赖用户手动输入、记忆复杂字符——已经成为用户体验的绊脚石&#xff0c;导致转化率下降、运营成本上升。​AppTrace​ 作…

神经网络常见激活函数 13-Softplus函数

文章目录Softplus函数导函数函数和导函数图像优缺点PyTorch 中的 Softplus 函数TensorFlow 中的 Softplus 函数Softplus 函数导函数 Softplus函数 Softplus⁡(x)ln⁡(1ex)\begin{aligned} \operatorname{Softplus}(x) & \ln \bigl(1 e^{\,x}\bigr) \end{aligned} Softplu…

深度理解 KVM:Linux 内核系统学习的重要角度

&#x1f4d6; 推荐阅读&#xff1a;《Yocto项目实战教程:高效定制嵌入式Linux系统》 &#x1f3a5; 更多学习视频请关注 B 站&#xff1a;嵌入式Jerry 深度理解 KVM&#xff1a;Linux 内核系统学习的重要角度 作者&#xff1a;嵌入式 Jerry 一、为什么开发者需要学习 KVM&…

闭包的定义和应用场景

一、闭包是什么&#xff1f; 闭包是指函数可以“记住”并访问它定义时的词法作用域&#xff0c;即使这个函数在其作用域链之外执行。 简单说&#xff1a;函数 A 在函数 B 中被定义&#xff0c;并在函数 B 外部被调用&#xff0c;它依然能访问函数 B 中的变量&#xff0c;这就是…

北京-4年功能测试2年空窗-报培训班学测开-第五十四天

今天交付的成果是&#xff0c;初版简历虽然只写了项目部分&#xff0c;但用了一整天&#xff0c;期间联系了前司组长&#xff0c;拿到了性能测试报告。然后再看压测脚本&#xff0c;突然能看懂了&#xff0c;对服务端日志也能看懂些了&#xff0c;还找到了客户端日志怎么说呢&a…

算法训练营day24 回溯算法③ 93.复原IP地址 、78.子集、 90.子集II

今天继续回溯算法的专题&#xff0c;第三篇博客&#xff01; 93.复原IP地址 输入&#xff1a;s "25525511135" 输出&#xff1a;["255.255.11.135","255.255.111.35"] 切割字符串为4段&#xff0c;当进行到第四段的时候对第四段字符串进行判断…