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.mzph.cn/news/735993.shtml

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

相关文章

企微hook源码

企微hook源码

企微hook源码已经在QQ群内开源。速度进群下载&#xff0c;避免和谐。 QQ群&#xff1a;649480745 //pc端发送消息回调 void RecvPcMsgRes(DWORD eax) { // OutputDebugStringA("pc发送消息"); PWX_STRING pMsgPb (PWX_STRING)(eax);//消息pb结构体 string pbDa…
阅读更多...
打卡--MySQL8.0 一（单机部署）

打卡--MySQL8.0 一（单机部署）

一路走来&#xff0c;所有遇到的人&#xff0c;帮助过我的、伤害过我的都是朋友&#xff0c;没有一个是敌人。如有侵权&#xff0c;请留言&#xff0c;我及时删除&#xff01; MySQL 8.0 简介 MySQL 8.0与5.7的区别主要体现在&#xff1a;1、性能提升&#xff1b;2、新的默认…
阅读更多...
鸿蒙开发学习入门教程之环境配置

鸿蒙开发学习入门教程之环境配置

最近鸿蒙开发越来越火&#xff0c;各个大厂都有鸿蒙版本的计划和宣传&#xff0c;看这个趋势&#xff0c;可能会在几年内发展壮大&#xff0c;为我们移动端码农开辟一片新的职场。所以现在开始学起来还是很有必要的。今天就一起开始配置环境搞起来吧。 首先&#xff0c;找到官…
阅读更多...
用户管理【MySQL】

用户管理【MySQL】

文章目录 查看用户信息创建用户修改密码删除用户授予权限收回权限 查看用户信息 在名为mysql的数据库中有一个表user维护着 MySQL 的用户信息。 其中&#xff1a; user&#xff1a; 表示该用户的用户名。host&#xff1a; 表示该用户可以从哪个主机登录&#xff0c;localhost…
阅读更多...
【Spark编程基础】实验一Spark编程初级实践（附源代码）

【Spark编程基础】实验一Spark编程初级实践（附源代码）

文章目录 一、实验目的二、实验平台三、实验内容和要求1. 计算级数2. 模拟图形绘制3.统计学生成绩 一、实验目的 1.掌握 Scala 语言的基本语法、数据结构和控制结构&#xff1b; 2.掌握面向对象编程的基础知识&#xff0c;能够编写自定义类和特质&#xff1b; 3.掌握函数式编程…
阅读更多...
SSL证书：构建网络安全的基石

SSL证书：构建网络安全的基石

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
简单接入电商API接口|轻松实现实时采集淘宝、抖音、快手、1688商品，挖掘潜力款

简单接入电商API接口|轻松实现实时采集淘宝、抖音、快手、1688商品，挖掘潜力款

今天给大家带来一款非常实用的电商API接口&#xff0c;这款数据采集接口支持淘宝采集、抖音采集、快手采集、1688采集以及潜力款分析&#xff0c;功能强大&#xff0c;助您在电商领域更上一层楼。 首先&#xff0c;我们来了解一下淘宝采集功能。作为国内最大的电商平台&#xf…
阅读更多...
基于Java+springboot+VUE+redis实现的前后端分类版网上商城项目

基于Java+springboot+VUE+redis实现的前后端分类版网上商城项目

基于Java springbootVUEredis实现的前后端分类版网上商城项目 博主介绍&#xff1a;多年java开发经验&#xff0c;专注Java开发、定制、远程、文档编写指导等,csdn特邀作者、专注于Java技术领域 作者主页 央顺技术团队 Java毕设项目精品实战案例《1000套》 欢迎点赞 收藏 ⭐留言…
阅读更多...
Contact-GraspNet: Efficient 6-DoF Grasp Generationin Cluttered Scenes

Contact-GraspNet: Efficient 6-DoF Grasp Generationin Cluttered Scenes

总结 提出一种端到端的网络&#xff0c;解决复杂场景中对未知物体的抓取。将六自由度抓取投影到观察到的点云中的接触点&#xff0c;表示只有4-DoF。 摘要 我们提出了一个端到端网络&#xff0c;可以直接从场景的深度记 录中有效地生成六自由度平行颚抓取的分布。 我们的新…
阅读更多...
06 数据结构之树

06 数据结构之树

引言&#xff1a; 数的代码实现&#xff0c; 先序遍历、中序、后序、层次遍历 /* binary_tree.h */ #ifndef _BINARY_TREE_H #define _BINARY_TREE_H#include <stdio.h> #include <stdlib.h> #include <string.h>#define DEBUG(msg) \printf("--%s--, %…
阅读更多...
车载诊断协议DoIP系列 —— 诊断报文和诊断报文应答传输层安全(TLS)

