Linux -- 线程控制相关的函数

目录

pthread_create -- 创建线程

参数

返回值

 代码 -- 不传 args：

编译时带  -lpthread

运行结果 

为什么输出混杂？

如何证明两个线程属于同一个进程？

 

如何证明是两个执行流？ 

什么是LWP？

代码 -- 传 args：

运行结果：

pthread_self -- 线程标识符

代码：

LWP标识符 和 线程标识符的区别

pthread_join -- 等待线程退出

 前言：主线程比新线程先退出

参数

返回值

 代码 -- 不获取退出状态

代码 -- 获取退出状态

 ​编辑

pthread_exit -- 终止线程

前言：新、主线程共享地址空间

参数

作用

代码 

pthread_cancel -- 取消线程

参数

返回值

代码

pthread_create -- 创建线程

#include <pthread.h>int pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routine) (void *), void *arg);

参数

thread: 指向一个 pthread_t 类型的指针，用于存储新创建线程的标识符，是输出型参数。

attr: 指向一个 pthread_attr_t 类型的指针，这个参数可以用来设置线程的属性，如栈大小、调度策略等。如果不需要特别设置线程属性，可以传递 NULL。

start_routine: 这是一个函数指针，指向新线程开始执行的函数。该函数必须接受一个 void* 类型的参数，并返回一个 void* 类型的结果。

arg: 这个参数将被传递给 start_routine 函数作为其唯一的参数。如果你不想传递任何参数，可以使用 NULL。

返回值

如果函数调用成功，返回值为 0。

如果发生错误，返回值为一个非零的错误代码。

 代码 -- 不传 args：

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;void* newthreadRun(void* args)
{while(1){cout<<"I am new thread"<<endl;sleep(1);}
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,nullptr);while(1){cout<<"I am main thread"<<endl;sleep(1);}return 0;
}

编译时带  -lpthread

这里需要了解一点小故事，用户知道线程和进程，但不知道轻量级进程，而Linux中没有真线程，Linux中没有线程相关的系统调用，只有轻量级进程的系统调用，为了让用户和系统达成一致，系统将轻量级进程的系统调用进行封装，转换成线程相关的接口语义提供给用户，也就有了pthread库（即原生线程库），这个库既不属于C语言，也不属于C++，所以在Linux系统中编写多线程时，都必须在编译时带上 -lpthread。

在 Linux 中编译使用 Pthreads 的程序时，通常需要链接 Pthreads 库。这可以通过在编译命令中添加 -lpthread 选项来实现。-lpthread 选项不仅告诉编译器链接 Pthreads 库，还会启用一些必要的编译器选项，以确保线程支持的正确性和性能。 如果不使用 -lpthread 选项，编译器可能会报错或生成不可用的二进制文件。

thread:thread.ccg++ -o $@ $^ -std=c++11 -lpthread.PHONY:clean
clean:rm -f thread

运行结果 

可以看出，两个执行流同时输出信息。同时也可以看出，一开始新、主线程打印的消息混在一起了，后面才分开来，这是正常现象。

为什么输出混杂？

在多线程程序中，多个线程同时向终端输出信息时，可能会出现输出混杂的情况。这是因为每个线程的输出操作并不是原子的（原子操作，即要么完全执行，要么根本不执行），即一个线程可能在另一个线程已经开始输出但还没有完成输出时就开始了自己的输出，这种现象通常称为“输出交错”或“输出混杂”。 

如何证明两个线程属于同一个进程？

当不传 args 版本的代码运行时，输入命令 ps ajx | head -1 && ps ajx | grep thread 筛选出 thread 进程，可以看出只有一个进程被调度：

如何证明是两个执行流？ 

当代码运行起来时，输入命令 ps -aL | head -1 && ps -aL | grep thread 可以查看线程的信息，可以看出两个线程的 pid 一样，即属于同一个进程，而 LWP 不同，则说明一个进程中有两个执行流：

ps -aL：-a显示所有进程，包括其他用户的进程，-L 显示每个线程的详细信息。 

什么是LWP？

