您可以捐助,支持我们的公益事业。

1元 10元 50元





认证码:  验证码,看不清楚?请点击刷新验证码 必填



  求知 文章 文库 Lib 视频 iPerson 课程 认证 咨询 工具 讲座 Model Center   Code  
会员   
   
 
   
 
 订阅
嵌入式中的多核开发和核间通信总结
 
 
  93  次浏览      6 次
 2025-1-13
 
编辑推荐:
本文主要介绍了嵌入式中的多核开发和核间通信总结相关内容。 希望对您的学习有所帮助。
本文来自于CSDN,由火龙果软件Linda编辑、推荐。

随着市场对嵌入式设备功能需求的提高,市面上出现了集成嵌入式处理器和单片机的主控方案,以兼顾性能和效率。 在实际应用中,嵌入式处理器和单片机之间需要进行大量且频繁的数据交换,如果采用低速串行接口,则数据传输效率低,这将严重影响产品的性能;而如果采用高速并口,则占用管脚多,硬件成本将会增加。 为解决这一痛点,各大芯片公司陆续推出了兼具A核和M核的多核异构处理器,如NXP的i.MX8系列、瑞萨的RZ/G2L系列以及TI的AM62x系列等等。虽然这些处理器的品牌及性能有所不同,但多核通信原理基本一致,都是基于寄存器和中断传递消息,基于共享内存传输数据。 以配电终端产品为例,A核负责通讯和显示等人机交互任务,M核负责采样和保护等对实时性要求较高的任务,双核间交互模拟量、开关量和录波文件等多种信息,A核+M核的方案既满足了传统采样保护功能,又支持多种接口通信及新增容器等功能,符合国家电网现行配电标准。

通过物理内存DDR分配,将硬件层分为了两部分:TXVring Buffer(发送虚拟环状缓冲区)和RXVring Buffer(接收虚拟环状缓冲区);其中M核从TXVring区发送数据,从RXVring区读取接收数据,A核反之。

硬件层通信实现机制

以imx8为例,在最底层硬件上,A核和M核通讯是靠硬件来进行的,称为MU,如图

处理器支持消息传递单元(MessagingUnit,简称MU)功能模块,通过MU传递消息进行通信和协调,芯片内的M控制核和A处理核通过通过寄存器中断的方式传递命令,最多支持4组MU双向传递消息,既可通过中断告知对方数据传递的状态,也可发送最多4字节数据,还可在低功耗模式下唤醒对方,是保证双核通信实时性的重要手段。

(1)CoreA写入数据;

(2)MU将Tx 空位清0,Rx满位置1;

(3)产生接收中断请求,通知CoreB接收状态寄存器中的接收器满,可以读取数据;

(4)CoreB响应中断,读取数据;

(5)CoreB读完数据后,MU将Rx满位清0,Tx空位置1;

(6)状态寄存器向CoreA生成发送中断请求,告知CoreB读完数据,发送寄存器空。

通过以上步骤,就完成了1次从CoreA向CoreB 传递消息的过程,反之亦然。

驱动层Virtio下RPMsg通信实现

Virtio是通用的IO虚拟化模型,位于设备之上的抽象层,负责前后端之间的通知机制和控制流程,为异构多核间数据通信提供了层的实现。 RPMsg消息框架是Linux系统基于Virtio缓存队列实现的主处理核和协处理核间进行消息通信的框架,当客户端驱动需要发送消息时,RPMsg会把消息封装成Virtio缓存并添加到缓存队列中以完成消息的发送,当消息总线接收到协处理器送到的消息时也会合理地派送给客户驱动程序进行处理。 在驱动层,对A核,Linux采用RPMsg框架+Virtio驱动模型,将RPMsg封装为了tty文件供应用层调用;在M核,将Virtio移植,并使用简化版的RPMsg,因为涉及到互斥锁和信号量,最终使用FreeRTOS完成过程的封装,流程框图如下方所示。

主处理核与协处理核数据传递流程图

(1)Core0向Core1发送数据,通过rpmsg_send函数将数据打包至Virtioavail链表区;

(2)在avail链表寻找共享内存中空闲缓存,将数据置于共享内存中;

(3)通过中断通知Core1数据到来,共享内存由avail链表区变至used区;

(4)Core1收到中断,触发rpmsg的接收回调函数,从used区获取数据所在的共享内存的物理地址,完成数据接收;

