Linux学习——线程的控制

目录

​编辑

一，线程的创建

二，线程的退出

1，在子线程内return

 2,使用pthread_exit(void*)

三，线程等待

四，线程获取自己的id值

五，线程取消

六，线程分离

一，线程的创建

在对进程控制之前，首先要做的便是创建一个线程。创建方法如下：

使用的创建方法叫做pthread_create。

参数介绍：

thread：线程id
attr：线程属性，直接设为null
start_routine：函数指针
arg：这个参数会传递进start_routine的void*参数中。

例子：

 #include<iostream>#include<pthread.h>#include<unistd.h>using namespace std;void* hander(void* args)//新线程执行的方法{while(true){sleep(1);cout << "i am new thread" << endl;}}int main(){pthread_t td;pthread_create(&td, nullptr, hander, nullptr);//创建好新线程以后，新线程会去执行传入的hander方法。while(true)//主线程会继续向下执行自己的方法{sleep(1);cout << "i am main thread" << endl;}return 0;}

 执行这个代码以后结果如下：

在这里要注意，在使用g++编译时要加上-lpthread。因为线程库是一个第三方库，但是是安装在系统中的所以只需要-l便可以连接到pthread库。

二，线程的退出

1，在子线程内return

  线程的退出有多种方式，先来看看最基本的一种退出方式，代码如下：

​
void *hander(void *args)
{string name = static_cast<const char *>(args);int cnt = 5;while (cnt--){cout << "i am new thread" << name << endl;sleep(1);}return nullptr;//最基本的退出线程的方式便是直接在子线程内部使用return的方式退出
}class data
{
public:char buf[64];int i;
};int main()
{for (int i = 1; i <= NUM; i++) // 创建一批线程{data *m = new data();snprintf(m->buf, sizeof(m->buf), "%s:%d", "new thread", i);pthread_t td;pthread_create(&td, nullptr, hander, (void *)m->buf);}while (true){cout << "-- -- -- -- -- -- -- --sucess -- -- -- -- -- -- -- " << endl;sleep(1);}return 0;
}​

 在使用这种方式退出时，主线程在子线程退出以后还会继续执行。但是如果是子线程不退出而主线程先退出呢？像这样：

​
void *hander(void *args)
{string name = static_cast<const char *>(args);int cnt = 5;while (true)//子线程一直在死循环{cout << "i am new thread" << name << endl;sleep(1);}return nullptr;
}class data
{
public:char buf[64];int i;
};int main()
{for (int i = 1; i <= NUM; i++) // 创建一批线程{data *m = new data();snprintf(m->buf, sizeof(m->buf), "%s:%d", "new thread", i);pthread_t td;pthread_create(&td, nullptr, hander, (void *)m->buf);}int cnt = 5;while (cnt--)//主线程在cnt减到零时就退出{cout << "-- -- -- -- -- -- -- --sucess -- -- -- -- -- -- -- " << endl;sleep(1);}return 0;
}​

 这样的话只要主线程退出了，这个进程都会直接结束。 如下：

 2,使用pthread_exit(void*)

这个函数是线程库提供给我们的专门用于线程退出的函数，他的参数可以直接设置为nullptr。使用方式如下：

void *hander(void *args)
{string name = static_cast<const char *>(args);int cnt = 5;while (cnt--){cout << "i am new thread" << name << endl;sleep(1);}pthread_exit(nullptr);//使用pthread_exit()退出线程。
}class data
{
public:char buf[64];int i;
};int main()
{for (int i = 1; i <= NUM; i++) // 创建一批线程{data *m = new data();snprintf(m->buf, sizeof(m->buf), "%s:%d", "new thread", i);pthread_t td;pthread_create(&td, nullptr, hander, (void *)m->buf);}while (true){cout << "-- -- -- -- -- -- -- --sucess -- -- -- -- -- -- -- " << endl;sleep(1);}return 0;
}

使用pthread_exit退出的效果和在子线程内使用return退出的效果一样。 

 ##注意##  线程的退出不能使用exit,因为exit的本质其实是向进程发信号，所以exit是专门用于进程退出的。同样的，线程的退出也不需要返回errno，因为如果一个线程因为异常退出的话整个进程都会退出，进程返回errno就可以了。

