linux 内核等待队列

news2024/9/21 12:43:43

等待队列在Linux内核中用来阻塞或唤醒一个进程,也可以用来同步对系统资源的访问,还可以实现延迟功能

在软件开发中任务经常由于某种条件没有得到满足而不得不进入睡眠状态,然后等待条件得到满足的时候再继续运行,进入运行状态。这种需求需要等待队列机制的支持。Linux中提供了等待队列的机制,该机制在内核中应用很广泛。

在Linux内核中使用等待队列的过程很简单,首先定义一个wait_queue_head,然后如果一个task想等待某种事件,那么调用wait_event(等待队列,事件)就可以了。

等待队列应用广泛,但是内核实现却十分简单。其涉及到两个比较重要的数据结构:__wait_queue_head,该结构描述了等待队列的链头,其包含一个链表和一个原子锁,结构定义如下:

struct wait_queue_head {

      spinlock_t lock;                    /* 保护等待队列的原子锁 */

      struct list_head task_list;          /* 等待队列 */

};

typedef struct wait_queue_head wait_queue_head_t;

wait_queue_entry,该结构是对一个等待任务的抽象。每个等待任务都会抽象成一个wait_queue_entry,并且挂载到wait_queue_head上。

该结构定义如下:struct wait_queue_entry {

    unsigned int flags;         //1:互斥进程,0:非互斥进程

    void *private;                       /* 通常指向当前任务控制块 */

    /* 任务唤醒操作方法,该方法在内核中提供,通常为autoremove_wake_function */

    wait_queue_func_t func;            

    struct list_head task_list;              /* 挂入wait_queue_head的挂载点 */

};

typedef struct wait_queue_entry wait_queue_entry_t;

定义"等待队列":

定义并初始化一个名为name的等待队列 ,注意此处是定义一个wait_queue_t类型的变量name,并将其private与设置为tsk

DECLARE_WAITQUEUE(name,tsk); //任务唤醒操作方法为:default_wake_function

Linux中等待队列的实现思想如下图所示,当一个任务需要在某个wait_queue_head上睡眠时,将自己的进程控制块信息封装到wait_queue_entry中,然后挂载到wait_queue_head的链表中,执行调度睡眠。当某些事件发生后,另一个任务(进程)会唤醒wait_queue_head上的某个或者所有任务,唤醒工作也就是将等待队列中的任务设置为可调度的状态,并且从队列中删除。

使用等待队列时首先需要定义一个wait_queue_head,这可以通过DECLARE_WAIT_QUEUE_HEAD宏来完成,这是静态定义的方法。该宏会定义一个wait_queue_head,并且初始化结构中的锁以及等待队列。当然,动态初始化的方法也很简单,初始化一下锁及队列就可以了。

一个任务需要等待某一事件的发生时,通常调用wait_event,该函数会定义一个wait_queue_entry,描述等待任务,并且用当前的进程描述块初始化wait_queue_entry,然后将wait_queue_entry加入到wait_queue_head中。函数实现流程说明如下:

1、  用当前的进程描述块(PCB)初始化一个wait_queue_entry描述的等待任务。

2、  在等待队列锁资源的保护下,将等待任务加入等待队列。

3、  判断等待条件是否满足,如果满足,那么将等待任务从队列中移出,退出函数。

4、 如果条件不满足,那么任务调度,将CPU资源交与其它任务。

5、 当睡眠任务被唤醒之后,需要重复(2)、(3)步骤,如果确认条件满足,退出等待事件数。

等待队列编程接口

等待队列接口函数介绍

#include <linux/wait.h> //头文件包含

1.定义一个等待队列头

wait_queue_head_t my_queue;

2.初始一个等待队列头

init_waitqueue_head(&my_queue);

定义并初始化一个等待队列头

DECLARE_WAIT_QUEUE_HEAD(my_queue);

3.进程的睡眠操作——条件睡眠

//判断condition条件,决定是否将当前进程推入等待队列(条件为假时)此函数为宏函数

wait_event(wait_queue_head_t wq, int condition);

/*可以被系统消息打断*/

wait_event_interruptible(wait_queue_head_t wq,int condition);

wait_event_timeout(wait_queue_head_t wq, int condition, long timeout);

wait_event_interruptiblble_timeout(wait_queue_head_t wq,int condition, long timeout);

参数wq:表示等待队列头

参数condition:阻塞条件,为假(0)则进入休眠直到wake_up且condition为真条件成立才退出

参数timeout:表示睡眠指定时长(时钟滴答度量,eg.延时2秒=2*HZ)后,自动转入唤醒状态

3.进程的睡眠操作——无条件睡眠(不建议使用,新内核将去掉这些接口,请使用上面的接口)

/*

 * These are the old interfaces to sleep waiting for an event.

 * They are racy.  DO NOT use them, use the wait_event* interfaces above.

 * We plan to remove these interfaces.

 */