(5)通过中断通知Core0数据接收完成,共享内存缓存由used区变为avail区,供下次传输使用。

应用层双核通信实现方式

在应用层,对A核可使用open、write和read函数对 /dev下设备文件进行调用;对M核,可使用rpmsg_lite_remote_init、rpmsg_lite_send和rpmsg_queue_recv函数进行调用,不做重点阐述。

实际使用效果

通过程序实测,M核和A核可以批量传输大数据。同样以配电产品为例——128点采样的录波文件大约为43K,若通过传统的串行总线传输方式,需要数秒才可完成传输。 而使用i.MX8MP的双核异构通信方案,只需要不到0.5秒即可传输完成,数据传输效率提升数十倍!同时还避免了串行总线易受EMC干扰的问题,提高了数据传输稳定性,简化了应用编程,可满足用户快速开发的需求。

ARM内核A核、R核和M核的对比

直接参考:ARM内核A核、R核和M核的异同点和应用场景 - 知乎 (zhihu.com)

如何将进程、线程与CPU核进行绑定

参考:如何将进程、线程与CPU核进行绑定 - 知乎 (zhihu.com)

CPU绑定指的是在多核CPU的系统中将进程或线程绑定到指定的CPU核上去执行。在Linux中,我们可以利用CPU affinity属性把进程绑定到一个或多个CPU核上。

CPU Affinity是进程的一个属性,这个属性指明了进程调度器能够把这个进程调度到哪些CPU上。该属性要求进程在某个指定的CPU上尽量长时间地运行而不被迁移到其他处理器。

CPU Affinity分为2种:soft affinity和hard affinity。soft affinity只是一个建议,如果不可避免,调度器还是会把进程调度到其它的CPU上去执行;hard affinity则是调度器必须遵守的规则, 2.6以上版本的Linux内核可以让开发人员可以编程实现hard affinity。

使用hard affinity的意义

提高CPU缓存命中率

CPU各核之间是不共享缓存的,如果进程频繁地在多个CPU核之间切换,则会使旧CPU核的cache失效,失去了利用CPU缓存的优势。如果进程只在某个CPU上执行,可以避免进程在一个CPU上停止执行,然后在不同的CPU上重新执行时发生的缓存无效而引起的性能成本。

适合对时间敏感的应用

在实时性要求高应用中,我们可以把重要的系统进程绑定到指定的CPU上,把应用进程绑定到其余的CPU上。这种做法确保对时间敏感的应用程序可以得到运行,同时可以允许其他应用程序使用其余的计算资源。

如何将进程与CPU核进行绑定

系统函数

在Linux中,用结构体cpu_set_t来表示CPU Affinity掩码,同时定义了一系列的宏来用于操作进程的可调度CPU集合:

  1. #define _GNU_SOURCE
  2. #include <sched.h>
  3. void CPU_ZERO(cpu_set_t *set);
  4. void CPU_SET(int cpu, cpu_set_t *set);
  5. void CPU_CLR(int cpu, cpu_set_t *set);
  6. int CPU_ISSET(int cpu, cpu_set_t *set);
  7. int CPU_COUNT(cpu_set_t *set);

 

具体的作用如下:

  1. CPU_ZERO():清除集合的内容,让其不包含任何CPU。
  2. CPU_SET():添加cpu到集合中。
  3. CPU_CLR():从集合中移除cpu
  4. CPU_ISSET() :测试cpu是否在集合中。
  5. CPU_COUNT():返回集合中包含的CPU数量。

 

在Linux中,可以使用以下两个函数设置和获取进程的CPU Affinity属性:

  1. #define _GNU_SOURCE
  2. #include <sched.h>
  3. int sched_setaffinity(pid_t pid, size_t cpusetsize,const cpu_set_t *mask);
  4. int sched_getaffinity(pid_t pid, size_t cpusetsize,cpu_set_t *mask);

 

另外可以通过下面的函数获知当前进程运行在哪个CPU上:

int sched_getcpu(void);

 

如果调用成功,该函数返回一个非负的CPU编号值。