LWP（Light Weight Process）是轻量级进程的缩写，在 Linux 中，LWP 通常被称为“线程”。

代码 -- 传 args：

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){std::cout<<threadname<<" is running: "<<cnt<<", pid: "<<getpid()<<" mythread id: "<<toHex(pthread_self())<<std::endl;sleep(1);}return nullptr;
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");pthread_join(tid,nullptr);return 0;
}

运行结果：

pthread_self -- 线程标识符

#include <pthread.h>
pthread_t pthread_self(void);

该函数用于获取当前线程的标识符（pthread_t 类型）。

代码：

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{while(1){cout<<"I am new thread, new thread tid: "<<toHex(pthread_self())<<", pid: "<<getpid()<<endl;sleep(1);}
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,nullptr);while(1){cout<<"I am main thread, main thread tid: "<<toHex(pthread_self())<<", pid: "<<getpid()<<endl;sleep(1);}return 0;
}

可以看出，新、主线程的线程标识符 tid 的值不一样，同时也可以看出，LWP 和线程标识符 tid的值是不一样的：

LWP标识符 和 线程标识符的区别

 LWP（Light Weight Process）标识符和线程标识符（Thread Identifier，TID）在数值上通常是不一样的。虽然它们在概念上密切相关，但它们表示的是不同的标识符，用途和获取方式也有所不同。

pthread_join -- 等待线程退出

 前言：主线程比新线程先退出

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;//新线程运行5秒while(cnt--){std::cout<<threadname<<" is running: "<<cnt<<", pid: "<<getpid()<<" mythread id: "<<toHex(pthread_self())<<std::endl;sleep(1);}return nullptr;
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");sleep(1);//因为主线程没有阻塞等待新线程，1秒后，主线程先退出了std::cout<<"main thread quit"<<std::endl;return 0;
}

因为主线程没有阻塞等待新线程退出，1秒后，主线程退出了，主线程退出了就等同于整个进程退出了，分配给进程的资源都被释放了，所以所有的线程都要退出，所以新线程还没执行完就被退出了，通常需要主线程最后结束。线程的退出也需要wait，不然会发生内存泄漏问题。

#include <pthread.h>int pthread_join(pthread_t thread, void **value_ptr);

该函数用于等待指定的线程终止，并获取该线程的退出状态。 

参数

thread：要等待的线程的标识符（pthread_t 类型，可以调用 pthread_self 函数获取）。

value_ptr：输出型参数，用于存储线程的退出状态。如果不需要获取退出状态，可以传递 NULL。

返回值

等待线程退出成功，返回 0。 

等待线程退出失败，返回非零错误码。

 代码 -- 不获取退出状态

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){std::cout<<threadname<<" is running: "<<cnt<<", pid: "<<getpid()<<" mythread id: "<<toHex(pthread_self())<<std::endl;sleep(1);}return nullptr;
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");int n=pthread_join(tid,nullptr);//获取返回值std::cout<<"main thread quit, n="<<n<<std::endl;return 0;
}

新线程正常退出，故返回值为 0. 

代码 -- 获取退出状态

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){std::cout<<threadname<<" is running: "<<cnt<<", pid: "<<getpid()<<" mythread id: "<<toHex(pthread_self())<<std::endl;sleep(1);}return (void*)123;
}
int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");void* ret=nullptr;int n=pthread_join(tid,&ret);//ret强转为long long是为了避免精度损失std::cout<<"main thread quit, n="<<n<<",main thread get a ret:"<<(long long)ret<<std::endl;return 0;
}

线程的退出状态其实就是线程执行的任务函数的返回值。 

 

pthread_exit -- 终止线程

前言：新、主线程共享地址空间

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>
int g_val=100;
string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){printf("new thread, g_val:%d,&g_val:%p\n",g_val,&g_val);g_val++;//在新线程中改变g_val的值sleep(1);}return nullptr;
}int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");int cnt=10;while(cnt--){//主线程不改变g_val的值printf("main thread, g_val:%d,&g_val:%p\n",g_val,&g_val);sleep(1);}void* ret=nullptr;int n=pthread_join(tid,&ret);std::cout<<"main thread quit, n="<<n<<",main thread get a ret:"<<(long long)ret<<std::endl;return 0;
}

