Linux 多线程编程详解

目录

为什么要使用多线程

线程概念

线程的标识 pthread_t

线程的创建

向线程传入参数

线程的退出与回收

线程主动退出

线程被动退出

线程资源回收(阻塞方式)

线程资源回收(非阻塞方式)

为什么要使用多线程

在编写代码时，是否会遇到以下的场景会感觉到难以下手？

要做 2 件事，一件需要阻塞等待，另一件需要实时进行。例如播放器：一边 在屏幕上播放视频，一边在等待用户的按键操作。如果使用单线程的话，程序必 须一会查询有无按键，一会播放视频。查询按键太久，就会导致视频播放卡顿； 视频播放太久，就无法及时响应用户的操作。并且查询按键和播放视频的代码混杂在一起，代码丑陋。

如果使用多线程，线程 1 单独处理按键，线程 2 单独处理播放，可以完美解决上述问题

线程概念

所谓线程，就是操作系统所能调度的最小单位。

普通的进程，只有一个线程在执行对应的逻辑。我们可以通过多线程编程，使一个进程可以去执行多个不同的任务。相比多进程编程而言，线程享有共享资源，即在进程中出现的全局变量， 每个线程都可以去访问它，与进程共享“4G”内存空间，使得系统资源消耗减少。 本章节来讨论 Linux 下 POSIX 线程。

线程的标识 pthread_t

对于进程而言，每一个进程都有一个唯一对应的 PID 号来表示该进程

而对于线程而言，也有一个“类似于进程的 PID 号”，名为 tid，其本质是一个 pthread_t 类型的变量。线程号与进程号是表示线程和进程的唯一标识，但是对于线程号而言，其仅仅在其所属的进程上下文中才有意义。

获取线程号

#include <pthread.h>

pthread_t pthread_self(void);

成功：返回线程号

在程序中，可以通过函数 pthread_self，来返回当前线程的线程号，例程 1 给出了打印线程 tid 号。

测试例程 1：（Phtread_txex1.c）

#include <pthread.h>
#include <stdio.h>int main()
{pthread_t tid = pthread_self();printf("tid = %lu\n",(unsigned long)tid);return 0;
}

因采用 POSIX 线程接口，故在要编译的时候包含 pthread 库

使用 gcc 编译应 gcc xxx.c -lpthread 方可编译多线程程序

编译结果：

线程的创建

怎么创建线程呢？

使用 pthread_create 函数：

创建线程

#include <pthread.h>

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routine) (void *), void *arg);

  • 第一个参数为 pthread_t 指针，用来保存新建线程的线程号；
  • 第二个参数表示了线程的属性，一般传入 NULL 表示默认属性；
  • 第三个参数是一个函数指针，就是线程执行的函数。这个函数返回值为 void*， 形参为 void*。
  • 第四个参数则表示为向线程处理函数传入的参数，若不传入，可用 NULL 填充， 有关线程传参后续小节会有详细的说明，接下来通过一个简单例程来使用该函数创建出一个线程。

测试例程 2：（Phtread_txex2.c）

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun(void *arg)
{printf("pthread_New = %lu\n",(unsigned long)pthread_self());
}int main()
{pthread_t tid1;int ret = pthread_create(&tid1,NULL,fun,NULL);if(ret != 0){perror("pthread_create");return -1;}/*tid_main 为通过pthread_self获取的线程ID，tid_new通过执行pthread_create成功后tid指向的空间*/printf("tid_main = %lu tid_new = %lu \n",(unsigned long)pthread_self(),(unsigned long)tid1);/*因线程执行顺序随机，不加sleep可能导致猪线程先执行，导致进程结束，无法执行到子线程*/sleep(1);return 0;
}

运行结果：

通过 pthread_create 确 实 可 以 创 建 出 来 线 程 ， 主 线 程 中 执 行 pthread_create 后 的 tid 指向了线程号空间，与子线程通过函数 pthread_self 打印出来的线程号一致。

