【Linux系统化学习】线程控制

目录

前言

POSIX线程库

线程控制

创建线程

线程终止

pthread_exit()函数

pthread_cancel()函数(会在下面线程等待部分详解)

线程等待 

pthread_join()函数

获取线程退出码

分离线程

线程取消(pthread_cancel()函数)

线程ID及进程地址空间分布


前言

好久不见!各位支持我的IT人,前段时间由于准备蓝桥杯需要学习一段时间算法就停止更新Linux的内容;由于自己也是算法初学者,想着蓝桥杯突击一个多月算法就行了没必要更新算法博客,后面还会专门学习算法到那时候在更新算法的内容。停更前对Linux中的线程做了一个简单的介绍,在接下来的几篇文章我们会深入探讨Linux的线程这方面的问题。线程这方面学习完后,Linux系统编程就结束了,接下来便是网络编程和数据库;在网络编程学习中会编写我的第一个项目,到时候希望大家多多支持!!!


POSIX线程库

线程是操作系统中的一个概念,在Linux这个特定的操作系统中是没有线程这个概念的;是用轻量级进程(LWP)来实现所谓操作系统中的线程的;因此Linux操作系统只会提供轻量级进程的的系统调用,不会提供线程创建的接口。基于此原因我们要在操作系统和用户之间包含一个软件层对用户层向上提供线程的控制接口,对操作系统提供轻量级进程的控制接口。这并不繁琐,可以让操作系统和用户层实现解耦,反而这是Linux操作系统的一大亮点。这个软件层就是POSIX线程库,这是一个原生库,对于每个Linux系统都会包含这个库;因此我们在用户层创建线程时需要引入这个库。


线程控制

创建线程

函数原型

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

功能:创建一个新的线程

参数:

  • thread:返回线程ID(这是一个输出行参数)
  • attr:设置线程的属性,attr为NULL表示使用默认属性
  • start_routine:是个函数地址,线程启动后要执行的函数
  • arg:传给线程启动函数的参数

注意:第三个参数是一个返回值为void*参数为void*的函数指针,第四个void*参数作为第三个函数指针的参数。 

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

简单代码示例

void* ThereadTountine(void* args)
{
    const char * p = (char *) args;//这里也可以使用c++11中的安全类型转换
    while(true)
    {
        sleep(1);
        cout<<p<<endl;
    }
}
int main()
{
    pthread_t tid;
    pthread_create(&tid,nullptr,ThereadTountine,(void*)"new thread-1");
    while(true)
    {
        sleep(1);
        cout<<"main thread"<<endl;
    }
    return 0;
}

  

 这里只是创建了一个新线程,我们可以使用循环配合这个线程创建函数创建更多的线程。

注意:这里的第四个参数不仅仅可以像上面一样传入一个常量字符串,甚至是可以传入一个自定义对象。

线程终止

如果我们只终止某个线程而不终止整个进程,我们可以有三种方法

  • 1. 从线程函数return。这种方法对主线程不适用,从main函数return相当于调用exit。
  • 2. 线程可以调用pthread_ exit终止自己。(新线程调用的函数不可以使用exit函数,因为exit使用来终止整个进程的,而线程只是整个进程中的一个执行流)
  • 3. 一个线程可以调用pthread_ cancel终止同一进程中的另一个线程。

pthread_exit()函数

功能:终止线程

函数原型:

void pthread_exit(void *value_ptr);

参数:

value_ptr:value_ptr不要指向一个局部变量。 

返回值:

无返回值,跟进程一样,线程结束的时候无法返回到它的调用者(自身)

需要注意,pthread_exit或者return返回的指针所指向的内存单元必须是全局的或者是用malloc分配的,不能在线程函数的栈上分配,因为当其它线程得到这个返回指针时线程函数已经退出了。 

pthread_cancel()函数(会在下面线程等待部分详解)

功能:

取消一个执行中的线程

函数原型:

int pthread_cancel(pthread_t thread);

参数:

  • thread:线程ID
  • 返回值:成功返回0;失败返回错误码

线程等待 

我们在进程学习的时候,当一个进程退出后没有被等待会产生僵尸进程,造成资源浪费。那么对于线程来说,当一个线程退出的时候也会产生类似僵尸进程的问题。因此我们要等待线程,不仅是为了方式僵尸问题,而且可以获取线程的返回值。

pthread_join()函数

功能:等待线程结束

函数原型

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

参数:

  • thread:线程ID
  • value_ptr:它指向一个指针,后者指向线程的返回值

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

获取线程退出码

线程创建函数的返回值为void * ,而线程等待的第二个参数为void**;这个参数是一个输出型参数,可以获取到函数退出的推出信息。