例程

  1. #define _GNU_SOURCE
  2. #include <sched.h>
  3. #include <unistd.h>
  4. #include <sys/types.h>
  5. #include <sys/wait.h>
  6. #include <stdio.h>
  7. #include <stdlib.h>
  8. int main(int argc, char *argv[])
  9. {
  10. cpu_set_t set;
  11. int parentCPU, childCPU;
  12. int j;
  13. int cpu_num = -1;
  14. if (argc != 3) {
  15. fprintf(stderr, "Usage: %s parent-cpu child-cpu\n", argv[0]);
  16. exit(EXIT_FAILURE);
  17. }
  18. parentCPU = atoi(argv[1]);
  19. childCPU = atoi(argv[2]);
  20. CPU_ZERO(&set);
  21. switch (fork()) {
  22. case -1: { /* Error */
  23. fprintf(stderr, "fork error\n");
  24. exit(EXIT_FAILURE);
  25. }
  26. case 0: { /* Child */
  27. CPU_SET(childCPU, &set);
  28. if (sched_setaffinity(getpid(), sizeof(set), &set) == -1) {
  29. fprintf(stderr, "child sched_setaffinity error\n");
  30. exit(EXIT_FAILURE);
  31. }
  32. sleep(1);
  33. if (-1 != (cpu_num = sched_getcpu())) {
  34. fprintf(stdout, "The child process is running on cpu %d\n", cpu_num);
  35. }
  36. exit(EXIT_SUCCESS);
  37. }
  38. default: { /* Parent */
  39. CPU_SET(parentCPU, &set);
  40. if (sched_setaffinity(getpid(), sizeof(set), &set) == -1) {
  41. fprintf(stderr, "parent sched_setaffinity error\n");
  42. exit(EXIT_FAILURE);
  43. }
  44. if (-1 != (cpu_num = sched_getcpu())) {
  45. fprintf(stdout, "The parent process is running on cpu %d\n", cpu_num);
  46. }
  47. wait(NULL); /* Wait for child to terminate */
  48. exit(EXIT_SUCCESS);
  49. }
  50. }
  51. }

 

 

程序首先用CPU_ZERO清空CPU集合,然后调用fork()函数创建一个子进程,并调用sched_setaffinity()函数给父进程和子进程分别设置CPU Affinity,输入参数parentCPU和childCPU分别指定父进程和子进程运行的CPU号。指定父进程和子进程运行的CPU为1和0,程序输出如下:

  1. # ./affinity_test 1 0
  2. The parent process is running on cpu 1
  3. The child process is running on cpu 0

 

如何将线程与CPU核进行绑定

系统函数

前面介绍了进程与CPU的绑定,那么线程可不可以与CPU绑定呢?当然是可以的。在Linux中,可以使用以下两个函数设置和获取线程的CPU Affinity属性:

  1. #define _GNU_SOURCE
  2. #include <pthread.h>
  3. int pthread_setaffinity_np(pthread_t thread, size_t cpusetsize, const cpu_set_t *cpuset);
  4. int pthread_getaffinity_np(pthread_t thread, size_t cpusetsize, cpu_set_t *cpuset);

 

例程

  1. #define _GNU_SOURCE
  2. #include <pthread.h>
  3. #include <stdio.h>
  4. #include <stdlib.h>
  5. #include <errno.h>
  6. static void *thread_start(void *arg) {
  7. ......
  8. struct thread_info *tinfo = arg;
  9. thread = tinfo->thread_id;
  10. CPU_ZERO(&cpuset);
  11. CPU_SET(tinfo->thread_num, &cpuset);
  12. s = pthread_setaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
  13. if (s != 0) {
  14. handle_error_en(s, "pthread_setaffinity_np");
  15. }
  16. CPU_ZERO(&cpuset);
  17. s = pthread_getaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
  18. if (s != 0) {
  19. handle_error_en(s, "pthread_getaffinity_np");
  20. }
  21. for (j = 0; j < cpu_num; j++) {
  22. if (CPU_ISSET(j, &cpuset)) { //如果当前线程运行在CPU j上,则输出信息
  23. printf(" thread %d is running on cpu %d\n", tinfo->thread_num, j);
  24. }
  25. }
  26. pthread_exit(NULL);
  27. }
  28. int main(int argc, char *argv[])
  29. {
  30. ......
  31. cpu_num = sysconf(_SC_NPROCESSORS_CONF); //获取系统的CPU数量
  32. tinfo = calloc(cpu_num, sizeof(struct thread_info));
  33. if (tinfo == NULL) {
  34. handle_error_en(0, "calloc");
  35. }
  36. for (j = 0; j < cpu_num; j++) { //有多少个CPU就创建多少个线程
  37. tinfo[j].thread_num = j;
  38. s = pthread_create(&tinfo[j].thread_id, NULL, thread_start, &tinfo[j]);
  39. if (s != 0) {
  40. handle_error_en(s, "pthread_create");
  41. }
  42. }
  43. for (j = 0; j < cpu_num; j++) {
  44. s = pthread_join(tinfo[j].thread_id, NULL);
  45. if (s != 0) {
  46. handle_error_en(s, "pthread_join");
  47. }
  48. }
  49. ......
  50. }

 

