scheduler_tick函数详解

2023-10-07 07:58
文章标签 函数 详解 scheduler tick

本文主要是介绍scheduler_tick函数详解,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

scheduler_tick是调度器中的一个核心重要的函数,它叫做周期调度器,驱动调度器运行的机制之一。

event_handler()-->tick_handle_periodic()->tik_periodic()->update_process_times()-->scheduler_tick()

以上是该函数的调用回溯,由时钟中断驱动着这个函数的运行,每个CPU tick到来时都会执行一次。这里还有一个知识点要涉及到,那就是内核的时间子系统,在SMP环境下,每一个CPU都自己的tick device,这些tick device中有一个被选择做global tick device,global tick device负责维护整个系统的jiffies以及更新基于jiffies进行的全系统统计信息。而本文介绍的scheduler_tick显然是每个CPU自己的tick到来时要执行的操作,因为每个CPU由自己的runquque,管理自己的就绪进程,因此对应的时钟中断肯定也是属于该CPU自身的。

下面将按照代码的顺序介绍它做了什么内容。

void scheduler_tick(void)
{int cpu = smp_processor_id();struct rq *rq = cpu_rq(cpu);struct task_struct *curr = rq->curr;sched_clock_tick();  //----------(1)raw_spin_lock(&rq->lock);update_rq_clock(rq);     //---------(2)curr->sched_class->task_tick(rq, curr, 0); //-------(3)update_cpu_load_active(rq); //-----------(4)raw_spin_unlock(&rq->lock);perf_event_task_tick();#ifdef CONFIG_SMPrq->idle_balance = idle_cpu(cpu);trigger_load_balance(rq);
#endifrq_last_tick_reset(rq);
}

(1)更新调度器使用的clock信息
(2)更新当前runqueue中的clock时间,基于(1)的clock来获取
(3)执行不同调度类中的task_tick回调函数
(4)更新该runqueue相关的CPU load负载,会根据cfs_rq中计算的runnable_load_avg来更新CPU负载,而runnable_load_avg的更新在我的另一篇博客中介绍PELT。

这个函数的关键处理就是调用:

  curr->sched_class->task_tick(rq, curr, 0);

注意它传入的参数,是当前runqueue中的curr变量,也就是当前正在运行着的进程。这里会调用调度类中的task_tick回调,我们主要以CFS调度器来做介绍。