void* ThereadTountine(void* args)
{
    const char * p = (char *) args;//这里也可以使用c++11中的安全类型转换
    int cnt=5;
    while(cnt--)
    {
        sleep(1);
        cout<<p<<endl;
    
    }
    return (void*)"new thread-1 done";
}
int main()
{
    pthread_t tid;
    pthread_create(&tid,nullptr,ThereadTountine,(void*)"I am new thread-1");
    void * ret=nullptr;
    int n = pthread_join(tid,&ret);
    cout<<(const char *) ret<<endl;
    return 0;
}

对于线程出异常我们根本不许用考虑,因为当某个线程出异常的时候,整个进程都会挂掉;等待线程已经没有什么意义了。

分离线程

如果我们线程一直不退出时,主线程会一直阻塞等待这个线程。我们可以将这个线程设置为游离状态。

  • 默认情况下,新创建的线程是joinable的,线程退出后,需要对其进行pthread_join操作,否则无法释放资源,从而造成系统泄漏。
  • 如果不关心线程的返回值,join是一种负担,这个时候,我们可以告诉系统,当线程退出时,自动释放线程资源。

因此我们可以根据需求动态决策,线程的状态。 

函数原型

如果想要分离一个线程,可以在主线程中调用函数将新线程分离,也可以在新线程中将自已与主线程分离。

int pthread_detach(pthread_t thread);

//分离自己
pthread_detach(pthread_self());

注意:joinable和分离是冲突的,一个线程不可以既是joinable又是分离的。

#include <iostream>
#include <unistd.h>
#include <pthread.h>
using namespace std;
void *ThereadTountine(void *args)
{
    // 新线程和主线程分离
    //pthread_detach(pthread_self());
    const char *p = (char *)args; // 这里也可以使用c++11中的安全类型转换
    int cnt = 5;
    while (cnt--)
    {
        sleep(1);
        cout << p << endl;
    }
    return (void *)"new thread-1 done";
}
int main()
{
    pthread_t tid;
    pthread_create(&tid, nullptr, ThereadTountine, (void *)"I am new thread-1,running  ~ ~ ");
    //主线程和新线程分离
    pthread_detach(tid);
    sleep(1);//保证新线程已经执行了一秒
    
    int n = pthread_join(tid, nullptr);
    cout << n << endl;
    return 0;
}

 

线程取消(pthread_cancel()函数)

void *ThereadTountine(void *args)
{
    const char *p = (char *)args; // 这里也可以使用c++11中的安全类型转换
    int cnt = 5;
    while (cnt--)
    {
        sleep(1);
        cout << p << endl;
    }
}
int main()
{
    pthread_t tid;
    pthread_create(&tid, nullptr, ThereadTountine, (void *)"I am new thread-1,running  ~ ~ ");
    sleep(5);//保证新线程已经执行了一秒
    //取消新线程
    int n = pthread_cancel(tid);
    cout<<"cancle n:"<<n<<endl;
    void* ret=nullptr;
    n = pthread_join(tid, &ret);
    cout<<"join n:" << n << "    thread return:"<<(int64_t) ret<<endl;
    return 0;
}

 

当线程被取消后其退出码为-1;当线程被分离时可以被取消,但是不可以被等待。因此对于分离的线程在运行时我们可以对其取消操作


线程ID及进程地址空间分布

在新线程中可以使用pthread_self(),来获取自身ID

 这个ID看起来非常的大,我们可以尝试转化为16进制进行打印; 

转化为十六进制后,这个线程ID和虚拟地址非常的类似。

void* ThereadTountine(void* args)
{
    const char * p = (char *) args;//这里也可以使用c++11中的安全类型转换
    while(true)
    {
        sleep(1);
        cout<<p<<endl;
        printf("new thread ID : %x\n",pthread_self());//获取自身线程ID
    }
}
int main()
{
    pthread_t tid;
    pthread_create(&tid,nullptr,ThereadTountine,(void*)"I am new thread-1");
    while(true)
    {
        sleep(1);
        cout<<"I am main thread"<<endl;
        printf("main ID : %x\n",pthread_self());
    }
    return 0;
}

当我们在用户层创建了n个线程时,通过线程库操作系统会创建n个轻量级进程,对于这些轻量级进程来说可以复用进程那一套管理方案来解决。我们所谓的“线程”是不过是用户级线程,对于这些线程来说我们也要进行管理——“先描述,在组织”,因此我们要有一个TCB(Thread Control Block,线程控制块),这个TCB并不存在于操作系统中,存在于库中。TCB中含有LWP ID 等关于这个线程的各种属性。但是对于每个单独的线程来说,还要包含存储独立上下文的存储结构和独立的栈空间。库是共享的在共享区中只包含一次就可以,然而线程可以是很多的,我们可以将每个线程的TCB和进程上下文的存储空间和独立的栈描述起来,然后使用一个数组将其组织起来;将每个线程的起始地址作为TID向上返回给用户。