可以看出，新线程修改了 g_val 的值，主线程中 g_val 的值也被修改了，说明新、主线程共享了地址空间，看到的是同一个变量，而不是和进程一样，发生写时拷贝。

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>
int g_val=100;
string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){printf("new thread, g_val:%d,&g_val:%p\n",g_val,&g_val);g_val++;//故意对空指针进行解引用int *p=nullptr;*p=10;sleep(1);}return nullptr;
}int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");int cnt=10;while(cnt--){printf("main thread, g_val:%d,&g_val:%p\n",g_val,&g_val);sleep(1);}void* ret=nullptr;int n=pthread_join(tid,&ret);std::cout<<"main thread quit, n="<<n<<",main thread get a ret:"<<(long long)ret<<std::endl;return 0;
}

 

在新线程中故意对野指针进行解引用，结果新、主线程一起退出了，这是因为在同一个进程中运行的所有线程共享相同的地址空间，这意味着如果一个线程造成了段错误（segmentation fault），那么这个错误会影响到整个进程，而不仅仅是单个线程。操作系统通常会终止整个进程以防止进一步的损坏。

#include <pthread.h>void pthread_exit(void *value_ptr);

参数

value_ptr：一个指向指针的指针，用于存储线程的退出状态。

这个值可以被 pthread_join 函数捕获并使用。如果不需要传递退出状态，可以传递 NULL。

作用

终止当前线程：调用 pthread_exit 的线程会立即终止其执行。

传递退出状态：可以通过 value_ptr 参数传递一个退出状态，这个状态可以被 pthread_join 函数捕获。

代码 

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>
int g_val=100;
string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){printf("new thread, g_val:%d,&g_val:%p\n",g_val,&g_val);g_val++;sleep(1);}pthread_exit((void*)123);
}int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");void* ret=nullptr;int n=pthread_join(tid,&ret);std::cout<<"main thread quit, n="<<n<<",main thread get a ret:"<<(long long)ret<<std::endl;return 0;
}

pthread_cancel -- 取消线程

#include <pthread.h>int pthread_cancel(pthread_t thread);

参数

thread：要取消的线程的标识符（pthread_t 类型）。

返回值

取消线程成功，返回 0。

取消线程失败，返回非零错误码。

代码

#include<iostream>
#include<pthread.h>
#include<unistd.h>
using namespace std;
#include<string>
int g_val=100;
string toHex(pthread_t tid)
{char buffer[64];snprintf(buffer,sizeof(buffer),"0x%lx",tid);return buffer;
}
void* newthreadRun(void* args)
{std:string threadname=(char*)args;int cnt=5;while(cnt--){printf("new thread, g_val:%d,&g_val:%p\n",g_val,&g_val);g_val++;sleep(1);}pthread_exit((void*)123);
}int main()
{pthread_t tid;pthread_create(&tid,nullptr,newthreadRun,(void*)"thread-1");pthread_cancel(tid);void* ret=nullptr;int n=pthread_join(tid,&ret);std::cout<<"main thread quit, n="<<n<<",main thread get a ret:"<<(long long)ret<<std::endl;return 0;
}

线程的退出状态为 -1，表示线程被取消。

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

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

相关文章

es 开启slowlog

es 开启slowlog

在 Elasticsearch 中&#xff0c;slowlog&#xff08;慢日志&#xff09;是用来记录查询和索引操作的性能数据&#xff0c;帮助你诊断性能瓶颈。你可以为查询 (search slowlog) 和索引 (index slowlog) 配置慢日志。 数据准备 POST /products/_doc/1 {"product_name&quo…
阅读更多...
【韩顺平 Java满汉楼项目 控制台版】MySQL+JDBC+druid

【韩顺平 Java满汉楼项目 控制台版】MySQL+JDBC+druid

