一文读懂 | 进程怎么绑定 CPU

昨天在群里有朋友问:把进程绑定到某个 CPU 上运行是怎么实现的。

首先,我们先来了解下将进程与 CPU 进行绑定的好处。

进程绑定 CPU 的好处:在多核 CPU 结构中,每个核心有各自的L1、L2缓存,而L3缓存是共用的。如果一个进程在核心间来回切换,各个核心的缓存命中率就会受到影响。相反如果进程不管如何调度,都始终可以在一个核心上执行,那么其数据的L1、L2 缓存的命中率可以显著提高。

所以,将进程与 CPU 进行绑定可以提高 CPU 缓存的命中率,从而提高性能。而进程与 CPU 绑定被称为:CPU 亲和性

设置进程的 CPU 亲和性

前面介绍了进程与 CPU 绑定的好处后,现在来介绍一下在 Linux 系统下怎么将进程与 CPU 进行绑定的(也就是设置进程的 CPU 亲和性)。

Linux 系统提供了一个名为 sched_setaffinity 的系统调用,此系统调用可以设置进程的 CPU 亲和性。我们来看看 sched_setaffinity 系统调用的原型:

int sched_setaffinity(pid_t pid, size_t cpusetsize, const cpu_set_t *mask);

下面介绍一下 sched_setaffinity 系统调用各个参数的作用:

  • pid:进程ID,也就是要进行绑定 CPU 的进程ID。

  • cpusetsize:mask 参数所指向的 CPU 集合的大小。

  • mask:与进程进行绑定的 CPU 集合(由于一个进程可以绑定到多个 CPU 上运行)。

参数 mask 的类型为 cpu_set_t,而 cpu_set_t 是一个位图,位图的每个位表示一个 CPU,如下图所示:

例如,将 cpu_set_t 的第0位设置为1,表示将进程绑定到 CPU0 上运行,当然我们可以将进程绑定到多个 CPU 上运行。

我们通过一个例子来介绍怎么通过 sched_setaffinity 系统调用来设置进程的 CPU 亲和性:

#define _GNU_SOURCE
#include <sched.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>int main(int argc, char **argv)
{cpu_set_t cpuset;CPU_ZERO(&cpuset);    // 初始化CPU集合,将 cpuset 置为空CPU_SET(2, &cpuset);  // 将本进程绑定到 CPU2 上// 设置进程的 CPU 亲和性if (sched_setaffinity(0, sizeof(cpuset), &cpuset) == -1) {printf("Set CPU affinity failed, error: %s\n", strerror(errno));return -1; }return 0;
}

CPU 亲和性实现

知道怎么设置进程的 CPU 亲和性后,现在我们来分析一下 Linux 内核是怎样实现 CPU 亲和性功能的。

本文使用的 Linux 内核版本为 2.6.23

Linux 内核为每个 CPU 定义了一个类型为 struct rq 的 可运行的进程队列,也就是说,每个 CPU 都拥有一个独立的可运行进程队列。

一般来说,CPU 只会从属于自己的可运行进程队列中选择一个进程来运行。也就是说,CPU0 只会从属于 CPU0 的可运行队列中选择一个进程来运行,而绝不会从 CPU1 的可运行队列中获取。

所以,从上面的信息中可以分析出,要将进程绑定到某个 CPU 上运行,只需要将进程放置到其所属的 可运行进程队列 中即可。

下面我们来分析一下 sched_setaffinity 系统调用的实现,sched_setaffinity 系统调用的调用链如下:

sys_sched_setaffinity()
└→ sched_setaffinity()└→ set_cpus_allowed()└→ migrate_task()

从上面的调用链可以看出,sched_setaffinity 系统调用最终会调用 migrate_task 函数来完成进程与 CPU 进行绑定的工作,我们来分析一下 migrate_task 函数的实现:

