现在大家使用的基本上都是多核cpu,一般是4核的。平时应用程序在运行时都是由操作系统管理的。操作系统对应用进程进行调度,使其在不同的核上轮番运行。

对于普通的应用,操作系统的默认调度机制是没有问题的。但是,当某个进程需要较高的运行效率时,就有必要考虑将其绑定到单独的核上运行,以减小由于在不同的核上调度造成的开销。

把某个进程/线程绑定到特定的cpu核上后,该进程就会一直在此核上运行,不会再被操作系统调度到其他核上。但绑定的这个核上还是可能会被调度运行其他应用程序的。

操作系统对多核cpu的调度

目前windows和linux都支持对多核cpu进行调度管理。

软件开发在多核环境下的核心是多线程开发。这个多线程不仅代表了软件实现上多线程,要求在硬件上也采用多线程技术。

多核操作系统的关注点在于进程的分配和调度。进程的分配将进程分配到合理的物理核上,因为不同的核在共享性和历史运行情况都是不同的。有的物理核能够共享二级cache,而有的却是独立的。如果将有数据共享的进程分配给有共享二级cache的核上,将大大提升性能;反之,就有可能影响性能。

进程调度会涉及实时性、负载均衡等问题,目前研究的热点问题主要集中在以下方面:

  1. 程序的并行开发设计
  2. 多进程的时间相关性
  3. 任务的分配和调度
  4. 缓存的错误共享
  5. 一致性访问问题
  6. 进程间通信
  7. 多处理器核内部资源竞争

多进程和多线程在cpu核上运行时情况如下:
每个 CPU 核运行一个进程的时候,由于每个进程的资源都独立,所以 CPU 核心之间切换的时候无需考虑上下文
每个 CPU 核运行一个线程的时候,有时线程之间需要共享资源,所以这些资源必须从 CPU 的一个核心被复制到另外一个核心,这会造成额外的开销

绑定进程到cpu核上运行

查看cpu有几个核

使用cat /proc/cpuinfo查看cpu信息,如下两个信息:

processor,指明第几个cpu处理器
cpu cores,指明每个处理器的核心数
也可以使用系统调用sysconf获取cpu核心数:

#include <unistd.h>int sysconf(_SC_NPROCESSORS_CONF);/* 返回系统可以使用的核数,但是其值会包括系统中禁用的核的数目,因 此该值并不代表当前系统中可用的核数 */
int sysconf(_SC_NPROCESSORS_ONLN);/* 返回值真正的代表了系统当前可用的核数 *//* 以下两个函数与上述类似 */
#include <sys/sysinfo.h>int get_nprocs_conf (void);/* 可用核数 */
int get_nprocs (void);/* 真正的反映了当前可用核数 */

我使用的是虚拟机,有2个处理器,每个处理器只有一个核,等同于一个处理器两个核心。

使用taskset指令

获取进程pid

-> % ps
PID TTY TIME CMD
2683 pts/1 00:00:00 zsh
2726 pts/1 00:00:00 dgram_servr
2930 pts/1 00:00:00 ps

查看进程当前运行在哪个cpu上

-> % taskset -p 2726
pid 2726's current affinity mask: 3

显示的十进制数字3转换为2进制为最低两个是1,每个1对应一个cpu,所以进程运行在2个cpu上。

指定进程运行在cpu1上

-> % taskset -pc 1 2726
pid 2726's current affinity list: 0,1
pid 2726's new affinity list: 1

注意,cpu的标号是从0开始的,所以cpu1表示第二个cpu(第一个cpu的标号是0)。

至此,就把应用程序绑定到了cpu1上运行,查看如下:

-> % taskset -p 2726
pid 2726's current affinity mask: 2

启动程序时绑定cpu

#启动时绑定到第二个cpu
-> % taskset -c 1 ./dgram_servr&
[1] 3011#查看确认绑定情况
-> % taskset -p 3011
pid 3011's current affinity mask: 2

使用sched_setaffinity系统调用

sched_setaffinity可以将某个进程绑定到一个特定的CPU。

#define _GNU_SOURCE /* See feature_test_macros(7) */
#include <sched.h>/* 设置进程号为pid的进程运行在mask所设定的CPU上
* 第二个参数cpusetsize是mask所指定的数的长度
* 通常设定为sizeof(cpu_set_t)* 如果pid的值为0,则表示指定的是当前进程
*/
int sched_setaffinity(pid_t pid, size_t cpusetsize, cpu_set_t *mask);int sched_getaffinity(pid_t pid, size_t cpusetsize, cpu_set_t *mask);/* 获得pid所指示的进程的CPU位掩码,并将该掩码返回到mask所指向的结构中 */