文章目录 功能界面用户登录界面显示餐桌状态预定显示所有菜品点餐查看账单结账退出满汉楼 程序框架图项目依赖项目结构方法调用图功能实现登录显示餐桌状态订座显示所有菜品点餐查看账单结账退出满汉楼 扩展思考多表查询如果将来字段越来越多怎么办&#xff1f; 员工信息字段可…
阅读更多...
知道一个服务器IP地址如果attack服务器地址

知道一个服务器IP地址如果attack服务器地址

CSDN提醒&#xff1a;亲爱的用户&#xff1a;你好&#xff01; 你的账号于2024-12-17 19:04:04在美国美国登录&#xff0c;登录IP为&#xff1a;47.238.159.124。若非本人登录&#xff0c;请及时修改密码。 莫名其妙显示美国登录了我的CSDN博客 卧槽 服务器的IP地址是一个用于…
阅读更多...
3大Excel免费功能

3大Excel免费功能

推荐几个免费excel图表绘制工具 Power Map Power Map是Excel的内置功能 Power Map可在Windows用户的Excel 2013或者Excel 2016或者Office 365中使用，如下图， 看案例 动态地图1 动态地图2
阅读更多...
前端面试问题集合

前端面试问题集合

0 HTML5相关 websocket WebSocket 使用ws或wss协议&#xff0c;Websocket是一个持久化的协议&#xff0c;相对于HTTP这种非持久的协议来说。WebSocket API最伟大之处在于服务器和客户端可以在给定的时间范围内的任意时刻&#xff0c;相互推送信息。WebSocket并不限于以Ajax(或X…
阅读更多...
强化学习路径规划：基于SARSA算法的移动机器人路径规划，可以更改地图大小及起始点，可以自定义障碍物，MATLAB代码

强化学习路径规划：基于SARSA算法的移动机器人路径规划，可以更改地图大小及起始点，可以自定义障碍物，MATLAB代码

一、SARSA算法概述 SARSA&#xff08;State-Action-Reward-State-Action&#xff09;是一种在线强化学习算法&#xff0c;用于解决决策问题&#xff0c;特别是在部分可观测的马尔可夫决策过程&#xff08;POMDPs&#xff09;中。SARSA算法的核心思想是通过与环境的交互来学习一…
阅读更多...
通过基于几何的网格自适应增强 CFD 网格划分

通过基于几何的网格自适应增强 CFD 网格划分

CFD 仿真中的网格质量问题 在 CFD 仿真中&#xff0c;网格质量直接影响分析精度和效率。结构良好的网格可以准确地捕捉物理现象&#xff0c;确保可靠的结果&#xff0c;而质量差会导致错误和代价高昂的设计缺陷。高质量的网格在复杂的几何体中至关重要&#xff0c;因为流体行为…
阅读更多...
Dockerfile文件编写

Dockerfile文件编写

目录 Dockerfile文件编写 1.什么是Dockerfile 2. Dockerfile作用 3.dockerfile 的基本结构&#xff1a; 4.dockerfile指令&#xff1a; FROM 指定基础镜像&#xff0c;dockerfile构建镜像的第一个指令 LABEL 指定镜像维护人信息 ADD/COPY 复制本地文件/目录到镜像中 …
阅读更多...
ARM学习（38）多进程多线程之间的通信方式

ARM学习（38）多进程多线程之间的通信方式

ARM学习（38）ARM学习（38）多进程多线程之间的通信方式 一、问题背景 笔者在调试模拟器的时候，碰到进程间通信的问题，一个进程在等另外一个进程ready的时候，迟迟等不到，然后通过调试发现，另外一个进程变量已经变化了，但是当前进程变量没变化，需要了解进程间通信的方式…
阅读更多...
pytest -s执行的路径

pytest -s执行的路径

pytest -s执行的路径&#xff1a; 直接写pytest -s&#xff0c;表示从当前路径下开始执行全部.py的文件。 执行具体指定文件&#xff1a;pytest -s .\testXdist\test_dandu.py 下面这样执行pytest -s 会报找不到文件或没权限访问&#xff0c; 必须要加上具体文件路径pytest -s…
阅读更多...
XXE练习

XXE练习