static int
migrate_task(struct task_struct *p, int dest_cpu, struct migration_req *req)
{struct rq *rq = task_rq(p);// 情况1:// 如果进程还没有在任何运行队列中// 那么只需要将进程的 cpu 字段设置为 dest_cpu 即可if (!p->se.on_rq && !task_running(rq, p)) {set_task_cpu(p, dest_cpu);return 0;}// 情况2:// 如果进程已经在某一个 CPU 的可运行队列中// 那么需要将进程从之前的 CPU 可运行队列中迁移到新的 CPU 可运行队列中// 这个迁移过程由 migration_thread 内核线程完成// 构建进程迁移请求init_completion(&req->done);req->task = p;req->dest_cpu = dest_cpu;list_add(&req->list, &rq->migration_queue);return 1;
}

我们先来介绍一下 migrate_task 函数各个参数的意义:

  • p:要设置 CPU 亲和性的进程描述符。

  • dest_cpu:绑定的 CPU 编号。

  • req:进程迁移请求对象(下面会介绍)。

所以,migrate_task 函数的作用就是将进程描述符为 p 的进程绑定到编号为 dest_cpu 的目标 CPU 上。

migrate_task 函数主要分两种情况来将进程绑定到某个 CPU 上:

  • 情况1:如果进程还没有在任何 CPU 的可运行队列中(不可运行状态),那么只需要将进程描述符的 cpu 字段设置为 dest_cpu 即可。当进程变为可运行时,会根据进程描述符的 cpu 字段来自动放置到对应的 CPU 可运行队列中。

  • 情况2:如果进程已经在某个 CPU 的可运行队列中,那么需要将进程从之前的 CPU 可运行队列中迁移到新的 CPU 可运行队列中。迁移过程由 migration_thread 内核线程完成,migrate_task 函数只是构建一个进程迁移请求,并通知 migration_thread 内核线程有新的迁移请求需要处理。

而进程迁移过程由 __migrate_task 函数完成,我们来看看 __migrate_task 函数的实现:

static int 
__migrate_task(struct task_struct *p, int src_cpu, int dest_cpu)
{struct rq *rq_dest, *rq_src;int ret = 0, on_rq;...rq_src = cpu_rq(src_cpu);    // 进程所在的原可运行队列rq_dest = cpu_rq(dest_cpu);  // 进程希望放置的目标可运行队列...on_rq = p->se.on_rq;  // 进程是否在可运行队列中(可运行状态)if (on_rq)deactivate_task(rq_src, p, 0);  // 把进程从原来的可运行队列中删除set_task_cpu(p, dest_cpu);if (on_rq) {activate_task(rq_dest, p, 0);   // 把进程放置到目标可运行队列中...}...return ret;
}

__migrate_task 函数主要完成以下两个工作:

  • 把进程从原来的可运行队列中删除。

  • 把进程放置到目标可运行队列中。

其工作过程如下图所示(将进程从 CPU0 的可运行队列迁移到 CPU3 的可运行队列中):

如上图所示,进程原本在 CPU0 的可运行队列中,但由于重新将进程绑定到 CPU3,所以需要将进程从 CPU0 的可运行队列迁移到 CPU3 的可运行中。

迁移过程首先将进程从 CPU0 的可运行队列中删除,然后再将进程插入到 CPU3 的可运行队列中。

当 CPU 要运行进程时,首先从它所属的可运行队列中挑选一个进程,并将此进程调度到 CPU 中运行。

总结

从上面的分析可知,其实将进程绑定到某个 CPU 只是将进程放置到 CPU 的可运行队列中。

由于每个 CPU 都有一个可运行队列,所以就有可能会出现 CPU 间可运行队列负载不均衡问题。如 CPU0 可运行队列中的进程比 CPU1 可运行队列多非常多,从而导致 CPU0 的负载非常高,而 CPU1 负载非常低的情况。

当出现上述情况时,就需要对 CPU 间的可运行队列进行重平衡操作,有兴趣的可以自行阅读源码或参考相关资料。


推荐阅读:

专辑|Linux文章汇总

专辑|程序人生

专辑|C语言

我的知识小密圈

关注公众号,后台回复「1024」获取学习资料网盘链接。

欢迎点赞,关注,转发,在看,您的每一次鼓励,我都将铭记于心~

嵌入式Linux

微信扫描二维码,关注我的公众号

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

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

相关文章

每日一题(25)—— 自加++

C语言同意一些令人震惊的结构,下面的结构是合法的吗&#xff0c;如果是它做些什么&#xff1f; int a 5, b 7, c; c ab; 不管你相不相信&#xff0c;上面的例子是完全合乎语法的。问题是编译器如何处理它&#xff1f;水平不高的编译作者实际上会争论这个问题&#xff0c;根…

Spark天堂之门解密

本课主题 什么是 Spark 的天堂之门Spark 天堂之门到底在那里Spark 天堂之门源码鉴赏引言 Spark 天堂之门就是SparkContext&#xff0c;这篇文章会从 SparkContext 创建3大核心对象 TaskSchedulerImpl、DAGScheduler 和 SchedulerBackend 开始到注册给 Master 这个过程中的源码鉴…

C语言,使用union了解内存

今天一个读者朋友给我发的一段代码&#xff0c;这段代码让他有了疑惑。代码如下&#xff1a;#include "stdio.h" int main() {typedef union{short i;char j[2];}DATA;DATA a;a.j[0] 10;a.j[1] 1;printf("%x\n",a.i);return 0; }他的几个测试代码以及输出…

我做技术的这十年,我不做技术的这一年~

我和明哥认识是因为之前他在群里跟我们分享一件事情&#xff0c;当时因为明哥相信网上认识的一个朋友&#xff0c;说是要一起开发一个项目&#xff0c;结果他被骗了几万块钱。然后聊着聊着&#xff0c;我觉得明哥太实诚了&#xff0c;后面继续接触&#xff0c;知道他做的一些决…

每日一题(26)—— 无限循环的几种形式

嵌入式系统中经常要用到无限循环&#xff0c;你怎么样用C编写死循环呢&#xff1f; 1、while(1) { } —— 个人推荐使用 2、for(;;) { } —— 这个实现方式让我为难&#xff0c;因为这个语法没有确切表达到底怎么回事。 3、goto Loop: ... goto Loop; —— 应试者如给…

Oracle Golden Gate概要

Oracle GoldenGate简介 Oracle Golden Gate用于源数据库与目标数据库的数据复制备份&#xff1b;可以在异构的环境(各种操作系统和数据库)之间实现数据亚秒级的实时复制备份&#xff1b;以及可以在实时数据仓库、数据同步、集中/分发、容灾、数 据库升级和迁移等多个场景下应用…

android 音频加载hal so调试

1. 整个加载流程图 2. 加载hal so的代码位置 2.1 在audiopolicymanager中的加载位置 diff --git a/frameworks/av/services/audiopolicy/managerdefault/AudioPolicyManager.cpp b/frameworks/av/services/audiopolicy/managerdefault/AudioPolicyManager.cpp index 632290a9…

【修炼5】《基础篇》别把项目成功当目标

副标题——做对的事情&#xff0c;远比你把事情做对&#xff0c;来的重要&#xff01;&#xff08;作者&#xff1a; 孙继滨&#xff09;<?xml:namespace prefix o />【项目经理之修炼】 全文索引给大家提一个问题&#xff1a;***************************************…

每日一题(27)—— define定义一个宏表明1年中有多少秒

用预处理指令#define 声明一个常数&#xff0c;用以表明1年中有多少秒&#xff08;忽略闰年问题&#xff09; 分析&#xff1a; 1、#define 语法的基本知识&#xff08;例如&#xff1a;不能以分号结束&#xff0c;括号的使用&#xff0c;等等&#xff09; 2、懂得预处理器将…

String,StringBuffer与StringBuilder的区别??