实例

#include<stdlib.h>
#include<stdio.h>
#include<sys/types.h>
#include<sys/sysinfo.h>
#include<unistd.h>#define __USE_GNU
#include<sched.h>
#include<ctype.h>
#include<string.h>
#include<pthread.h>
#define THREAD_MAX_NUM 200 //1个CPU内的最多进程数int num=0; //cpu中核数
void* threadFun(void* arg) //arg 传递线程标号(自己定义)
{
cpu_set_t mask; //CPU核的集合
cpu_set_t get; //获取在集合中的CPU
int *a = (int *)arg;
int i;printf("the thread is:%d\n",*a); //显示是第几个线程
CPU_ZERO(&mask); //置空
CPU_SET(*a,&mask); //设置亲和力值
if (sched_setaffinity(0, sizeof(mask), &mask) == -1)//设置线程CPU亲和力
{
printf("warning: could not set CPU affinity, continuing...\n");
}CPU_ZERO(&get);
if (sched_getaffinity(0, sizeof(get), &get) == -1)//获取线程CPU亲和力
{
printf("warning: cound not get thread affinity, continuing...\n");
}
for (i = 0; i < num; i++)
{
if (CPU_ISSET(i, &get))//判断线程与哪个CPU有亲和力
{
printf("this thread %d is running processor : %d\n", i,i);
}
}return NULL;
}int main(int argc, char* argv[])
{
int tid[THREAD_MAX_NUM];
int i;
pthread_t thread[THREAD_MAX_NUM];num = sysconf(_SC_NPROCESSORS_CONF); //获取核数
if (num > THREAD_MAX_NUM) {
printf("num of cores[%d] is bigger than THREAD_MAX_NUM[%d]!\n", num, THREAD_MAX_NUM);
return -1;
}
printf("system has %i processor(s). \n", num);for(i=0;i<num;i++)
{
tid[i] = i; //每个线程必须有个tid[i]
pthread_create(&thread[i],NULL,threadFun,(void*)&tid[i]);
}
for(i=0; i< num; i++)
{
pthread_join(thread[i],NULL);//等待所有的线程结束,线程为死循环所以CTRL+C结束
}
return 0;
}

运行结果

-> % ./a.out
system has 2 processor(s).
the thread is:0
the thread is:1
this thread 0 is running processor : 0
this thread 1 is running processor : 1

绑定线程到cpu核上运行

绑定线程到cpu核上使用pthread_setaffinity_np函数,其原型定义如下:

#define _GNU_SOURCE /* See feature_test_macros(7) */
#include <pthread.h>int pthread_setaffinity_np(pthread_t thread, size_t cpusetsize, const cpu_set_t *cpuset);
int pthread_getaffinity_np(pthread_t thread, size_t cpusetsize, cpu_set_t *cpuset);Compile and link with -pthread.

各参数的意义与sched_setaffinity相似。

实例

#define _GNU_SOURCE
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>#define handle_error_en(en, msg) \
do { errno = en; perror(msg); exit(EXIT_FAILURE); } while (0)int
main(int argc, char *argv[])
{
int s, j;
cpu_set_t cpuset;
pthread_t thread;thread = pthread_self();/* Set affinity mask to include CPUs 0 to 7 */CPU_ZERO(&cpuset);
for (j = 0; j < 8; j++)
CPU_SET(j, &cpuset);s = pthread_setaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
if (s != 0)
handle_error_en(s, "pthread_setaffinity_np");/* Check the actual affinity mask assigned to the thread */s = pthread_getaffinity_np(thread, sizeof(cpu_set_t), &cpuset);
if (s != 0)
handle_error_en(s, "pthread_getaffinity_np");printf("Set returned by pthread_getaffinity_np() contained:\n");
for (j = 0; j < CPU_SETSIZE; j++)
if (CPU_ISSET(j, &cpuset))
printf(" CPU %d\n", j);exit(EXIT_SUCCESS);
}

运行结果

-> % ./a.out
Set returned by pthread_getaffinity_np() contained:
CPU 0
CPU 1

总结

可以使用多种方法把进程/线程指定到特定的cpu核上运行。

