Linux系统编程:线程控制

news2024/11/17 15:32:36

目录

一. 线程的创建

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和2
    pthread_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.coloradmin.cn/o/933213.html

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

相关文章

在编辑器中使用正则

正则是一种文本处理工具&#xff0c;常见的功能有文本验证、文本提取、文本替换、文本切割等。有一些地方说的正则匹配&#xff0c;其实是包括了校验和提取两个功能。 校验常用于验证整个文本的组成是不是符合规则&#xff0c;比如密码规则校验。提取则是从大段的文本中抽取出…

探索AIGC人工智能(Midjourney篇)(二)

文章目录 利用Midjourney进行LOGO设计 用ChatGPT和Midjourney的AI绘画&#xff0c;制作儿童绘本故事 探索Midjourney换脸艺术 添加InsightFaceSwap机器人 Midjourney打造专属动漫头像 ChatGPT Midjourney画一幅水墨画 Midjourney包装设计之美 Midjourney24节气海报插画…

【车载开发系列】常用开发工具一览

【车载开发系列】常用开发工具一览 常用开发工具一览 【车载开发系列】常用开发工具一览一. HexView(十六进制查看编辑器)二. VSB Vehicle Systems Builder三. MULTI IDE四. CANoe五. CANalyzer网络分析测试工具六. CasePlayer2七. Renesas Flash Programmer八. Ecu Spectrum九…

红黑树基础理解

一、数据结构 1.数组 a.内存地址连续&#xff0c;使用之前必须要指定数组长度 b.可以通过下标访问的方式访问成员&#xff0c;查询效率高 c.增删操作会带来性能消耗效率相对差点(要防止数据下标越界的问题&#xff0c;需要动态扩容&#xff09; 2.链表 &#xff1a;单向链表…

ICP算法

一、ICP 迭代最接近点&#xff08;ICP&#xff09;&#xff1a;给定两个点集。估计R&#xff0c;t以对齐两个点。 找到点的对应关系估算R&#xff0c;t基于R&#xff0c;t&#xff0c;计算误差和分数重复执行上述步骤直到收敛 传统ICP&#xff1a;根据距离进行计算&#xff0c…

使用Python统计小说语言描写的字数

说明&#xff1a;最早出现这个需求&#xff0c;来自博主阅读《罪与罚》&#xff0c;书中陀思妥耶夫斯基有太多的语言描述&#xff0c;以至于我想知道这本书中到底出现了多少对白。文本介绍如果使用python程序统计一本书中的对话&#xff0c;角色名称&#xff0c;标点符号。 找…

深度学习模型数值稳定性——梯度衰减和梯度爆炸的说明

文章目录 0. 前言1. 为什么会出现梯度衰减和梯度爆炸&#xff1f;2. 如何提高数值稳定性&#xff1f;2.1 随机初始化模型参数2.2 梯度裁剪&#xff08;Gradient Clipping&#xff09;2.3 正则化2.4 Batch Normalization2.5 LSTM&#xff1f;Short Cut&#xff01; 0. 前言 按照…

读取SD卡图片bin文件显示LCD上

读取SD卡bin文件显示图片 Coding 环境搭建&#xff1a; 硬件平台&#xff1a;STM32H750XBH6开发环境&#xff1a;STM32CubeMX V6.8.1KEIL V5.28.0.0STM32H750固件版本&#xff1a;package V1.11.0仿真下载驱动&#xff1a;ST-Link 前言&#xff1a;STM32H750XBH6 的flash只…

零基础学习正演的数值模拟(含代码)

摘要: 本贴从零开始学习正演的数值模拟方法. 包括相应的偏微分基础、声波方程、雷克子波、均匀速度场的模拟、一般速度场的模拟. 1. 偏微分基础 本小节仅涉及高等数学相关知识, 与领域无关. 1.1 导数 引例: 物体从一维坐标的原点开始移动, 在 t t t 时刻, 它在坐标轴的位置…

汤普森采样(Thompson sampling): 理论支持