特别说明的是，当主线程伴随进程结束时，所创建出来的线程也会立即结束， 不会继续执行。并且创建出来的线程的执行顺序是随机竞争的，并不能保证哪一 个线程会先运行。可以将上述代码中 sleep 函数进行注释，观察实验现象。

上述运行代码 3 次，其中有 2 次被进程结束，无法执行到子线程的逻辑，最后一 次则执行到了子线程逻辑后结束的进程。如此可以说明，线程的执行顺序不受控制，且整个进程结束后所产生的线程也随之被释放，在后续内容中将会描述如何 控制线程执行。

向线程传入参数

pthread_create()的最后一个参数的为 void*类型的数据，表示可以向线 程传递一个 void*数据类型的参数，线程的回调函数中可以获取该参数，例程 3 举例了如何向线程传入变量地址与变量值。

测试例程 3：（Phtread_txex3.c）

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun1(void *arg)
{printf("%s:arg = %d Addr = %p\n",__FUNCTION__,*(int *)arg,arg);
}void *fun2(void *arg)
{printf("%s:arg = %d Addr = %p\n",__FUNCTION__,(int)(long)arg,arg);
}int main()
{pthread_t tid1,tid2;int a = 50;int ret = pthread_create(&tid1,NULL,fun1,(void *)&a); // 21 创建线程传入变量 a 的地址if(ret != 0){perror("pthread_create");return -1;}ret = pthread_create(&tid2,NULL,fun2,(void *)(long)a); // 27 创建线程传入变量 a 的值if(ret != 0){perror("pthread_create");return -1;}sleep(1);printf("%s:a = %d Add = %p \n",__FUNCTION__,a,&a);return 0;
}

运行结果：

例程展示了如何利用线程创建函数的第四个参数向线程传入数据，举例了如何以地址的方式传入值、以变量的方式传入值，

例程代码的 21 行，是将变量 a 先行取地址后，再次强制类型转化为 void*后传入线程，线程处理的回调函数 中，先将万能指针 void*转化为 int*，再次取地址就可以获得该地址变量的值， 其本质在于地址的传递。

例程代码的 27 行，直接将 int 类型的变量强制转化为 void*进行传递（针对不同位数机器，指针对其字数不同，需要 int 转化为 long 在转指针，否则可能会发生警告），在线程处理回调函数中，直接将 void*数据转 248 / 566 化为 int 类型即可，本质上是在传递变量 a 的值。 上述两种方法均可得到所要的值，但是要注意其本质，一个为地址传递，一 个为值的传递。当变量发生改变时候，传递地址后，该地址所对应的变量也会发 生改变，但传入变量值的时候，即使地址指针所指的变量发生变化，但传入的为 变量值，不会受到指针的指向的影响，实际项目中切记两者之间的区别。具体说明见例程 4。

测试例程 4：（Phtread_txex4.c）

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun1(void *arg)
{while(1){printf("%s:arg = %d Addr = %p\n",__FUNCTION__,*(int *)arg,arg);sleep(1);}
}void *fun2(void *arg)
{while(1){printf("%s:arg = %d Addr = %p\n",__FUNCTION__,(int)(long)arg,arg);sleep(1);}
}int main()
{pthread_t tid1,tid2;int a = 50;int ret = pthread_create(&tid1,NULL,fun1,(void *)&a);if(ret != 0){perror("pthread_create");return -1;}sleep(1);ret = pthread_create(&tid2,NULL,fun2,(void *)(long)a);if(ret != 0){perror("pthread_create");return -1;}while(1){a++;sleep(1);printf("%s:a = %d Add = %p \n",__FUNCTION__,a,&a);}return 0;
}

运行结果：

上述例程讲述了如何向线程传递一个参数，在处理实际项目中，往往会遇到 传递多个参数的问题，我们可以通过结构体来进行传递，解决此问题。