String,StringBuffer与StringBuilder的区别?? String 字符串常量StringBuffer 字符串变量&#xff08;线程安全&#xff09;StringBuilder 字符串变量&#xff08;非线程安全&#xff09; 简要的说&#xff0c; String 类型和 StringBuffer 类型的主要性能区别其实在于 Strin…

鸿蒙的路还很长

这是昨晚看到我的老领导发的和鸿蒙有关的文章&#xff0c;我在下面评论了&#xff0c;作为科技自媒体屌丝本屌&#xff0c;我昨晚也是看了鸿蒙2.0的发布会&#xff0c;也有一些观点。鸿蒙OS是什么&#xff1f;鸿蒙os是一个操作系统&#xff0c;而且是面向智能终端的&#xff0c…

有关Accordion组件的研究——Silverlight学习笔记[27]

Accordion组件在开发中常用于信息的分类显示。本文将为大家介绍该组件的特性以及通过一个实例讲述该组件的基本运用。组件所在命名控件&#xff1a;System.Windows.Controls组件常用方法&#xff1a;SelectAll&#xff1a;选择所有位于Accordion组件中的Accordion项。&#xff…

螺旋格式输出数据

螺旋格式输出数据 问题&#xff1a;(问答题) 编程输出以下格式的数据。 When i0 1 When i1 7 8 96 1 25 4 3 When i2 21 22 23 24 2520 7 8 9 1019 6 1 2 1118 5 4 3 1217 16 15 14 13 1、Python&#xff1a; def format_…

每日一题(28)—— 引用与指针的区别

引用与指针有什么区别&#xff1f; &#xff08;1&#xff09;引用必须被初始化&#xff0c;指针不必&#xff1b; &#xff08;2&#xff09;引用初始化以后不能被改变&#xff0c;指针可以&#xff1b; &#xff08;3&#xff09;不存在指向空值的引用&#xff0c;但是存在…

聊聊 top 命令中的 CPU 使用率

之前写过cpu占用率的文章CPU占用率是什么&#xff1f;平常我们使用 top 命令来查看系统的性能情况&#xff0c;在 top 命令中可以看到很多不同类型的 CPU 使用率&#xff0c;如下图红框中标出部分&#xff1a;下面&#xff0c;我们来介绍一下这些 CPU 使用率的意义&#xff1a;…

Linux 脚本、 正则表达式 等

shell的脚步总是以这样的一行开头&#xff1a;#!/bin/bash这行叫做shebang顺序执行两个命令&#xff0c;可以$cmd1;cmd2要验证脚本语法的准确性&#xff0c;可以用bask-nscriptfilename来验证如果要debug则为bash-xscr.sh删除老的文件&#xff1a;find /home/wwwroot -type f-m…

哈尔特征Haar

哈尔特征&#xff08;Haar-like features&#xff09; 是用于物体识别的一种数字图像特征。它们因为与哈尔小波转换 极为相似而得名&#xff0c;是第一种即时的人脸检测運算。 历史上&#xff0c;直接使用图像的强度(就是图像每一个像素点的RGB值)使得特征的计算强度很大。帕帕…

乐鑫科技2022笔试面试题

来源于读者投稿&#xff0c;作者来源于牛客网的 galun 。投递方式&#xff1a;内推。岗位&#xff1a;嵌入式软件实习生。个人情况&#xff1a;本科双非电子信息工程&#xff0c;硕士华五软件工程研一在读&#xff1b;本科做过一些很水的项目 &#xff0c;也拿项目搞了一些奖&a…

每日一题(29)—— 如何引用一个已经定义过的全局变量

如何引用一个已经定义过的全局变量&#xff1f; extern关键字 可以用引用头文件的方式&#xff0c;也可以用extern关键字&#xff0c;如果用引用头文件方式来引用某个在头文件中声明的全局变理&#xff0c;假定你将那个变写错了&#xff0c;那么在编译期间会报错&#xff0c;如…