两个小问题

线程可以fork()创建子进程吗?

可以,在前面进程的学习中我们是只含有一个执行流的进程,在这个进程中创建子进程;现在我们这个进程中的进程中含有多个执行流,只不过在这众多执行流中fork子进程。

线程可以进行程序替换吗?

可以,但不推荐!因为线程公用主线程的公共资源,进行程序替换可能会导致,整个进程被替换;应该在众多线程中的一个线程中fork一个进程后进行程序替换。 


今天对Linux下线程控制的各种操作的分享到这就结束了,希望大家读完后有很大的收获,也可以在评论区点评文章中的内容和分享自己的看法;个人主页还有很多精彩的内容。您三连的支持就是我前进的动力,感谢大家的支持!!!

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Scikit-Learn支持向量机分类

Scikit-Learn 支持向量机分类 1、支持向量机&#xff08;SVM&#xff09;1.1、SVM概述1.2、SVM原理1.3、SVM的损失函数1.4、支持向量机分类的优缺点 2、Scikit-Learn支持向量机分类2.1、Scikit-Learn支持向量机分类API2.2、支持向量机分类初体验&#xff08;手写数字识别&#…

【工具-PyCharm】

工具-PyCharm ■ PyCharm-简介■ PyCharm-安装■ PyCharm-使用■ 修改主题■ 设置字体■ 代码模板■ 解释器配置■ 文件默认编码■ 快捷键■ 折叠■ 移动■ 注释■ 编辑■ 删除■ 查看■ 缩进■ 替换 ■ PyCharm-简介 官方下载地址 Professional&#xff1a;专业版&#xff0…

头脑风暴法的四个原则,设计师必看!

俗话说 “三个臭皮匠超越诸葛亮”&#xff0c;这在工作场景中也是如此。最常见的工作场景是会议。会议的目的很多&#xff0c;如工作报告、产品宣传等。头脑风暴是一种工作会议。其目的是集思广益&#xff0c;充分发挥团队的智慧。有效的头脑风暴不仅考验组织者的会议控制能力&…

【前端Vue】Vue3+Pinia小兔鲜电商项目第6篇:整体认识和路由配置,本资源由 收集整理【附代码文档】

Vue3ElementPlusPinia开发小兔鲜电商项目完整教程&#xff08;附代码资料&#xff09;主要内容讲述&#xff1a;认识Vue3&#xff0c;使用create-vue搭建Vue3项目1. Vue3组合式API体验,2. Vue3更多的优势,1. 认识create-vue,2. 使用create-vue创建项目,1. setup选项的写法和执行…

【机器学习-17】数据变换---小波变换特征提取及应用案列介绍

引言 在机器学习领域&#xff0c;数据变换是一种常见且重要的预处理步骤。通过对原始数据进行变换&#xff0c;我们可以提取出更有意义的特征&#xff0c;提高模型的性能。在众多数据变换方法中&#xff0c;小波变换是一种非常有效的方法&#xff0c;尤其适用于处理非平稳信号和…

实战解析:SpringBoot接口防抖机制与防重复提交技巧

目录 前言 啥是防抖 思路解析 哪一类接口需要防抖? 如何确定接口是重复的&#xff1f; 分布式部署下如何做接口防抖&#xff1f; 使用共享缓存 使用分布式锁 Spring Boot与Redis深度整合入口&#xff1a;实战指南 具体实现 请求锁 唯一key生成 重复提交判断 Red…

scipy.sparse.csr_matrix 中的 indptr indices data

# ------------------------------------------------------------------------------- # Description: 分析理解 scipy.sparse.csr_matrix 中的 indptr & indices & data # Reference: https://blog.csdn.net/bymaymay/article/details/81389722 # Author: Sophia…

Win 进入桌面黑屏,只有鼠标

大家好&#xff0c;我叫秋意零。 今天&#xff0c;遇到一个同事电脑进入桌面黑屏&#xff0c;只有鼠标。经过询问沟通&#xff0c;说是 Windows 突然进行了自动更新&#xff0c;更新之后桌面就黑了屏。经过查询是一个桌面进程没启动才会导致桌面黑屏。首先分两种情况&#xff0…

STL Array、ForwardList源码剖析