测试例程 5：（Phtread_txex5.c）

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>struct Stu{int Id;char Name[32];float Mark;
};void *fun1(void *arg)
{struct Stu *tmp = (struct Stu *)arg;printf("%s:Id = %d Name = %s Mark = %.2f\n",__FUNCTION__,tmp->Id,tmp->Name,tmp->Mark);}int main()
{pthread_t tid1,tid2;struct Stu stu;stu.Id = 10000;strcpy(stu.Name,"ZhangSan");stu.Mark = 94.6;int ret = pthread_create(&tid1,NULL,fun1,(void *)&stu);if(ret != 0){perror("pthread_create");return -1;}printf("%s:Id = %d Name = %s Mark = %.2f\n",__FUNCTION__,stu.Id,stu.Name,stu.Mark);sleep(1);return 0;
}

运行结果：

线程的退出与回收

线程的退出情况有三种：第一种是进程结束，进程中所有的线程也会随之结束。

第二种是通过函数 pthread_exit 来主动的退出线程。

第三种被其他线程调用 pthread_cancel 来被动退出。

当线程结束后，主线程可以通过函数 pthread_join/pthread_tryjoin_np 来回收线程的资源，并且获得线程结束后需要返回的数据。

线程主动退出

pthread_exit 函数原型如下：

线程主动退出

#include <pthread.h>

void pthread_exit(void *retval);

pthread_exit 函数为线程退出函数，在退出时候可以传递一个 void*类型的数据带给主线程，若选择不传出数据，可将参数填充为 NULL。

线程被动退出

pthread_cancel 函数原型如下：

线程被动退出，其他线程使用该函数让另一个线程退出

#include <pthread.h> 

int pthread_cancel(pthread_t thread);

成功：返回 0

该函数传入一个 tid 号，会强制退出该 tid 所指向的线程，若成功执行会返回 0。

线程资源回收(阻塞方式)

thread_join 函数原型如下：

线程资源回收（阻塞）

#include <pthread.h> 

int pthread_join(pthread_t thread, void **retval);

该函数为线程回收函数，默认状态为阻塞状态，直到成功回收线程后才返回。第一个参数为要回收线程的 tid 号，第二个参数为线程回收后接受线程传出的数据。

线程资源回收(非阻塞方式)

pthread_tryjoin_np 函数原型如下：

线程资源回收（非阻塞）

#define _GNU_SOURCE

#include <pthread.h> 

int pthread_tryjoin_np(pthread_t thread, void **retval);

该函数为非阻塞模式回收函数，通过返回值判断是否回收掉线程，成功回 收则返回 0，其余参数与 pthread_join 一致。

测试例程 6：（Phtread_txex6.c）

#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun1(void *arg)
{static int tmp = 0; // 8 必须要static修饰，否则pthread_join无法获取到正确值//int tmp = 0;tmp = *(int *)arg;tmp+=100;printf("%s:Addr = %p tmp = %d\n",__FUNCTION__,&tmp,tmp);pthread_exit((void *)&tmp);
}int main()
{pthread_t tid1;int a = 50;void *Tmp = NULL;int ret = pthread_create(&tid1,NULL,fun1,(void *)&a); // 23if(ret != 0){perror("pthread_create");return -1;}pthread_join(tid1,&Tmp);printf("%s:Addr = %p Val = %d\n",__FUNCTION__,Tmp,*(int *)Tmp);return 0;
}

运行结果：

上述例程先通过 23 行将变量以地址的形式传入线程，在线程中做出了自加 100 的操作，当线程退出的时候通过线程传参，用 void*类型的数据通过 pthread_join 接 受 。 此 例 程 去 掉 了 之 前 加 入 的 sleep 函 数 ， 原 因 是 pthread_join 函数具备阻塞的特性，直至成功收回掉线程后才会冲破阻塞，因 此不需要靠考虑主线程会执行到 30 行结束进程的情况。

特别要说明的是例程第 8 行，当变量从线程传出的时候，需要加 static 修饰，对生命周期做出延续， 否则无法传出正确的变量值。

测试例程 7：（Phtread_txex7.c）

