Linux系统编程:线程控制

目录

一. 线程的创建

1.1 pthread_create函数

1.2 线程id的本质

二. 多线程中的异常和程序替换

2.1 多线程程序异常

2.2 多线程中的程序替换

三. 线程等待

四. 线程的终止和分离

4.1 线程函数return

4.2 线程取消 pthread_cancel

4.3 线程退出 pthread_exit

4.4 线程分离 pthread_detach 

五. 总结


一. 线程的创建

1.1 pthread_create函数

函数原型:int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(start_routine)(void*), void *args)

函数功能:创建新线程

函数参数:

        thread -- 输出型参数,用于获取新线程的id

        attr -- 设置线程属性,一般采用nullptr,表示为默认属性

        start_routine -- 新创建线程的入口函数

        args -- 传入start_routine函数的参数

返回值:成功返回0,失败返回对应错误码

关于pthread系列函数的错误检查问题:

  • 一般的Linux系统调用相关函数,都是成功返回0,失败返回-1。
  • 但函数pthread系列函数不是,这些函数都是成功返回0,失败返回错误码,不对全局错误码进行设置。

代码1.1演示了如何通过pthread_create函数创建线程,在主函数中,分别以%lld和%x的方式输出子线程id,图1.1为代码的运行结果。

代码1.1:创建线程

#include <iostream>
#include <cstdio>
#include <cstring>
#include <pthread.h>
#include <unistd.h>// 新建线程的入口函数
void *threadRoutine(void *args)
{while(true){std::cout << (char*)args << std::endl;sleep(1);}return nullptr;
}int main()
{pthread_t tid;   // 接收子线程id的输出型参数// 调用pthread_create函数创建线程// tid接收新线程的id,nullptr表示新线程为默认属性// 新线程的入口函数设为threadRoutine,参数为"thread 1"int n = pthread_create(&tid, nullptr, threadRoutine, (char*)"thread 1");if(n != 0)  // 检验新线程是否创建成功{std::cout << "error:" << strerror(n) << std::endl;exit(1);}while(true){printf("main thread, tid = %lld 0x%x\n", tid, tid);sleep(1);}return 0;
}
图1.1  代码1.1的运行结果

1.2 线程id的本质

如1.2所示,在Linux的线程库pthread中,提供了用于维护每个线程的属性字段,包括描述线程的结构体struct pthread、线程的局部存储、线程栈等,用于对每个线程的维护。

每个线程在线程库中用于维护它的属性字段的起始地址,就是这个线程的id,换言之,线程id就是动态库(地址空间共享区)的一个地址,Linux为64位环境,因此,代码1.1输出的线程id会很大,这个值就对应地址空间共享区的位置。

为了保证每个线程的栈区是独立的,Linux采用的方法是线程栈在用户层提供,这样每个线程都会在动态线程库内部分得一块属于自身的“栈区”,这样就可以保证线程栈的独立性,而主线程的栈区,就使用进程地址空间本身的栈区。

Linux保证线程栈区独立性的方法: 

  • 子线程的栈区在用户层提供。
  • 主线程栈区采用地址空间本身的栈区。

线程id的本质:地址空间共享区的一个地址。

图1.2  线程id的图解

二. 多线程中的异常和程序替换

2.1 多线程程序异常

在多线程程序中,如果某个线程在执行期间出现了异常,那么整个进程都可能会退出,在多线程场景下,任意一个线程出现异常,其影响范围都是整个进程

如代码2.1创建了2个子线程,其中threadRun2函数中人为创造除0错误引发异常,发现整个进程都退出了,不会出现只有一个线程终止的现象。

结论:任意一个线程出现异常,其影响范围都是整个进程,会造成整个进程的退出。

代码2.1:多线程程序异常