pikachu-XXE靶场 1.POC:攻击测试 <?xml version"1.0"?> <!DOCTYPE foo [ <!ENTITY xxe "a">]> <foo>&xxe;</foo> 2.EXP:查看文件 <?xml version"1.0"?> <!DOCTYPE foo [ <!ENTITY xxe SY…
阅读更多...
Numpy基本介绍

Numpy基本介绍

目录 1、Numpy的优势 1.1、ndarray介绍 1.2、ndarray与Python原生list运算效率对比 1.3、ndarray的优势 1.3.1、内存块风格 1.3.2、ndarray支持并行化运算（向量化运算） 1.3.3、效率远高于纯Python代码 2、N维数组-ndarray 2.1、ndarray的属性 2.2、ndarray的形状 2…
阅读更多...
用前端html如何实现2024烟花效果

用前端html如何实现2024烟花效果

用HTML、CSS和JavaScript编写的网页&#xff0c;主要用于展示“2024新年快乐&#xff01;”的文字形式烟花效果。下面是对代码主要部分的分析&#xff1a; HTML结构 包含三个<canvas>元素&#xff0c;用于绘制动画。引入百度统计的脚本。 CSS样式 设置body的背景为黑…
阅读更多...
makefile文件

makefile文件

简介&#xff1a; 自动化编译&#xff1a;只需要一个make命令&#xff0c;整个工程自动编译 提高编译效率&#xff1a;再次编译时&#xff0c;只编译修改的文件&#xff08;查看时间戳&#xff0c;根据修改文件的时间判断文件是否被修改&#xff09; 基本语法&#xff1a; …
阅读更多...
ArKTS基础组件

ArKTS基础组件

一.AlphabetIndexer 可以与容器组件联动用于按逻辑结构快速定位容器显示区域的组件。 子组件 color:设置文字颜色。 参数名类型必填说明valueResourceColor是 文字颜色。 默认值&#xff1a;0x99182431。 selectedColor:设置选中项文字颜色。 参数名类型必填说明valueRes…
阅读更多...
微积分复习笔记 Calculus Volume 2 - 4.3 Separable Equations

微积分复习笔记 Calculus Volume 2 - 4.3 Separable Equations

4.3 Separable Equations - Calculus Volume 2 | OpenStax
阅读更多...
【爬虫一】python爬虫基础合集一

【爬虫一】python爬虫基础合集一

【爬虫一】python爬虫基础合集一 1. 网络请求了解1.1. 请求的类型1.2. 网络请求协议1.3. 网络请求过程简单图解1.4. 网络请求Headers(其中的关键字释义)&#xff1a;请求头、响应头 2. 网络爬虫的基本工作节点2.1. 了解简单网络请求获取响应数据的过程所涉及要点 1. 网络请求了…
阅读更多...
WPF DataTemplate 数据模板

WPF DataTemplate 数据模板

DataTemplate 顾名思义&#xff0c;数据模板&#xff0c;在 wpf 中使用非常频繁。 它一般用在带有 DataTemplate 依赖属性的控件中&#xff0c;如 ContentControl、集合控件 ListBox、ItemsControl 、TabControls 等。 1. 非集合控件中使用 <UserControl.Resources>&l…
阅读更多...
LM芯片学习

LM芯片学习

1、LM7805稳压器 https://zhuanlan.zhihu.com/p/626577102?utm_campaignshareopn&utm_mediumsocial&utm_psn1852815231102873600&utm_sourcewechat_sessionhttps://zhuanlan.zhihu.com/p/626577102?utm_campaignshareopn&utm_mediumsocial&utm_psn18528…
阅读更多...
OCR多模态大模型：视觉模型与LLM的结合之路

OCR多模态大模型：视觉模型与LLM的结合之路

原文&#xff1a;https://zhuanlan.zhihu.com/p/7783443583 在使用多模态大模型(Visual Language Model, VLM)做视觉信息抽取时&#xff0c;常常出现错字的问题。为了解决这一问题&#xff0c;本文提出了一种名为Guidance OCR的方法。该方法在不额外训练模型的情况下&#xff…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023