//将当前进程推入等待队列将其睡眠,wake_up唤醒

sleep_on(wait_queue_head_t *q);

/*可以被系统消息打断*/

interruptible_sleep_on(wait_queue_head_t *q);

long sleep_on_timeout(wait_queue_head_t *q, long timeout);

long interruptible_sleep_on_timeout(wait_queue_head_t *q, long timeout);

参数wq:表示等待队列头

参数timeout:表示睡眠指定时长后,自动转入唤醒状态

4.将非互斥进程插入等待队列链表的第一个位置,需要自己定义wait_queue_t

add_wait_queue(wait_queue_head_t *q, wait_queue_t *wait)

函数将互斥进程插入等待队列链表的最后一个位置

add_wait_queue_exclusive(wait_queue_head_t *q, wait_queue_t *wait)

5.进程唤醒函数

wake_up(wait_queue_head_t *wq);

wake_up_all(wait_queue_head_t *wq);

wake_up_interruptible(wait_queue_head_t *wq);

注意事项:

1.唤醒函数和导致睡眠函数要配对使用,如果导致睡眠函数使用带interruptible的,则唤醒函数也要使用interruptible的。

2.在使用wake_up唤醒进程之前要将wait_event中的condition变量的值赋为真,否则该进程被唤醒后会立即再次进入睡眠

3. wake_up()每次只能唤醒一个进程,而且是从队列头开始唤醒的,而wait_event()函数每次会将新建的等待队列插到队列头,因此最后调用wait_event()函数的进程先被唤醒!如果要唤醒某个特定的进程,没有现成的函数,按照本人理解,只能使用wake_up_all()函数唤醒所有进程,然后在通过条件condition来控制(每个进程使用不同的变量来控制,在wake_up_all()函数后只将要唤醒的进程的变量置成真)。

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

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

相关文章

虚拟数字人有什么用?有哪些应用场景?

​​过去三年&#xff0c;元宇宙概念进入到大众视野&#xff0c;虚拟数字人备受关注。抖音达人柳夜熙、洛天依、网红虚拟偶像AYAYI等&#xff0c;随着元宇宙的流行&#xff0c;数字人也逐渐成为一种趋势。据行业预测&#xff0c;到2030年&#xff0c;中国的数字人总市场规模将达…

全汉电源SN生产日期解读

新买了一个全汉的电脑电源&#xff0c;SN&#xff1a;WZ3191900030&#xff0c;看了几次没想明白&#xff0c;最后估计SN是2023年19周这样来记录日期的。问了一下京东全汉客服&#xff0c;果然就是这样的。那大家如果在闲鱼上看到全汉电源&#xff0c;就知道它的生产日期了。

Excel导入操作

<template><el-dialogwidth"500px"title"员工导入":visible"showExcelDialog"close"$emit(update:showExcelDialog, false)"><el-row type"flex" justify"center"><div class"upload-e…