#include <iostream>
#include <pthread.h>
#include <unistd.h>void *threadRoutine1(void *args)
{while(true){std::cout << (char*)args << std::endl;sleep(1);}return nullptr;
}void *threadRoutine2(void *args)
{while(true){std::cout << "thread 2, 除0错误!" << std::endl;int a = 10;a /= 0; }return nullptr;
}int main()
{pthread_t tid1, tid2;//先后创建线程1和2pthread_create(&tid1, nullptr, threadRoutine1, (void*)"thread 1");sleep(1);pthread_create(&tid2, nullptr, threadRoutine2, (void*)"thread 2");while(true){std::cout << "main thread ... ... " << std::endl;sleep(1);}return 0;
}
图2.1  代码2.1的运行结果

2.2 多线程中的程序替换

与多线程中线程异常类似,多线程中某个线程如果进行了程序替换,那么并不会出现这个线程去运行新的程序,其他线程正常执行原来的工作的情况,而是整个进程都被替换去执行新的程序。

代码2.2在threadRoutine1函数中通过execl去执行系统指令ls,运行代码我们发现,在子线程中进行程序替换后,主线程也不再继续运行了,进程执行完ls指令,就终止了。

结论:多线程程序替换是整个进程都被替换,而不是只替换一个线程。

代码2.2:多线程程序替换