linux下把进程绑定到特定cpu核上运行相关推荐

  1. 为什么要把进程/线程绑定到特定cpu核上运行?(cpu core id coreIdx)opdevsdk_sys_bindThreadCoreId()

    看海康hikflow_demo代码,在线程处理函数里调用了绑定函数,把这个线程绑定到某个cpu核上,不知为何要这么做? 原因 答1 现在大家使用的基本上都是多核cpu,一般是4核的.平时应用程序在运行 ...

  2. linux指定cpu运行程序,进程/线程绑定到特定CPU核的linux实现(有代码有实例)

    前言 现在计算机上的CPU大多都是多核的,有4核甚至是8核的.但是一个计算机启动之后其进程数是远远多于CPU核数的,因为操作系统会给自动调度这些进程在CPU核上轮流运行.但是对于应用程序或者进程,其性 ...

  3. 使用 sched_setaffinity 将线程绑到CPU核上运行

    linux 提供CPU调度函数,可以将CPU某一个核和指定的线程绑定到一块运行. 这样能够充分利用CPU,且减少了不同CPU核之间的切换,尤其是在IO密集型压力之下能够提供较为友好的性能. 通过sch ...

  4. c和cpp实现CPU核上绑定固定线程

    文章目录 参考链接: 相关概念及工具 CPU亲和性 查看cpu有几个核 命令查看 代码查看 代码讲解 cpu集(cpu_set_t) cpu_set_t的使用 非动态分配cpu_set_t 动态分配c ...

  5. 在 Picorv32 / 蜂鸟 E203 软核上运行 RT-Thread

    这篇文章主要介绍一下如何在2个FPGA软核上运行 RT-Thread.首先会介绍一下我用的 FPGA,接下来分别介绍在 蜂鸟 E203 和 picorv32 上运行 RT-Thread. 如果大家对如 ...

  6. Renode应用:在RISC-V核上运行FreeRTOS

    本篇记录通过Renode在RISC-V核上运行FreeRTOS demo的情况.本来不准备写这一篇,但是发现近期工作学习密度实在太大,上周工作的中间结果这周竟然完全想不起来了,不得不又花了一些时间从头 ...

  7. asp.net core mvc中如何把二级域名绑定到特定的控制器上

    由于公司的工作安排,一直在研究其他技术,所以一直没时间更新博客,今天终于可以停下手头的事情,写一些新内容了. 应用场景:企业门户网站会根据内容不同,设置不同的板块,如新浪有体育,娱乐频道,等等.有的情 ...

  8. 在linux中配置编译u-boot方法,在ZC702上运行Linux(4)-编译和使用U-Boot Linux

    1. 安装工具链 如网页上所说,安装包xilinx-2011.09-50-arm-xilinx-linux-gnueabi.bin提示系统是dash,而安装包需要bash.按照提示运行命令 sudo ...

  9. 什么是“ Windows任务的主机进程”,为什么我的PC上运行着这么多主机?

    If you spend any time poking around through your Task Manager window, you've probably seen a process ...

最新文章

  1. 【sgTopo】强哥古法炮制、纯手工打造简单拓扑图、流程图、思维导图组件(完善中ing)
  2. linux 修改默认路径吗,linux中vsftp修改默认路径
  3. 开源项目SlidingMenu的使用(Android)
  4. linux shell oracle脚本_领导:如何用shell脚本统计Oracle数据库进程明细和存储过程信息...
  5. fit,fit_generator的使用区别
  6. as安装过程中gradle_电磁阀在安装过程中需注意的一些细节
  7. 无人驾驶轨迹跟踪之纯轨迹跟踪(Pure Pursuit)
  8. C++写OpenCV图像灰度化
  9. web前端期末大作业:美食文化网页设计与实现——美食餐厅三级(HTML+CSS+JavaScript)
  10. 拖拽化、低代码、可视化布局学习资料搜集
  11. 【翻译】Real-Time High-Resolution Background Matting
  12. 网络安全常用的主流数据库(DBMS)✍
  13. [源码解析] PyTorch 分布式之弹性训练(4)---Rendezvous 架构和逻辑
  14. 转:如何在艰难时期留住好员工
  15. 谁还不是一个宝宝了~
  16. Ajax学习日志(三)—— 如何传递get请求参数
  17. 到底snappy ubuntu core是什么?
  18. 爬取智联招聘上24座热门城市中Java招聘信息
  19. jq trigger
  20. weka遇到java.util.zip.ZipException: invalid LOC header (bad signature)

热门文章

  1. 爬一爬 iPhone 11为何嘴上说真丑,销量却真香?
  2. celery源码分析-worker初始化分析(下)
  3. 权限表管理之更新权限表数据
  4. 美多商城之用户中心(收货地址3)
  5. python函数的用法详解(作用、定义、调用、函数参数、函数返回值、函数说明文档、函数嵌套使用)
  6. python位运算符
  7. MATLAB_8-边缘检测_demo.m[课堂齿轮作业]其他的在文章末尾
  8. 网络工程师_要记录下来的一些题_4
  9. Linux里新建文件/目录的默认权限
  10. 为什么U-Net在医学图像上表现优越?