#define _GNU_SOURCE 
#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun(void *arg)
{printf("Pthread:%d Come !\n",(int )(long)arg+1);pthread_exit(arg);
}int main()
{int ret,i,flag = 0;void *Tmp = NULL;pthread_t tid[3];for(i = 0;i < 3;i++){ret = pthread_create(&tid[i],NULL,fun,(void *)(long)i);if(ret != 0){perror("pthread_create");return -1;}}while(1){for(i = 0;i <3;i++){if(pthread_tryjoin_np(tid[i],&Tmp) == 0){printf("Pthread : %d exit !\n",(int )(long )Tmp+1);flag++;	}}if(flag >= 3) break;}return 0;
}

运行结果：

例程 7 展示了如何使用非阻塞方式来回收线程，此外也展示了多个线程可 以指向同一个回调函数的情况。

例程 6 通过阻塞方式回收线程几乎规定了线程回收的顺序，若最先回收的线程未退出，则一直会被阻塞，导致后续先退出的 线程无法及时的回收。

通过函数 pthread_tryjoin_np，使用非阻塞回收，线程可以根据退出先 后顺序自由的进行资源的回收。

测试例程 8：（Phtread_txex8.c）

#define _GNU_SOURCE 
#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <errno.h>void *fun1(void *arg)
{printf("Pthread:1 come!\n");while(1){sleep(1);}
}void *fun2(void *arg)
{printf("Pthread:2 come!\n");pthread_cancel((pthread_t )(long)arg); // 杀死线程 1，使之强制退出pthread_exit(NULL);
}int main()
{int ret,i,flag = 0;void *Tmp = NULL;pthread_t tid[2];ret = pthread_create(&tid[0],NULL,fun1,NULL); // 27if(ret != 0){perror("pthread_create");return -1;}sleep(1);ret = pthread_create(&tid[1],NULL,fun2,(void *)tid[0]); // 33 传输线程 1 的线程号if(ret != 0){perror("pthread_create");return -1;}while(1){ //通过非阻塞方式收回线程，每次成功回收一个线程变量自增，直至 2 个线程全数回收for(i = 0;i <2;i++){if(pthread_tryjoin_np(tid[i],NULL) == 0){printf("Pthread : %d exit !\n",i+1);flag++;	}}if(flag >= 2) break;}return 0;
}

运行结果：

例程 8 展示了如何利用 pthread_cancel 函数主动的将某个线程结束。

27 行与 33 行创建了线程，将第一个线程的线程号传参形式传入了第二个线程。第一个的线程执行死循环睡眠逻辑，理论上除非进程结束，其永远不会结束，但在第二个线程中调用了 pthread_cancel 函数，相当于向该线程发送一个退出的指令，导致线程被退出，最终资源被非阻塞回收掉。

此例程要注意第 32 行的 sleep 函数，一定要确保线程 1 先执行，因线程是无序执行，故加入该睡眠函数控制顺序

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

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

相关文章

后期混音效果全套插件Waves 14 Complete mac中文版新增功能

后期混音效果全套插件Waves 14 Complete mac中文版新增功能

Waves 14 Complete for Mac是一款后期混音效果全套插件&#xff0c;Waves音频插件,内置混响&#xff0c;压缩&#xff0c;降噪和EQ等要素到建模的模拟硬件&#xff0c;环绕声和后期制作工具&#xff0c;包含全套音频效果器&#xff0c;是可以让你使用所有功能。Waves 14 Comple…
阅读更多...
Vue3全局共享数据

Vue3全局共享数据

目录 1&#xff0c;Vuex2&#xff0c;provide & inject2&#xff0c;global state4&#xff0c;Pinia5&#xff0c;对比 1&#xff0c;Vuex vue2 的官方状态管理器&#xff0c;vue3 也是可以用的&#xff0c;需要使用 4.x 版本。 相对于 vuex3.x&#xff0c;有两个重要变…
阅读更多...
微信小程序电商审核模版

微信小程序电商审核模版

《电商平台服务协议》与交易规则 下载链接 电商平台对入驻经营者的审核要求或规范文件 下载链接 电商平台对用户交易纠纷处理的机制或方案 下载链接 打包下载&#xff1a;https://download.csdn.net/download/nicepainkiller/88519604https://download.csdn.net/download/nicep…
阅读更多...
拓世科技集团打造数字人营销解决方案，为车企提供新的“增长担当”