#include <iostream>
#include <cstdio>
#include <cstring>
#include <pthread.h>
#include <unistd.h>void *threadRoutine1(void *args)
{while(true){std::cout << (char*)args << std::endl;execl("/bin/ls", "ls", nullptr);   // 子线程中进行程序替换exit(0);}return nullptr;
}int main()
{pthread_t tid;// 创建线程int n = pthread_create(&tid, nullptr, threadRoutine1, (void*)"thread 1");if(n != 0)  {// 检验线程创建成功与否std::cout << strerror(n) << std::endl;exit(1);}while(true){std::cout << "main thread" << std::endl;sleep(1);}return 0;
}
图2.2  代码2.2的运行结果

三. 线程等待

线程等待与进程等待类似,主线程需要等待子线程退出,以获取子线程的返回值。如果主线程不等待子线程,而主线程也不退出,那么子线程就会处于“僵尸状态”,其task_struct一直得不到释放,引起内存泄漏。

  • 通过pthread_join函数,可以实现对线程的等待。
  • 线程等待只能是阻塞等待,不能非阻塞等待

pthread_join函数 -- 等待线程

函数原型:int pthread_join(pthread_t thread, void **ret);

函数参数:

        thread -- 等待线程的id

        ret -- 输出型参数,获取线程函数的返回值

返回值:成功返回0,失败返回错误码

在代码3.1中, 线程函数threadRoutine中在堆区new了5个int型数据的空间,并赋值为1~5,线程函数返回指向这块堆区资源的指针,主线程等待子线程退出,主线程可以看到这块资源。注意线程函数返回值的类型为void*,使用返回值的时候要注意强制类型转换。

代码3.1:pthread_join线程等待

#include <iostream>
#include <cstdio>
#include <cstring>
#include <pthread.h>
#include <unistd.h>void *threadRoutine(void *args)
{std::cout << (char*)args << std::endl;int *pa = new int[5];for(int i = 0; i < 5; ++i){pa[i] = i + 1;}return (void*)pa;
}int main()
{pthread_t tid;pthread_create(&tid, nullptr, threadRoutine, (void*)"thread 1");int *pa = nullptr;// 等待线程退出,pa接收线程函数返回值pthread_join(tid, (void**)&pa);// 获取线程函数返回值指向的空间内的资源std::cout << "thread exit" << std::endl;for(int i = 0; i < 5; ++i){printf("pa[%d] = %d\n", i, pa[i]);}delete[] pa;return 0;
}
图3.1  代码3.1的运行结果

四. 线程的终止和分离

可以实现线程终止的方法有:

  • 线程函数return。
  • 由另一个线程将当前线程取消pthread_cancel。
  • 线程退出pthread_exit。

4.1 线程函数return

pthread_create函数的第三个参数start_routine为线程函数指针,新创建的线程就负责执行这个函数,如果这个函数运行完毕return退出,那么,线程就退出了。

但是这种方法对主线程不适用,如果主线程退出,就是进程终止了,全部线程都会退出

结论:如果线程函数return,那么线程就退出了,但主线程return进程就退出了,不适用这种退出方式。

线程函数接收一个void*类型的参数,返回void*类型参数,如果线程函数运行到了return,那么这个线程就退出了,如代码3.1中的threadRoutine,就是采用return来终止线程的。

代码4.1验证了主线程退出的情况,设定线程函数为死循环IO输出,但是主线程在创建完子线程sleep(2)之后return,发现线程函数并没有继续运行,证明了主线程退出不适用于return这种方法来终止。

代码4.1:验证主线程不能通过return退出

// 线程函数死循环
void *threadRoutine1(void *args)
{while(true){std::cout << (char*)args << std::endl;sleep(1);}return nullptr;
}int main()
{pthread_t tid;// 创建线程int n = pthread_create(&tid, nullptr, threadRoutine1, (void*)"thread 1");std::cout << "main thread" << std::endl;sleep(2);   // 主线程sleep 2s后退出return 5;
}
图4.1 代码4.1的运行结果

4.2 线程取消 pthread_cancel

pthread_cancel函数可用于通过指定线程id,来取消线程。

pthread_cancel -- 取消线程

函数原型:int pthread_cancel(pthread_t thread)

函数参数:thread -- 被取消的线程的id

返回值:成功返回0,不成功返回非0的错误码

一般而言,采用主线程取消子线程的方式来取消线程,一个线程取消自身也是可以的,但一般不会这样做,pthread_cancel(pthread_self()) 可用于某个线程取消其自身,其中pthread_self函数的功能是获取线程自身的id。

  • pthread_self函数 -- 获取线程自身的id。

如果一个线程被取消了,那么就无需在主线程中通过pthread_join对这个线程进行等待,但如果使用了pthread_join对被取消的线程进行等待,那么pthread_join的第二个输出型参数会记录到线程函数的返回值为-1。

结论:如果一个线程被pthread_cancel了,那么pthread_join会记录到线程函数返回(void*)-1。 

在代码4.2中,通过pthread_cancel函数,取消子线程,然后pthread_join等待子线程,输出强转为long long类型的返回值ret,记录到ret的值为-1。

代码4.2:取消子线程并等待取消了的子线程

// 线程函数
void *threadRoutine1(void *args)
{while(true){std::cout << (char*)args << std::endl;sleep(1);}return (void*)10;
}int main()
{pthread_t tid;// 创建线程pthread_create(&tid, nullptr, threadRoutine1, (void*)"thread 1");std::cout << "main thread" << std::endl;sleep(2);   pthread_cancel(tid);   // 取消id为tid的子线程void *ret = nullptr;int n = pthread_join(tid, &ret);    // 等待已经取消的线程退出std::cout << "ret : " << (long long)ret << std::endl;return 0;  
}
图4.2 代码4.2的运行结果

4.3 线程退出 pthread_exit

pthread_exit 函数在线程函数中,可用于指定线程函数的返回值并退出线程,与return的功能基本完全相同,注意,exit不可用于退出线程,在任何一个线程中调用exit,都在让整个进程退出。

pthread_exit 函数 -- 让某个线程退出

函数原型:void pthread_exit(void *ret

函数参数:ret -- 线程函数的退出码(返回值)

代码4.3在线程函数中调用pthread_exit终止线程,指定返回值为(void*)111,在主线程中等待子线程,并将线程函数返回值存入ret中,输出(long long)ret的值,证明子线程返回(void*)111。

代码4.3:通过pthread_exit终止线程

#include <iostream>
#include <cstdio>
#include <cstring>
#include <pthread.h>
#include <unistd.h>// 线程函数
void *threadRoutine1(void *args)
{int count = 0;while(true){std::cout << (char*)args << ", count:" << ++count << std::endl;if(count == 3) pthread_exit((void*)111);sleep(1);}return nullptr;
}int main()
{pthread_t tid;// 创建线程pthread_create(&tid, nullptr, threadRoutine1, (void*)"thread 1");std::cout << "main thread" << std::endl;sleep(5);   void *ret = nullptr;pthread_join(tid, &ret);   std::cout << "[main thread] child thread exit, ret:" << (long long)ret << std::endl;return 0;  
}
图4.3 代码4.3的运行结果

4.4 线程分离 pthread_detach 

严格意义上讲,pthread_detach并不算线程退出即使一个线程函数中使用了pthread_detach(pthread_self())对其自身进行分离,线程函数在pthread_detach之后的代码也会正常被执行。

pthread_detach一般用于不需要关心退出状态的线程被pthread_detach分离的子线程,即使主线程不等待子线程退出,子线程也不会出现僵尸问题

一般来说,都是线程分离其自身,当然也可以通过主线程分离子线程,但不推荐这么做。

经pthread_detach分离之后的线程,不应当pthread_join等待,如果等待一个被分离的线程,那么pthread_join函数会返回错误码。

结论:(1).pthread_detach用于将不需要关系关系退出状态的子线程分离   (2).被分离的线程不应被等待,如果被等待,那么pthread_join会返回非0错误码。

代码4.4演示了经pthread_detach分离之后线程函数继续运行,等待被分离的线程失败的情景。

代码4.4:线程分离及等待被分离的线程

#include <iostream>
#include <cstdio>
#include <cstring>
#include <pthread.h>
#include <unistd.h>// 线程函数
void *threadRoutine1(void *args)
{// 子线程将其自身分离pthread_detach(pthread_self());int count = 0;while(true){std::cout << (char*)args << ", count:" << ++count << std::endl;if(count == 3) pthread_exit((void*)111);sleep(1);}return (void*)10;
}int main()
{pthread_t tid;// 创建线程pthread_create(&tid, nullptr, threadRoutine1, (void*)"thread 1");std::cout << "main thread" << std::endl;sleep(5);   void *ret = nullptr;int n = pthread_join(tid, &ret);    // 等待已经取消的线程退出 if(n != 0)  // 检验是否等待成功{std::cout << "wait thread error -> " << strerror(n) << std::endl;}return 0;  
}
图4.4 代码4.4的运行结果

五. 总结

  • pthread_create函数可以创建子线程,关于线程的管理方法及属性字段,被记录在动态库里,线程id本质上就是地址空间共享区的某个地址。
  • 由于Linux在系统层面不严格区分进程和线程,CPU调用只认PCB,因此为了保证每个线程栈空间的独立性,子线程的栈由用户层(动态库)提供,主线程的栈区就是地址空间的栈区。
  • 在多线程中,任何一个线程出现异常,影响范围都是整个进程,如果在某个线程中调用exec系列函数替换程序,那么整个进程都会被替换掉。
  • pthread_join的功能为在主线程中等待子线程,如果子线程没有被detach且不被主线程等待,那么子线程就会出现僵尸问题。
  • 有三种方法可以终止线程:(1). 线程函数return,这种方法不适用于主线程。(2). pthread_exit 函数终止线程函数。(3). pthread_cancel 取消线程,被取消的线程不需要被等待,如果等待会记录到线程函数返回(void*)-1。
  • 如果某个子线程的退出状态不需要关心,那么就可以通过pthread_detach分离子线程,分离后的线程不应被等待,如果被等待,那么pthread_join函数就会返回非零错误码。

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

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

相关文章

Day44|leetcode 518.零钱兑换II、377. 组合总和 Ⅳ

完全背包理论基础 视频链接&#xff1a;带你学透完全背包问题&#xff01; 和 01背包有什么差别&#xff1f;遍历顺序上有什么讲究&#xff1f;_哔哩哔哩_bilibili 完全背包与01背包不同的地方就是&#xff1a;01背包每种物品只能取一次&#xff0c;而完全背包每种物品可以取…

2023年国赛数学建模思路 - 案例:粒子群算法

文章目录 1 什么是粒子群算法&#xff1f;2 举个例子3 还是一个例子算法流程算法实现建模资料 # 0 赛题思路 &#xff08;赛题出来以后第一时间在CSDN分享&#xff09; https://blog.csdn.net/dc_sinor?typeblog 1 什么是粒子群算法&#xff1f; 粒子群算法&#xff08;Pa…

yolov5中添加ShuffleAttention注意力机制

ShuffleAttention注意力机制简介 关于ShuffleAttention注意力机制的原理这里不再详细解释.论文参考如下链接here   yolov5中添加注意力机制 注意力机制分为接收通道数和不接受通道数两种。这次属于接受通道数注意力机制,这种注意力机制由于有通道数要求,所示我们添加的时候…

学习JAVA打卡第四十四天

Scanner类 ⑴Scanner对象 scanner对象可以解析字符序列中的单词。 例如&#xff1a;对于string对象NBA 为了解析出NBA的字符序列中的单词&#xff0c;可以如下构造一个scanner对象。 将正则表达式作为分隔标记&#xff0c;即让scanner对象在解析操作时把与正则表达式匹配的字…

【Linux】多线程概念线程控制

文章目录 多线程概念Linux下进程和线程的关系pid本质上是轻量级进程id&#xff0c;换句话说&#xff0c;就是线程IDLinux内核是如何创建一个线程的线程的共享和独有线程的优缺点 线程控制POSIX线程库线程创建线程终止线程等待线程分离 多线程概念 Linux下进程和线程的关系 在…

使用StreamLold写入 Starrocks报错:Caused by org

问题描述 使用StreamLoad写入Starrocks报错&#xff0c;报这个错误:Caused by: org.apache.http.ProtocolException: Content-Length header already present 代码案例 引入依赖 <!-- Starrocks使用StreamLoad发送Http请求 --><dependency><groupId>or…

Reactive响应式编程系列:一个Demo了解如何将事件驱动变成响应式

Reactive响应式编程系列&#xff1a;解密Lettuce如何实现响应式_lettuce原理_飞向札幌的班机的博客-CSDN博客Reactive响应式编程系列&#xff1a;解密Lettuce如何实现响应式_lettuce原理_飞向札幌的班机的博客-CSDN博客上面两篇文章也许介绍的内容过细&#xff0c;导致无法清晰…

系统架构设计高级技能 · 面向服务架构设计理论与实践

系列文章目录 系统架构设计高级技能 软件架构概念、架构风格、ABSD、架构复用、DSSA&#xff08;一&#xff09;【系统架构设计师】 系统架构设计高级技能 系统质量属性与架构评估&#xff08;二&#xff09;【系统架构设计师】 系统架构设计高级技能 软件可靠性分析与设计…

Jtti :sql server怎么备份数据库?

在 SQL Server 中备份数据库是一项重要的操作&#xff0c;它可以确保你的数据在意外情况下得以恢复。以下是在 SQL Server 中备份数据库的基本步骤&#xff1a; 使用 SQL Server Management Studio (SSMS) 进行备份&#xff1a; 打开 SQL Server Management Studio(SSMS)并连接…

【自动驾驶】TI SK-TDA4VM 开发板上电调试,AI Demo运行

1. 设备清单 TDA4VM Edge AI 入门套件【略】USB 摄像头(任何符合 V4L2 标准的 1MP/2MP 摄像头,例如:罗技 C270/C920/C922)全高清 eDP/HDMI 显示屏最低 16GB 高性能 SD 卡连接到互联网的 100Base-T 以太网电缆【略】UART电缆外部电源或电源附件要求: 标称输出电压:5-20VDC…

Jmeter 接口测试总结

背景介绍 对于 Android 项目来说&#xff0c;使用的是 Java 开发&#xff0c;网络请求接口的数量庞大且复杂&#xff0c;测试人员无法很直观的判断、得出网络请求是否存在问题。另一方面&#xff0c;为了验证请求接口是否能够在大负荷条件下&#xff0c;长时间、稳定、正常的运…

【JMeter】常用线程组设置策略

目录 一、前言 二、单场景基准测试 1.介绍 2.线程组设计 3.测试结果 三、单场景并发测试 1.介绍 2.线程组设计 3.测试结果 四、单场景容量/爬坡测试 1.介绍 2.线程组设计 3.测试结果 五、混合场景容量/并发测试 1.介绍 六、稳定性测试 1.介绍 2.线程组设计 …

C++中的const成员变量和成员函数

在类中&#xff0c;如果你不希望某些数据被修改&#xff0c;可以使用const关键字加以限定。const 可以用来修饰成员变量和成员函数。 const成员变量 const 成员变量的用法和普通 const 变量的用法相似&#xff0c;只需要在声明时加上 const 关键字。初始化 const 成员变量只有…

【跟小嘉学 Rust 编程】十八、模式匹配(Patterns and Matching)

系列文章目录 【跟小嘉学 Rust 编程】一、Rust 编程基础 【跟小嘉学 Rust 编程】二、Rust 包管理工具使用 【跟小嘉学 Rust 编程】三、Rust 的基本程序概念 【跟小嘉学 Rust 编程】四、理解 Rust 的所有权概念 【跟小嘉学 Rust 编程】五、使用结构体关联结构化数据 【跟小嘉学…

深度学习优化入门:Momentum、RMSProp 和 Adam

目录 深度学习优化入门&#xff1a;Momentum、RMSProp 和 Adam 病态曲率 1牛顿法 2 Momentum:动量 3Adam 深度学习优化入门&#xff1a;Momentum、RMSProp 和 Adam 本文&#xff0c;我们讨论一个困扰神经网络训练的问题&#xff0c;病态曲率。 虽然局部极小值和鞍点会阻碍…

Lambda 编程(Kotlin)一

学习记录&#xff0c;以下为个人理解 知识点&#xff1a; Lambda的定义&#xff1a;允许你把代码块当作参数传递给函数Lambda的语法约定&#xff1a;如果lambda 表达式是函数调用的最后一个实参&#xff0c;它可以放到括号的外边当lambda表达式时函数唯一的实参时&#xff0c…

01-jupyter notebook的使用方法

一、Tab补全 在shell中输入表达式&#xff0c;按下Tab&#xff0c;会搜索已输入变量&#xff08;对象、函数等等&#xff09;的命名空间&#xff1a; 除了补全命名、对象和模块属性&#xff0c;Tab还可以补全其它的。当输入看似文件路径时 &#xff08;即使是Python字符串&…

文心一言 VS 讯飞星火 VS chatgpt (79)-- 算法导论7.4 4题

四、请用go语言&#xff0c;证明:RANDOMIZED-QUICKSORT 期望运行时间是 Ω(nlgn)。 文心一言&#xff1a; 首先&#xff0c;为了证明RANDOMIZED-QUICKSORT的期望运行时间是Ω(nlg n)&#xff0c;我们需要证明在最坏的情况下&#xff0c;该算法的运行时间是O(nlg n)。然后&…

网络:RIP协议

1. RIP协议原理介绍 RIP是一种比较简单的内部网关协议&#xff08;IGP协议&#xff09;&#xff0c;RIP基于距离矢量的贝尔曼-福特算法(Bellman - Ford)来计算到达目的网络的最佳路径。最初的RIP协议开发时间较早&#xff0c;所以在带宽、配置和管理方面的要求也较低。 路由器运…

dockerfile镜像及Harbor私有仓库搭建的应用

目录 搭建私有仓库harbordockerfile构建镜像1&#xff0c;先创建一个目录2&#xff0c;编写dockerfile3&#xff0c;构建4&#xff0c; 验证镜像5&#xff0c;标记镜像6&#xff0c;上传镜像 搭建私有仓库harbor 首先安装容器编排工具&#xff1a;docker compose 我使用的是离…