三，线程等待

和进程一样，线程也需要等待。等待的目的如下：

1，回收新线程对应的内核资源。

2，接收新线程返回的数据。

线程等待函数： int pthread_join(pthread_t thread, void **retval)

thread:表示要等待线程的pid

reval:接收数据并将数据带出。

使用如下：

class thread
{
public:int _num;       // 线程的编号char _buf[64];  // 线程的名字pthread_t _tid; // 线程的id
};void *start_routine(void *args)
{int cnt = 5;while (cnt--){sleep(1);thread *_td = static_cast<thread *>(args);cout << "i am new thread:" << _td->_buf << ":" << _td->_num<< ":" << _td->_tid << endl;}pthread_exit(nullptr);//线程退出
}int main()
{vector<thread*> threads;for (int i = 1; i <= 10; i++)//创建线程{thread *td = new thread;td->_num = i;snprintf(td->_buf, sizeof(td->_buf), "%s-%d", "thread:", i);pthread_create(&td->_tid, nullptr, start_routine, (void *)td);threads.push_back(td);}for(auto e:threads){void *ret = nullptr;pthread_join(e->_tid, &ret);//回收线程cout << "等待成功"<< " tid:" << e->_tid << endl;}cout << "等待结束" << endl;return 0;
}

以上的代码便演示了如何用pthread_join进行线程的等待效果如下：

那该函数里面的里面的返回值有什么作用呢？其实这个返回值就是用来带出退出码的。过程如下：

 添加打印退出码的信息以后结果如下：

那为什么reval的类型是二级指针类型呢？这其实是因为线程结束后，退出信息会写入到线程库内部。线程库内部的退出码便是void*类型的。此时我们要想的便是获取这个退出码了，如何获取呢？因为pthread_join()的返回值是int类型的，所以我们便不能直接让pthread_join()直接返回一个void*类型的变量，所以只能自己在用户层定义一个void*类型的retval然后retval的地址传入进去获取返回值了。

四，线程获取自己的id值

使用 pthread_t pthread_self(void)可以获取到当前线程的id值。

示例代码：