程序首先获取当前系统的CPU数量cpu_num,然后根据CPU数量的数量创建线程,有多少个CPU就创建多少个线程,每个线程都运行在不同的CPU上。在4核的机器中运行结果如下:

  1. $ ./thread_affinity
  2. thread 1 is running on cpu 1
  3. thread 0 is running on cpu 0
  4. thread 3 is running on cpu 3
  5. thread 2 is running on cpu 2

用taskset命令实现进程与CPU核的绑定

Linux 的taskset命令用于设置或检索由pid指定的运行进程的CPU Affinity,或者以给定的CPU Affinity属性启动新的进程。CPU Affinity属性用位掩码来表示,其中最低位对应第一逻辑CPU,最后一位与最后一个逻辑CPU对应。检索到的掩码仅反映与物理系统上的CPU相对应的位。如果给出无效的掩码(即当前系统上没有对应的有效的CPU掩码),则返回错误。掩码通常以十六进制形式给出。例如:

  1. 0x00000001 表示CPU #0,
  2. 0x00000003 表示CPU #0 和 #1,
  3. 0x0000000f 表示CPU #0 ~ #3

 

taskset命令的选项如下:

  1. -a, --all-tasks
  2. 设置或检索所有由pid指定的进程的CPU Affinity属性。
  3. -c, --cpu-list numbers
  4. 指定处理器的数值列表,而不是位掩码。数字用逗号分隔,可以包括范围。比如:0,5,8-11
  5. -p, --pid
  6. 操作由pid指定的进程,不启动新的进程。

 

下面以Ubuntu16.04中的taskset命令说明该命令的使用方法:

显示进程运行的CPU核

  1. 命令:taskset -p 1
  2. 结果:pid 1‘s current affinity mask: f
  3. 说明:f表示进程1运行在CPU#0~CPU#3

 

指定进程运行在某个特定的CPU核上

  1. 命令:taskset -cp 1,2 7737
  2. 结果:pid 7737's current affinity list: 0-3
  3. pid 7737's new affinity list: 1,2
  4. 说明:该操作把进程7737限定在CPU#1~CPU#2上运行。

 

进程启动时指定CPU核

  1. 命令:taskset -c 1-2 ./get_affinity
  2. 结果:This process is running on cpu 1
  3. This process is running on cpu 2
  4. 说明:get_affinity程序通过sched_getaffinity()函数获取当前进程的CPU Affinity属性并输出提示信息。

 

本文通过几个简单的例子介绍了Linux环境下进程、线程与CPU的绑定方法,希望对大家有参考意义。

   
93 次浏览       6
 
相关文章

CMM之后对CMMI的思考
对软件研发项目管理的深入探讨
软件过程改进
软件过程改进的实现
 
相关文档

软件过程改进框架
软件过程改进的CMM-TSP-PSP模型
过程塑造(小型软件团队过程改进)
软件过程改进:经验和教训
 
相关课程

以"我"为中心的过程改进(iProcess )
iProcess过程改进实践
CMMI体系与实践
基于CMMI标准的软件质量保证

最新活动计划
SysML和EA系统设计与建模 1-16[北京]
企业架构师(业务、应用、技术) 1-23[北京]
大语言模型(LLM)Fine Tune 2-22[在线]
MBSE(基于模型的系统工程)2-27[北京]
OpenGauss数据库调优实践 3-11[北京]
UAF架构体系与实践 3-25[北京]
 
 
最新文章
iPerson的过程观:要 过程 or 结果
基于模型的需求管理方法与工具
敏捷产品管理之 Story
敏捷开发需求管理(产品backlog)
Kanban看板管理实践精要
最新课程
基于iProcess的敏捷过程
软件开发过程中的项目管理
持续集成与敏捷开发
敏捷过程实践
敏捷测试-简单而可行
更多...   
成功案例
英特尔 SCRUM-敏捷开发实战
某著名汽车 敏捷开发过程与管理实践
北京 敏捷开发过程与项目管理
东方证券 基于看板的敏捷方法实践
亚信 工作量估算
更多...