Csharp(C#)无标题栏窗体拖动代码

C#&#xff08;C Sharp&#xff09;是一种现代、通用的编程语言&#xff0c;由微软公司在2000年推出。C#是一种对象导向的编程语言&#xff0c;它兼具C语言的高效性和Visual Basic语言的易学性。C#主要应用于Windows桌面应用程序、Windows服务、Web应用程序、游戏开发等领域。C…

使用vscode的remotessh插件远程连接的时候被要求重复输入密码

问题描述&#xff1a; 需要远程连接服务器&#xff0c;使用ssh&#xff0c;我用到的是vscode里面的remotessh插件。配置好config以后 HostHostNameUserPortIdentifyFile进入到了vscode的密码登录界面&#xff0c;但是一直被要求循环输入密码&#xff0c;很奇怪&#xff0c;去…

遭到美国做空机构“灰熊”做空后,人工智能公司商汤科技股价暴跌

来源&#xff1a;猛兽财经 作者&#xff1a;猛兽财经 猛兽财经获悉&#xff0c;在遭到美国做空机构Grizzly Research&#xff08;灰熊&#xff09;指控夸大收入后&#xff0c;商汤科技的股价在周二一度下跌了9.7%。 Grizzly Research在周二发布的一份报告中称&#xff0c;商汤…

分享5款靠谱好用,无广告不流氓的好软件

​ 话不多说&#xff0c;直入正题&#xff0c;全都是靠谱好用&#xff0c;无广告不流氓的好软件&#xff0c;可以先点赞收藏&#xff0c;以后慢慢用。 1.动态壁纸软件——Lively Wallpaper ​ Lively Wallpaper是一款可以将视频、GIF、网页、游戏等内容作为桌面壁纸的软件&am…

对抗产品团队中的认知偏误:给产品经理的专家建议

今天的产品经理面临着独特的挑战。他们不仅需要设计和构建创新功能&#xff0c;还必须了解这些功能将如何为客户带来价值并推进关键业务目标。如果不加以控制&#xff0c;认知偏差可能会导致您构建的内容与客户想要的内容或业务需求之间不一致。本文将详细阐述产品经理可以避免…

融合抖音生态:抖音核销工具小程序开发全指南

为了更好地与抖音生态融合&#xff0c;许多开发者开始关注抖音核销工具小程序的开发。本文将为您提供一份详尽的指南&#xff0c;帮助您了解如何开发一个完善的抖音核销工具小程序。 第一步&#xff1a;理解抖音生态 抖音提供了一系列开发者工具和API&#xff0c;包括用户授权…

上市公司数字化转型及同群效应数据集合(四种测算方法)

数据简介&#xff1a;当今世界处于高速发展的信息时代中&#xff0c;数字革命的产生催生出大量数字技术和数字信息。在数字经济时代&#xff0c;数字化转型赋予了企业新的发展动能&#xff0c;数字化转型已经成为诸多企业高质量发展的重要路径。是否需要进行数字化转型、能否及…

Serilog .net下的新兴的日志框架

Serilog .net下的新兴的日志框架 1.Serilog简介 Serilog 是针对 .NET 应用程序的流行日志记录框架。它以其灵活性、易用性和可扩展性而闻名。借助 Serilog&#xff0c;开发人员可以轻松记录应用程序中的事件、错误和消息。它支持结构化日志记录&#xff0c;能够以结构化格式存…

SpringBoot整合validation数据校验

1. 首先引入依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-validation</artifactId></dependency> 点标识进去可以发现是通过Hibernate Validator使用 Java Bean Validation 2. 属性上…

中伟视界:AI盒子中的报警预录像功能能解决什么问题?实现原理是怎样的?

现代社会智能安防已成为各行各业的重要一环&#xff0c;而AI盒子中的报警预录像功能更是智能安防的一大利器。这一功能能够解决很多安防方面的难题&#xff0c;其实现原理更是技术创新的体现。 首先&#xff0c;让我们来看看AI盒子中的报警预录像功能能解决哪些问题。在传统的安…

基于PHP的校园兼职系统的设计与开发

基于PHP的校园兼职系统的设计与开发 摘要&#xff1a;从古代至今&#xff0c;教育都是国家培养人才的手段&#xff0c;在古代教育往往都是课堂式教育&#xff0c;在课堂内老师教导学生学习&#xff0c;而随着时间的推移&#xff0c;越来越多的在校大学生已经不满足于只在课堂上…

dapper+mysql查询报Error parsing column 0 (Id=<null>)

之前的分页接口都是正常的&#xff0c;突然就报错了Error parsing column 0 (Id<null>) {"error": {"code": null,"message": "Error parsing column 0 (Id<null>)","details": "DataException: Error pa…

vue.js ——Vuex

基本概念 vue进行开发过程中有没有遇到这样一种场景&#xff0c;就是有些时候一些数据是一种通用的共享数据&#xff08;比如登录信息&#xff09;&#xff0c;那么这类数据在各个组件模块中可能都会用到&#xff0c;如果每个组件中都去后台重新获取那么势必会造成性能浪费&am…

R语言30分钟入门

1. 环境&安装 R是支持win、linux合macos的 完整参考&#xff1a;https://zhuanlan.zhihu.com/p/596324321?utm_id0 主要是安装&#xff1a;1、R环境&#xff1b;2、rstudio开发环境&#xff08;后面主要是用rstudio&#xff0c;也可以用vscode&#xff09; 1.1. rstud…

异常 Exception 02

异常 Exception 02 六、异常处理1、基本介绍2、异常处理的方式3、示意图 try-catchthrows1、介绍2、注意事项 自定义异常1、基本概念2、自定义异常的步骤3、实例4、throw和throws的区别 六、异常处理 1、基本介绍 异常处理就是当异常发生时,对异常处理的方式。 2、异常处理的…

佳易王物流快运物流单打印登记查询系统软件操作教程

一、前言&#xff08;编程应用实例系列&#xff09;&#xff1a; 佳易王物流快运物流单打印登记查询系统软件操作教程 软件有试用版&#xff0c;可以下载试用&#xff0c;了解软件操作和软件功能。 软件试用版下载可以点击最下方官网卡片 软件为绿色免安装版&#xff0c;下载…

2023-简单点-yolox-pytorch代码解析(二)-nets/yolo.py

yolox-pytorch&#xff1a;nets/yolo.py yolox网络结构yolox-pytorch目录今天解析注释nets/yolo.py yolox网络结构 yolox-pytorch目录 nets目录 今天解析注释nets/yolo.py import torch import torch.nn as nnfrom .darknet import BaseConv, CSPDarknet, CSPLayer, DWConv##…