#include <iostream>
#include <pthread.h>
#include <vector>
#include <unistd.h>
using namespace std;void *Done(void *args)
{uint64_t i = (uint64_t)args;string name = "thread_" + to_string(i);sleep(1);cout << name << "id :" << pthread_self() << endl;//使用pthread_self()打印线程id值。}int main()
{vector<pthread_t> wait;for (uint64_t i = 1; i <= 4; i++){pthread_t td;pthread_create(&td, nullptr, Done, (void *)i); // 创建线程wait.push_back(td);sleep(2);}for (auto e : wait) // 等待线程{pthread_join(e, nullptr);}return 0;
}

 

如果用16进制打印便是下面这样的： 

其实线程的id就是一些地址。

五，线程取消

 进行线程取消的函数叫做pthread_cancel(pthread_t thread)。线程取消的前提是线程先运行起来，然后才能取消。

实验代码：创建线程，然后取消一半线程，观察现象。

class thread
{
public:int _num;       // 线程的编号char _buf[64];  // 线程的名字pthread_t _tid; // 线程的id
};void *start_routine(void *args)
{int cnt = 5;while (cnt--){sleep(1);thread *_td = static_cast<thread *>(args);cout << "i am new thread:" << _td->_buf << ":" << _td->_num<< ":" << _td->_tid << endl;}pthread_exit((void*)100);
}int main()
{vector<thread *> threads;for (int i = 1; i <= 10; i++){thread *td = new thread;td->_num = i;snprintf(td->_buf, sizeof(td->_buf), "%s-%d", "thread:", i);pthread_create(&td->_tid, nullptr, start_routine, (void *)td->_buf);threads.push_back(td);}for (int i = 0;i<threads.size()/2;i++)//取消一半的线程{pthread_cancel(threads[i]->_tid);}for (auto e : threads)//等待{void *ret = nullptr;pthread_join(e->_tid, &ret);cout << "等待成功"<< " tid:" << e->_tid << "quit code: " << (long long)(ret) << endl;delete e;}cout << "等待结束" << endl;return 0;
}

 运行结果如下：

可以看到如果取消线程，那线程还是会被等待然后退出，退出码是-1。其实这是一个宏：

六，线程分离

        线程分离使用到的函数 int pthread_detach(pthread_t thread)。先来说明一下，新创建的线程默认是joinable的。但是如果我的主线程并不关心当前的线程的返回值，那当前的线程便与我无关。那我的主线程去等待当前的线程便对我的主线程是一种负担。这个时候便可以来进行线程分离。线程的分离方式有两种：1，主线程去分离子线程    2，子线程自己进行分离。

示例代码：

1，主线程进行分离

#include<iostream>
#include<pthread.h>
#include<vector>
#include<unistd.h>
using namespace std;void* Done(void* args)
{uint64_t i = (uint64_t)args;string name = "thread_" + to_string(i);int cnt = 5;while (cnt--){sleep(1);cout << name << "running....." << endl;sleep(3);}
}int main()
{vector<pthread_t> wait;for (uint64_t i = 1; i <= 4; i++){pthread_t td;pthread_create(&td, nullptr, Done, (void*)i);//创建线程wait.push_back(td);sleep(3);//先休眠三秒，再进行线程分离pthread_detach(td);//主线程子集分离}for(auto e:wait)//等待线程{int n =  pthread_join(e,nullptr);cout << n << " " << endl;//打印等待的返回值，0表示成功，其它表示失败。}return 0;
}

2，子线程自己主动分离 

#include <iostream>
#include <pthread.h>
#include <vector>
#include <unistd.h>
using namespace std;void *Done(void *args)
{uint64_t i = (uint64_t)args;string name = "thread_" + to_string(i);pthread_detach(pthread_self()); // 子线程自己自动分离int cnt = 5;while (cnt--){cout << name << "running....." << endl;sleep(1);}
}int main()
{vector<pthread_t> wait;for (uint64_t i = 1; i <= 4; i++){pthread_t td;pthread_create(&td, nullptr, Done, (void *)i); // 创建线程wait.push_back(td);}for (auto e : wait) // 等待线程{int n = pthread_join(e, nullptr);cout << n << " " << endl; // 打印等待的返回值，0表示成功，其它表示失败。}return 0;
}

  

 

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

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

相关文章

JavaEE企业开发新技术2

JavaEE企业开发新技术2

目录 2.7 Field类的基本概念 文字性概念描述&#xff1a; Field类 2.8 Field的基本操作-1 2.9 Field的基本操作-2 分析&#xff1a; 2.10 Field 的综合练习 总结&#xff1a; 和equals的区别&#xff1a; 使用 比较 使用equals比较 2.7 Field类的基本概念 文字性…
阅读更多...
IAR全面支持小华全系芯片，强化工控及汽车MCU生态圈

IAR全面支持小华全系芯片，强化工控及汽车MCU生态圈

IAR Embedded Workbench for Arm已全面支持小华半导体系列芯片&#xff0c;加速高端工控MCU和车用MCU应用的安全开发 嵌入式开发软件和服务的全球领导者IAR与小华半导体有限公司&#xff08;以下简称“小华半导体”&#xff09;联合宣布&#xff0c;IAR Embedded Workbench fo…
阅读更多...
微信小程序开发系列（二十四）·wxml语法·列表渲染·wx:for-item 和 wx:for-index

微信小程序开发系列（二十四）·wxml语法·列表渲染·wx:for-item 和 wx:for-index

目录 1. 如果需要对默认的变量名和下标进行修改&#xff0c;可以使用wx:for-item 和 wx:for-index 2. 将 wx:for 用在 标签上&#xff0c;以渲染一个包含多个节点的结构块 方法一 方法二 3. 总结 3.1 wx:for-item 和 wx:for-index总结 3.2 总结 1. 如果需要对默…
阅读更多...
简述epoll实现

简述epoll实现

所有学习笔记&#xff1a;https://github.com/Dusongg/StudyNotes 文章目录 epoll数据结构的选择&#xff1f;以tcp为例&#xff0c;网络io的可读可写如何判断&#xff1f;epoll如何做到线程安全&#xff1f;LT和ET如何实现&#xff1f;tcp状态和io的读写有哪些关系&#xff1…
阅读更多...
ChatGPT等AI使用的过程苦笑不得瞬间

ChatGPT等AI使用的过程苦笑不得瞬间

引言&#xff1a; 在人工智能的浪潮中&#xff0c;我们见证了技术的飞速发展和智能应用的广泛渗透。特别是随着语言模型的进步&#xff0c;AI如ChatGPT、文心一言、通义千问、讯飞星火等已经成为人们日常生活和工作中不可或缺的助手。然而&#xff0c;与任何新兴技术一样&#…
阅读更多...
零售EDI：劳氏 Lowe‘s EDI项目案例

零售EDI：劳氏 Lowe‘s EDI项目案例

通过 EDI&#xff0c;企业与Lowes之间可以直接交换各种商业文档&#xff0c;如订单、发票、收据等&#xff0c;从而实现信息的实时交换&#xff0c;提高了供应链的效率和准确性。在现代供应链管理中&#xff0c;EDI 已经成为了不可或缺的重要工具。 作为一家拥有多条业务线的企…
阅读更多...
力扣每日一题 找出数组的第 K 大和 小根堆 逆向思维（TODO：二分+暴搜）

力扣每日一题 找出数组的第 K 大和 小根堆 逆向思维（TODO：二分+暴搜）

Problem: 2386. 找出数组的第 K 大和 文章目录 思路复杂度&#x1f496; 小根堆&#x1f496; TODO&#xff1a;二分 暴搜 思路 &#x1f468;‍&#x1f3eb; 灵神题解 复杂度 时间复杂度: 添加时间复杂度, 示例&#xff1a; O ( n ) O(n) O(n) 空间复杂度: 添加空间复杂…
阅读更多...
组态软件基础知识

组态软件基础知识

一、组态软件基础知识 1、概述 &#xff08;1&#xff09;、组态软件概念与产生背景 “组态”的概念是伴随着集散型控制系统&#xff08;Distributed Control System简称DCS&#xff09;的出现才开始被广大的生产过程自动化技术人员所熟知的。在工业控制技术的不断发…
阅读更多...
新手如何快速上手学习单片机？

新手如何快速上手学习单片机？

读者朋友能容我&#xff0c;不使博文负真心 新开专栏&#xff0c;期待与诸君共享精彩 个人主页&#xff1a;17_Kevin-CSDN博客 专栏&#xff1a;《单片机》 学习单片机是一个有趣且有挑战性的过程。单片机是一种微控制器&#xff0c;广泛应用于各种电子设备和嵌入式系统中。在这…
阅读更多...
大模型快速实现python3+html内容在线渲染

大模型快速实现python3+html内容在线渲染

需求&#xff1a; 有一份数据需要通过前端在线展示给用户&#xff0c;不需要复杂的样式交互&#xff0c;后端服务是基于Python3实现的API接口&#xff0c;对前端技术不是很了解&#xff0c;需要快速实现该需求。类似样式即可&#xff1a; 思路&#xff1a; 如果页面不复杂&am…
阅读更多...
开放式高实时高性能PLC控制器解决方案-基于米尔电子STM32MP135

开放式高实时高性能PLC控制器解决方案-基于米尔电子STM32MP135

前言 随着工业数字化进程加速与IT/OT深入融合&#xff0c;不断增加的OT核心数据已经逐步成为工业自动化行业的核心资产&#xff0c;而OT层数据具备高实时、高精度、冗余度高、数据量大等等特点&#xff0c;如何获取更加精准的OT数据对数字化进程起到至关重要的作用&#xff0c;…
阅读更多...
编译支持国密的抓包工具 WireShark

编译支持国密的抓包工具 WireShark

目录 前言WireShark支持国密的 WireShark小结前言 在上一篇文章支持国密的 Web 服务器中，我们搭建了支持国密的 Web 服务器，但是，我们使用 360 安全浏览器去访问，却出现了错误： 是我们的 Web 服务器没有配置好？在这里插入图片描述还是 360 安全浏览器不支持国密？还是两…
阅读更多...
中间件 | Redis - [基本信息]

中间件 | Redis - [基本信息]

INDEX 1 常规用法2 QPS3 pipeline 1 常规用法 分布式锁 最常见用法&#xff0c;需要注意分布式锁的redis需要单点 分布式事务 分布式事务中&#xff0c;核心的技术难点其实是分布式事务这个事本身作为数据的持久化 2PC&#xff0c;比如 seata 的 AT 模式下&#xff0c;将 un…
阅读更多...
moi3D安装

moi3D安装

下载文件双击文件 下一步 同意下一步 下一步 下一步 下一步 安装下一步 完成 破解 将如图中的文件复制到文件目录下 汉化 在目录中进入ui文件夹下 在安装包中找到如下的文件复制到ui目录下 在打开 另存为 另存为时改一下编码格式如图 打开软件 找到如图options进入…
阅读更多...
七彩虹八渐变 外贸建站公司wordpress模板

七彩虹八渐变 外贸建站公司wordpress模板

进出口水果wordpress外贸模板 漂亮水果wordpress外贸模板&#xff0c;做水果进出品生意的外贸公司自建站官网模板。 https://www.jianzhanpress.com/?p3516 玩具wordpress外贸模板 简洁玩具wordpress外贸模板&#xff0c;适合做跨境电商外贸公司使用的wordpres外贸s网站主题…
阅读更多...
深入探索HAProxy：高性能负载均衡器的奥秘

深入探索HAProxy：高性能负载均衡器的奥秘

目录 引言 一、HAProxy基础知识 &#xff08;一&#xff09;HAProxy概述 &#xff08;二&#xff09;核心特性 &#xff08;三&#xff09;支持调度算法 二、安装haproxy &#xff08;一&#xff09;下载源码包 &#xff08;二&#xff09;解决依赖环境 &#xff08;三…
阅读更多...
CAP告诉你系统没法做到完美，只能做到权衡和适当

CAP告诉你系统没法做到完美，只能做到权衡和适当

一、CAP介绍 CAP原理&#xff0c;全称为Consistency&#xff08;一致性&#xff09;、Availability&#xff08;可用性&#xff09;和Partition tolerance&#xff08;分区容错性&#xff09;&#xff0c;是分布式系统设计中的基本原理。它强调了在设计分布式系统时&#xff0c…
阅读更多...
【Linux】第四十二站：线程局部存储与线程分离

【Linux】第四十二站：线程局部存储与线程分离

一、线程的局部存储 1.实现多线程 如果我们想创建多线程&#xff0c;我们可以用下面的代码类似去实现 #include <iostream> #include <pthread.h> #include <string> #include <cstdlib> #include <unistd.h> #include <thread> #inclu…
阅读更多...
【机器学习】进阶学习：详细解析Sklearn中的MinMaxScaler---原理、应用、源码与注意事项

【机器学习】进阶学习：详细解析Sklearn中的MinMaxScaler---原理、应用、源码与注意事项

【机器学习】进阶学习&#xff1a;详细解析Sklearn中的MinMaxScaler—原理、应用、源码与注意事项 这篇文章的质量分达到了97分&#xff0c;虽然满分是100分&#xff0c;但已经相当接近完美了。请您耐心阅读&#xff0c;我相信您一定能从中获得不少宝贵的收获和启发~ &#x1f…
阅读更多...
PromptBreeder---针对特定领域演化和发展提示词的方法

PromptBreeder---针对特定领域演化和发展提示词的方法

原文地址&#xff1a;promptbreeder-evolves-adapts-prompts-for-a-given-domain 论文地址&#xff1a;https://arxiv.org/pdf/2309.16797.pdf 2023 年 10 月 6 日 提示方法分为两大类 硬提示是由人工精心设计的文本提示&#xff0c;包含离散的输入令牌&#xff1b;其缺点…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023