拓世科技集团打造数字人营销解决方案，为车企提供新的“增长担当”

汽车&#xff0c;已经渐渐融入了现代人的日常生活&#xff0c;从高端的身份标志转变为普罗大众的出行选择&#xff0c;它驶入了千家万户&#xff0c;成为了我们日常出行的可靠伙伴&#xff0c;见证着人们的生活故事和时代的变迁。 中国汽车市场的蓬勃发展引起了业内外的广泛关…
阅读更多...
怎样使用ovsyunlive在web网页上直接播放rtsp/rtmp视频

怎样使用ovsyunlive在web网页上直接播放rtsp/rtmp视频

业务中需要在网页中直接播放rtsp和rtmp视频&#xff0c;多方比较测试发现ovsyunlive的播放器能直接播放rtsp/rtmp视频&#xff0c;还是非常方便简洁&#xff0c;使用过程如下&#xff1a; 1&#xff0c;Windows系统在github上面下载ovsyunlive绿色包下载解压。 github地址&am…
阅读更多...
Android Studio代码无法自动补全

Android Studio代码无法自动补全

Android Studio代码自动无法补全问题解决 在写layout布局文件时&#xff0c;代码不提示&#xff0c;不自动补全&#xff0c;可以采用如下方法&#xff1a; 点击File—>Project Structure&#xff0c;之后如图所示&#xff0c;找到左侧Modules&#xff0c;修改SDK版本号&…
阅读更多...
『 MySQL数据库 』数据库基础之表的基本操作

『 MySQL数据库 』数据库基础之表的基本操作

文章目录 创建表&#x1f5e1;查看表&#x1f5e1;✒ 查看表内所有信息(描述\表结构等)✒ 根据条件查看表内数据✒ 查看表的具体详细信息: 修改表&#x1f5e1;✒ 修改表名:✒ 修改表的存储引擎、编码集(字符集和校验集):✒ 表内插入数据:insert into✒ 在表中新添一个字段(列)…
阅读更多...
pytorch中常用的损失函数

pytorch中常用的损失函数

1 损失函数的作用 损失函数是模型训练的基础&#xff0c;并且在大多数机器学习项目中&#xff0c;如果没有损失函数&#xff0c;就无法驱动模型做出正确的预测。 通俗地说&#xff0c;损失函数是一种数学函数或表达式&#xff0c;用于衡量模型在某些数据集上的表现。损失函数在…
阅读更多...
解决Jenkins执行git脚本时报错：No such device or address问题

解决Jenkins执行git脚本时报错：No such device or address问题

问题现象&#xff1a; Jenkins执行BeanShell脚本时&#xff0c;报错&#xff1a;jenkins fatal: could not read Username for http://112.11.120.1: No such device or address 解决方案&#xff1a; 解决服务器拉取git仓库的代码权限&#xff0c;使用高级子模块克隆功能。…
阅读更多...
mysql千万数据快速插入-实战

mysql千万数据快速插入-实战

文章目录 前言环境一、配置二、效果总结 前言 数据量太大了&#xff0c;每天半夜要同步很大数据到 mysql 数据库&#xff0c;其中一张表就上2千万&#xff0c;总计上亿条数据。同步任务每天0点之后开始任务&#xff08;因为到0之后才能统计前一天数据&#xff09;&#xff0c;…
阅读更多...
Tcl语言：基础入门（一）

Tcl语言：基础入门（一）

Tcl语言https://blog.csdn.net/weixin_45791458/category_12488978.html?spm1001.2014.3001.5482 Tcl语言是一种脚本语言&#xff0c;类似于Bourne shell(sh)、C shell&#xff08;csh&#xff09;、Bourne-Again Shell(bash)等UNIX shell语言。Shell程序主要作为胶水缝合其他…
阅读更多...
线性代数（六）| 二次型 标准型转换 正定二次型 正定矩阵

线性代数（六）| 二次型 标准型转换 正定二次型 正定矩阵