STL Array、ForwardList源码剖析 参考文章: https://blog.csdn.net/weixin_45389639/article/details/121618243 array 源代码 template<typename _Tp,std::size_t _Nm> struct array {typedef _Tp value_type;typedef _Tp* pointer;typedef value_type* iterator;// Su…

【看不懂命令行、.yaml?】Hydra 库极速入门

Hydra 是一个开源的 Python 框架&#xff0c;可以简化研究和其他复杂应用程序的开发。其核心功能是通过组合动态创建层次化的配置&#xff0c;并可以通过配置文件和命令行进行覆盖。Hydra 的名字来源于它能够运行多个类似的作业 - 就像一个多头的水怪一样。 主要特性: 从多个…

首发!Llama3纯本地部署攻略!中文方法!

引言 llama3在4月19日刚刚发布&#xff0c;官方的对比结果中在开源模型中堪称世界第一&#xff0c;整好周六日有时间&#xff0c;在魔搭社区上测试一下 一、启动环境 登录魔搭社区&#xff0c;到自己的机器资源&#xff0c;可以看到&#xff0c;可选的机器配置&#xff0c; …

YOLOv9改进策略 | Conv篇 | 利用 Haar 小波的下采样HWD替换传统下采样(改变YOLO传统的Conv下采样)

一、本文介绍 本文给大家带来的改进机制是Haar 小波的下采样HWD替换传统下采样&#xff08;改变YOLO传统的Conv下采样&#xff09;在小波变换中&#xff0c;Haar小波作为一种基本的小波函数&#xff0c;用于将图像数据分解为多个层次的近似和细节信息&#xff0c;这是一种多分…

什么是自动化测试?如何做自动化测试?

前面介绍了功能测试和接口测试&#xff0c;在介绍接口测试时提到了实现API自动化。那具体什么是自动化&#xff0c;为什么要做自动化&#xff0c;这里我们集中总结。 一. 什么是自动化&#xff1f; 顾名思义&#xff0c;自动化测试是相对人工测试而言的&#xff0c;它是指把人…

以太网帧格式解析

以太网的正式标准是IEEE802.3&#xff0c;它规定了以太网传输的帧结构。 以太网帧格式如下图所示&#xff1a; 以太网传输数据时&#xff0c;是按照上图的格式&#xff0c;自左到右依次传输的。需要注意的是前导码和SFD不属于以太网协议的内容&#xff0c;应该是属于物理层数据…

AI检索增强生成引擎-RAGFlow-深度理解知识文档,提取真知灼见

&#x1f4a1; RAGFlow 是什么&#xff1f; RAGFlow是一款基于深度文档理解构建的开源RAG&#xff08;Retrieval-Augmented Generation&#xff09;引擎。RAGFlow个人可以为各种规模的企业及提供一套专业的RAG工作流程&#xff0c;结合针对用户群体的大语言模型&#xff08;LL…

我独自升级崛起怎么下载 一文分享我独自升级崛起游戏下载教程

我独自升级崛起怎么下载 一文分享我独自升级崛起游戏下载教程 我独自升级&#xff1a;崛起是一款由韩国漫画改编而成的热门多人网络在线联机游戏&#xff0c;这款游戏是一款的角色扮演类型游戏&#xff0c;游戏有着独一无二的剧情模式。小伙伴们在游戏中可以体验到独特的成长系…

Meta提出全新文档级嵌入框架,利用LLM来增强信息检索能力

近年来&#xff0c;基于嵌入式检索&#xff08;embedding-based search&#xff09;或密集检索&#xff08;dense retrieval&#xff09;相比传统的稀疏检索&#xff08;sparse retrieval&#xff09;或基于词袋&#xff08;bag of words&#xff09;的方法&#xff0c;已经展示…

王道C语言督学营OJ课后习题(课时20)

#include<stdio.h> int main() {printf("%3d%3d",0,13);return 0; }

图深度学习——2.图的理论知识

1.图 1.1 图的定义 图是由节点&#xff08;顶点&#xff09;和边构成的数学结构。图用于表示对象之间的关系&#xff0c;其中节点表示对象&#xff0c;边表示对象之间的关系。 一个图&#xff0c;记为 G <V, E> &#xff0c;它包括以下两个要素&#xff1a; 1.节点&am…

函数的内容

一&#xff0c;概念 封装一份可以被重复执行的代码块&#xff0c;让大量代码重复使用 二&#xff0c;函数使用 大体分两步&#xff1a;声明函数&#xff0c;调用函数 声明函数有关键字&#xff1a;function 函数名&#xff08;&#xff09;{ 函数体 } 为基本格式&#xf…