static void task_tick_fair(struct rq *rq, struct task_struct *curr, int queued)
{struct cfs_rq *cfs_rq;struct sched_entity *se = &curr->se;for_each_sched_entity(se) {cfs_rq = cfs_rq_of(se);entity_tick(cfs_rq, se, queued);  //(1)}if (numabalancing_enabled)task_tick_numa(rq, curr);update_rq_runnable_avg(rq, 1);  //(2)
}

其中关键的两个步骤:
(1)执行调度实体的tick函数更新统计量和vruntime
(2)更新runqueue的avg统计量和负载

 static voidentity_tick(struct cfs_rq *cfs_rq, struct sched_entity *curr, int queued){/** Update run-time statistics of the 'current'.*/update_curr(cfs_rq);  //(1)/** Ensure that runnable average is periodically updated.*/update_entity_load_avg(curr, 1);  //(2)update_cfs_rq_blocked_load(cfs_rq, 1);update_cfs_shares(cfs_rq);#ifdef CONFIG_SCHED_HRTICK/** queued ticks are scheduled to match the slice, so don't bother* validating it and just reschedule.*/if (queued) {resched_curr(rq_of(cfs_rq));return;}/** don't let the period tick interfere with the hrtick preemption*/if (!sched_feat(DOUBLE_TICK) &&hrtimer_active(&rq_of(cfs_rq)->hrtick_timer))return;#endifif (cfs_rq->nr_running > 1)check_preempt_tick(cfs_rq, curr); //(3)}

(1)update_curr更新当前调度实体的runtime信息,包括exec time实际执行时间,以及vruntime,虚拟时间
(2)更新调度实体的avg负载,以便于给后面runqueue负载计算使用
(3) check_preempt_tick用于判断当前情况是否需要执行系统调度,这个是调度关键函数。

 static voidcheck_preempt_tick(struct cfs_rq *cfs_rq, struct sched_entity *curr){unsigned long ideal_runtime, delta_exec;struct sched_entity *se;s64 delta;ideal_runtime = sched_slice(cfs_rq, curr);delta_exec = curr->sum_exec_runtime - curr->prev_sum_exec_runtime;if (delta_exec > ideal_runtime) {resched_curr(rq_of(cfs_rq));/** The current task ran long enough, ensure it doesn't get* re-elected due to buddy favours.*/clear_buddies(cfs_rq, curr);return;}/** Ensure that a task that missed wakeup preemption by a* narrow margin doesn't have to wait for a full slice.* This also mitigates buddy induced latencies under load.*/if (delta_exec < sysctl_sched_min_granularity)return;se = __pick_first_entity(cfs_rq);delta = curr->vruntime - se->vruntime;if (delta < 0)return;if (delta > ideal_runtime)resched_curr(rq_of(cfs_rq));}

sched_slice计算当前进程理论运行的时间片,是一个实际时间,通过比较当前进程实际运行时间delta_exec,如果实际运行时间超过理论得到的时间片,那么说明需要调度了,设置调度标志位后返回,否则需要判断如下条件:
1.当前进程运行时间小于系统要求的最小时间片0.75ms,返回不进行调度行为
2.pick平衡二叉树中最左侧叶子节点的调度实体,比较当前进程和它的vruntime值,如果当前进程vruntime大于最左侧的进程,并且差值超过当前的理论运行时间片,那么也需要设置调度标志位进行调度。

这篇关于scheduler_tick函数详解的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/157070

相关文章

HTML5的input标签的`type`属性值详解和代码示例

《HTML5的input标签的`type`属性值详解和代码示例》HTML5的`input`标签提供了多种`type`属性值,用于创建不同类型的输入控件,满足用户输入的多样化需求,从文本输入、密码输入、... 目录一、引言二、文本类输入类型2.1 text2.2 password2.3 textarea(严格

C++ move 的作用详解及陷阱最佳实践

《C++move的作用详解及陷阱最佳实践》文章详细介绍了C++中的`std::move`函数的作用,包括为什么需要它、它的本质、典型使用场景、以及一些常见陷阱和最佳实践,感兴趣的朋友跟随小编一起看... 目录C++ move 的作用详解一、一句话总结二、为什么需要 move?C++98/03 的痛点⚡C++

MySQL中between and的基本用法、范围查询示例详解

《MySQL中betweenand的基本用法、范围查询示例详解》BETWEENAND操作符在MySQL中用于选择在两个值之间的数据,包括边界值,它支持数值和日期类型,示例展示了如何使用BETWEEN... 目录一、between and语法二、使用示例2.1、betwphpeen and数值查询2.2、be

python中的flask_sqlalchemy的使用及示例详解

《python中的flask_sqlalchemy的使用及示例详解》文章主要介绍了在使用SQLAlchemy创建模型实例时,通过元类动态创建实例的方式,并说明了如何在实例化时执行__init__方法,... 目录@orm.reconstructorSQLAlchemy的回滚关联其他模型数据库基本操作将数据添

Java中ArrayList与顺序表示例详解

《Java中ArrayList与顺序表示例详解》顺序表是在计算机内存中以数组的形式保存的线性表,是指用一组地址连续的存储单元依次存储数据元素的线性结构,:本文主要介绍Java中ArrayList与... 目录前言一、Java集合框架核心接口与分类ArrayList二、顺序表数据结构中的顺序表三、常用代码手动

JAVA线程的周期及调度机制详解

《JAVA线程的周期及调度机制详解》Java线程的生命周期包括NEW、RUNNABLE、BLOCKED、WAITING、TIMED_WAITING和TERMINATED,线程调度依赖操作系统,采用抢占... 目录Java线程的生命周期线程状态转换示例代码JAVA线程调度机制优先级设置示例注意事项JAVA线程

详解C++ 存储二进制数据容器的几种方法

《详解C++存储二进制数据容器的几种方法》本文主要介绍了详解C++存储二进制数据容器,包括std::vector、std::array、std::string、std::bitset和std::ve... 目录1.std::vector<uint8_t>(最常用)特点:适用场景:示例:2.std::arra

C++构造函数中explicit详解

《C++构造函数中explicit详解》explicit关键字用于修饰单参数构造函数或可以看作单参数的构造函数,阻止编译器进行隐式类型转换或拷贝初始化,本文就来介绍explicit的使用,感兴趣的可以... 目录1. 什么是explicit2. 隐式转换的问题3.explicit的使用示例基本用法多参数构造

Android使用java实现网络连通性检查详解

《Android使用java实现网络连通性检查详解》这篇文章主要为大家详细介绍了Android使用java实现网络连通性检查的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录NetCheck.Java(可直接拷贝)使用示例(Activity/Fragment 内)权限要求

MyBatis中的两种参数传递类型详解(示例代码)

《MyBatis中的两种参数传递类型详解(示例代码)》文章介绍了MyBatis中传递多个参数的两种方式,使用Map和使用@Param注解或封装POJO,Map方式适用于动态、不固定的参数,但可读性和安... 目录✅ android方式一:使用Map<String, Object>✅ 方式二:使用@Param