文章目录 1. 二次型化为标准型1.1 正交变换法1.2 配方法 2 . 正定二次型与正定矩阵 1. 二次型化为标准型 和第五章有什么样的联系 首先上一章我们说过对于对称矩阵&#xff0c;一定存在一个正交矩阵Q&#xff0c;使得$Q^{-1}AQB $ B为对角矩阵 那么这一章中&#xff0c;我们…
阅读更多...
配置阿里云镜像加速器 -docker

配置阿里云镜像加速器 -docker

1.百度aliyun 2.找到镜像服务ACR 3.搞一个个人版&#xff0c;身份验证一下就行了很简单 4.找到镜像加速器Centos 5.在xshell执行下面4条命令&#xff1a;4条命令直接从上面操作文档中粘贴&#xff0c;不容易出错 sudo mkdir -p /etc/docker sudo tee /etc/docker/daemon.json…
阅读更多...
module ‘torch‘ has no attribute ‘_six‘

module ‘torch‘ has no attribute ‘_six‘

主要问题是torchvision的问题 在122服务器上的scvi-env2环境中 import torch import torch.nn as nnimport numpy as npfrom tqdm import tqdm from torchvision.utils import save_image, make_grid # Model Hyperparametersdataset_path ./datasetscuda True DEVICE tor…
阅读更多...
【数据结构】树与二叉树（七）：二叉树的遍历

【数据结构】树与二叉树（七）：二叉树的遍历

文章目录 5.1 树的基本概念5.1.1 树的定义5.1.2 森林的定义5.1.3 树的术语5.1.4 树的表示 5.2 二叉树5.2.1 二叉树1. 定义2. 特点3. 性质引理5.1&#xff1a;二叉树中层数为i的结点至多有 2 i 2^i 2i个&#xff0c;其中 i ≥ 0 i \geq 0 i≥0。引理5.2&#xff1a;高度为k的二叉…
阅读更多...
GDPU 数据结构 天码行空9

GDPU 数据结构 天码行空9

实验九 哈夫曼编码 一、【实验目的】 1、理解哈夫曼树的基本概念 2、掌握哈夫曼树的构造及数据结构设计 3、掌握哈夫曼编码问题设计和实现 二、【实验内容】 1、假设用于通信的电文仅由8个字母 {a, b, c, d, e, f, g, h} 构成&#xff0c;它们在电文中出现的概率分别为{ 0.…
阅读更多...
简单的小调度器

简单的小调度器

收集小资源下的简单调度器 https://github.com/sigma318/TOS/tree/master https://github.com/smset028/xxddq
阅读更多...
uniapp+uview2.0+vuex实现自定义tabbar组件

uniapp+uview2.0+vuex实现自定义tabbar组件

效果图 1.在components文件夹中新建MyTabbar组件 2.组件代码 <template><view class"myTabbarBox" :style"{ backgroundColor: backgroundColor }"><u-tabbar :placeholder"true" zIndex"0" :value"MyTabbarS…
阅读更多...
[100天算法】-面试题 17.11.单词距离（day 68）

[100天算法】-面试题 17.11.单词距离（day 68）

题目描述 有个内含单词的超大文本文件&#xff0c;给定任意两个单词&#xff0c;找出在这个文件中这两个单词的最短距离(相隔单词数)。如果寻找过程在这个文件中会重复多次&#xff0c;而每次寻找的单词不同&#xff0c;你能对此优化吗?示例&#xff1a;输入&#xff1a;word…
阅读更多...
线性代数 | 矩阵运算 加减 数乘 矩阵的幂运算

线性代数 | 矩阵运算 加减 数乘 矩阵的幂运算

文章目录 1 矩阵加减和数乘2 矩阵与矩阵的乘法2.1 相乘条件&#xff1a;看中间&#xff0c;取两头2.2 相乘计算方法 3 矩阵的幂3.1 观察归纳法3.2 邻项相消法3.3 化为对角 4 判断是否可逆&#xff08;证明题或者要求求出逆矩阵&#xff09;4.1 直接观察4.2 由定义式推得4.2.1 待…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023