车载诊断协议DoIP系列 —— 诊断报文和诊断报文应答传输层安全(TLS)

车载诊断协议DoIP系列 —— 诊断报文和诊断报文应答&传输层安全(TLS) 我是穿拖鞋的汉子，魔都中坚持长期主义的汽车电子工程师（Wechat：gongkenan2013）。 老规矩，分享一段喜欢的文字，避免自己成为高知识低文化的工程师： 本就是小人物，输了就是输了，不要在意别人怎…
阅读更多...
NLP：文本相似度计算

NLP：文本相似度计算

前面我们已经实现了把长段的句子&#xff0c;利用HanLP拆分成足够精炼的分词&#xff0c;后面我们要实现“联想”功能&#xff0c;我这里初步只能想到通过文本相似度计算来实现。下面介绍一下文本相似度计算 &#xff08;当然HanLP也有文本相似度计算的方法&#xff0c;这里我…
阅读更多...
【JAVA】CSS3伸缩盒案例、响应式布局、BFC

【JAVA】CSS3伸缩盒案例、响应式布局、BFC

1.CSS3伸缩盒案例 效果&#xff1a;用伸缩盒模型 <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>Document</title>&…
阅读更多...
Windows电脑安装Linux（Ubuntu 22.04）系统（图文并茂）

Windows电脑安装Linux（Ubuntu 22.04）系统（图文并茂）

Windows电脑安装Ubuntu 22.04系统&#xff0c;其它版本的Ubuntu安装方法相同 Ubuntu 16.04、Ubuntu 18.04安装方法相同&#xff0c;制作U盘启动项的镜像文件下载你需要的版本即可&#xff01; Ubuntu的中文官网网址&#xff1a;https://cn.ubuntu.com/&#xff0c;聪明的你一定…
阅读更多...
redisson解决redis服务器的主从一致性问题

redisson解决redis服务器的主从一致性问题

redisson解决redis的主节点和从节点一致性的问题。从而解决锁被错误获取的情况。 实际开发中我们会搭建多台redis服务器&#xff0c;但这些服务器分主次&#xff0c;主服务器负责处理写的操作&#xff08;增删改&#xff09;&#xff0c;从服务器负责处理读的操作&#xff0c;…
阅读更多...
TCP粘包和分包

TCP粘包和分包

TCP的粘包和分包是网络通信中常见的问题&#xff0c;特别是在使用TCP协议进行数据传输时。这两个问题都涉及到TCP在传输数据时的工作机制。 粘包&#xff08;TCP数据合并&#xff09; 粘包指的是发送方发送的多个小数据包在传输过程中被TCP协议合并成一个大的数据包接收&…
阅读更多...
英飞凌电源管理PMIC的安全应用

英飞凌电源管理PMIC的安全应用

摘要 本篇文档主要用来介绍英飞凌电源管理芯片TLF35584的使用&#xff0c;基于电动助力转向应用来介绍。包含一些安全机制的执行。 TLF35584介绍 TLF35584是英飞凌推出的针对车辆安全应用的电源管理芯片&#xff0c;符合ASIL D安全等级要求&#xff0c;具有高效多电源输出通道&…
阅读更多...
AI认知与科普（通识）

AI认知与科普（通识）

一、宏观分析 1.全球人工智能产业概况&#xff1a; 近年来&#xff0c;全球人工智能产业呈现出快速增长的趋势。据相关数据显示&#xff0c;全球人工智能市场规模预计将在2025年达到约600亿美元&#xff0c;年复合增长率达到约25%。其中&#xff0c;美国、中国、欧洲、日本等地…
阅读更多...
Jmeter+Ant+Git/SVN+Jenkins实现持续集成接口测试，一文精通（一）

Jmeter+Ant+Git/SVN+Jenkins实现持续集成接口测试，一文精通（一）

前言 Jmeter&#xff0c;Postman一些基本大家相比都懂。那么真实在项目中去使用&#xff0c;又是如何使用的呢&#xff1f;本文将一文详解jmeter接口测试 一、接口测试分类 二、目前接口架构设计 三、市面上的接口测试工具 四、Jmeter简介&#xff0c;安装&#xff0c;环境…
阅读更多...
opencv解析系列 - 基于DOM提取大面积植被（如森林）

opencv解析系列 - 基于DOM提取大面积植被（如森林）

Note&#xff1a;简单提取&#xff0c;不考虑后处理&#xff08;填充空洞、平滑边界等&#xff09; #include <iostream> #include "opencv2/imgproc.hpp" #include "opencv2/highgui.hpp" #include <opencv2/opencv.hpp> using namespace cv…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023