目录 一、UCB与TS算法数学原理1、Upper Confidence Bounds 数学原理2、Thompson sampling 数学原理a、TS 基本数据原理1. beta 分布2. 共轭分布与共轭先验3. 采样的编程实现 b、TS 算法流程1. TS算法基础版本2. Batched Thompson Sampling 二、UCB与TS算法的优缺点1、TS算法的优…

Ubuntu释放VMware虚拟磁盘未使用空间

By: Ailson Jack Date: 2023.08.26 个人博客&#xff1a;http://www.only2fire.com/ 本文在我博客的地址是&#xff1a;http://www.only2fire.com/archives/152.html&#xff0c;排版更好&#xff0c;便于学习&#xff0c;也可以去我博客逛逛&#xff0c;兴许有你想要的内容呢。…

基于Java+SpringBoot+Vue前后端分离医院后台管理系统设计和实现

博主介绍&#xff1a;✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专…

Spring为什么要专门定义BeanDefinition ,有Class不行吗?

前言 创建一个Java Bean&#xff0c;大概是下面这个流程&#xff1a; 我们写的Java文件&#xff0c;会编译为Class文件&#xff0c;运行程序&#xff0c;类加载器会加载Class文件&#xff0c;放入JVM的方法区&#xff0c;我们就可以愉快的new对象了。 创建一个Spring Bean&am…

项目总结知识点记录(二)

1.拦截器实现验证用户是否登录&#xff1a; 拦截器类&#xff1a;实现HandlerInterception package com.yx.interceptor;import org.springframework.web.servlet.HandlerInterceptor; import org.springframework.web.servlet.ModelAndView;import javax.servlet.http.HttpS…

Mybatis+MybatisPlus拦截器实战之数据的加解密和脱敏

文章目录 一、前言二、拦截器简介三、代码目录结构简介四、核心代码讲解4.1 application.yml文件4.2 自定义注解4.2.1 SensitiveEntity4.2.2 SensitiveData4.2.3 MaskedEntity4.2.4 MaskedField4.2.5 MaskedMethod 4.3 Mybatis-Plus 拦截器数据自动加密4.4 Mybatis 打印完整sql…

7年经验之谈 —— 如何实现高效的Web自动化测试?

随着互联网的快速发展&#xff0c;Web应用程序的重要性也日益凸显。为了保证Web应用程序的质量和稳定性&#xff0c;Web自动化测试成为必不可少的一环。然而&#xff0c;如何实现高效的Web自动化测试却是一个值得探讨的课题。 首先&#xff0c;选择合适的测试工具是关键。市面…

低通滤波器和高通滤波器

应用于图像低通滤波器和高通滤波器的实现 需要用到傅里叶变换 #include <opencv2/opencv.hpp> #include <Eigen> #include <iostream> #include <vector> #include <cmath> #include <complex>#define M_PI 3.14159265358979323846…

五、多表查询-3.4连接查询-联合查询union

一、概述 二、演示 【例】将薪资低于5000的员工&#xff0c;和 年龄大于50岁的 员工全部查询出来 1、查询薪资低于5000的员工 2、查询年龄大于50岁的员工 3、将薪资低于5000的员工&#xff0c;和 年龄大于50岁的 员工全部查询出来&#xff08;把上面两部分的结果集直接合并起…

最新敏感信息和目录收集技术

敏感信息和目录收集 目标域名可能存在较多的敏感目录和文件&#xff0c;这些敏感信息很可能存在目录穿越漏洞、文件上传漏洞&#xff0c;攻击者能通过这些漏洞直接下载网站源码。搜集这些信息对之后的渗透环节有帮助。通常&#xff0c;扫描检测方法有手动搜寻和自动工具查找两…

requestAnimationFrame(RAF)

1、RAF介绍 requestAnimateFrame&#xff08;RAF&#xff09;动画帧&#xff0c;是一个做动画的API。 如果想要一个动画流畅&#xff0c;就需要以60帧/s来更新视图&#xff0c;那么一次视图的更新就是16.67ms。 想要达到上述目标&#xff0c;可以通过setTimeout定时器来手动控…