【Linux 20】进程控制

文章目录

  • 🌈 一、创建线程
    • ⭐ 1. 线程创建函数
    • ⭐ 3. 给线程传参
    • ⭐ 4. 创建多线程
    • ⭐ 5. 获取线程 ID
  • 🌈 二、终止线程
    • ⭐1. 使用 return 终止线程
    • ⭐ 2. 使用 pthread_exit 函数终止线程
    • ⭐ 3. 使用 pthread_cancel 函数终止线程
  • 🌈 三、等待线程
    • ⭐ 1. 线程等待函数
    • ⭐ 2. 获取返回值
  • 🌈 四、分离线程
    • ⭐ 1. 线程分离概念
    • ⭐ 2. 线程分离函数

  • 引入线程库:要使用线程相关的函数,需要使用 #include <pthread.h> 引入原生线程库。
  • 链接线程库:引入线程库后,在编译程序时还需要使用 -lpthread 选项链接原生线程库。

🌈 一、创建线程

⭐ 1. 线程创建函数

  • 线程创建成功时返回 0,创建失败时返回错误码。
#include <pthread.h>int pthread_create(pthread_t *thread, 				/* 输出型参数,用以获取创建成功的线程 ID */const pthread_attr_t *attr,		/* 设置创建线程的属性,使用 nullptr 表示使用默认属性 */void *(*start_routine) (void *), /* 函数地址,该线程启动后需要去执行的函数 */void *arg);						/* 线程要去执行的函数的形参,没参数时可填写 nullptr */
```## ⭐ 2. 创建单线程- 当一个程序启动时,其中至少有一个线程在工作,这个线程就叫做主线程。
- 主线程是产生其他子线程的线程,通常主线程必须最后完成某些执行操作。
- 让主线程调用 pthread_create 函数创建一个新线程,然后让新线程跑去执行 thread_run 函数,而主线程则继续执行后续代码。```cpp
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;// 新线程
void* thread_run(void* args)
{while (true){cout << "新 线程正在运行" << endl;sleep(1);}
}// 主线程
int main()
{// 记录线程 idpthread_t tid;// 创建新线程,并让新线程去执行 thread_run 函数pthread_create(&tid, nullptr, thread_run, nullptr);// 主线程继续执行自己后续的代码while (true){cout << "主 线程正在运行" << endl;sleep(1);}return 0;
}
  • 运行代码后会发现,主线程和新线程会交替执行自己的任务。

  • 在程序运行过程中,新开一个窗口使用ps axj命令查看当前进程的信息时,由于这两个线程都属于同一个进程,因此只能看到一个进程的信息。

image-20240912174356270

  • 如果想要查看线程 (轻量级进程) 的相关信息,可以使用 ps -aL 查看指定进程内部的轻量级进程的信息。
    • LWP (Light Weight Process) 表示的就是线程 (轻量级进程) 的 ID,其中主线程的 LWP 值等同于进程的 PID 值。

image-20240912175003416

⭐ 3. 给线程传参

  • 由于 pthread_create 函数创建出来的线程所执行的函数的形参类型是 void* 的,可以传递任何类型的参数,也能传对象给线程使用
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;class thread_data
{
public:thread_data(const string& thread_name):_thread_name(thread_name){}string thread_name(){return _thread_name;}private:    string _thread_name;
};void* thread_run(void* args)
{thread_data* td = static_cast<thread_data*>(args);while (true){cout << "新线程 " << td->thread_name() << " 正在运行" << endl;sleep(1);}
}int main()
{thread_data* td = new thread_data("thread 1");// 创建新线程,将 td 对象作为 thread_tun 函数的参数pthread_t tid;pthread_create(&tid, nullptr, thread_run, td);while (true){cout << "主线程正在运行" << endl;sleep(1);}return 0;
}

⭐ 4. 创建多线程

  • 每个线程都由各自的线程 ID 所管理着,创建多线程时可以使用一个数据结构将每个创建出来的线程的 ID 管理起来。

举个例子

  • 创建 5 个线程,使用数组将这些线程的线程 ID 管理起来,让这些线程都去执行 thread_run 函数。
#include <string>
#include <vector>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;
using std::vector;
using std::to_string;class thread_data
{
public:thread_data(const string& thread_name):_thread_name(thread_name){}string thread_name(){return _thread_name;}private:    string _thread_name;
};void* thread_run(void* args)
{thread_data* td = static_cast<thread_data*>(args);while (true){cout << "新线程 " << td->thread_name() << " 正在运行" << endl;sleep(1);}
}const int thread_num = 5;   // 创建 5 个线程int main()
{// 存储创建的所有线程的线程 IDvector<pthread_t> tids(thread_num);// 创建 5 个线程并给每个线程传递一个 thread_data 对象for (size_t i = 0; i < thread_num; i++){string thread_name = "thread " + to_string(i + 1);thread_data* td = new thread_data(thread_name);pthread_create(&tids[i], nullptr, thread_run, td);}while (true){cout << "主线程正在运行" << endl;sleep(1);}return 0;
}

  • 再使用 ps -aL 指令可以查到 主 + 新 这 6 个线程的情况。

image-20240912200440834

⭐ 5. 获取线程 ID

  1. 可通过 pthread_create 函数的第一个输出型参数获得创建的线程的 ID。
  2. 让线程执行的函数调用 pthread_self 函数获取调用该函数的线程的 ID。
    • 哪个线程调用该函数就返回哪个线程的线程 ID。
#include <pthread.h>pthread_t pthread_self(void);
  • 注:pthread_self 函数获得的线程 ID 不等于内核的 LWP 值,pthread_self 函数获得的是用户级原生线程库的线程 ID,而 LWP 是内核的轻量级进程ID,它们之间是一对一的关系。

🌈 二、终止线程

  • 如果只是想终止某个线程而不是整个进程,可以有如下 3 种方法。
  1. 使用 return 终止线程:非主线程可以在执行的函数中使用 return 终止当前线程。
  2. 使用 pthread_exit 终止线程:线程自己可以调用该函数终止自己。
  3. 使用 pthread_cancel 终止线程:该函数能通线程 ID 终止任意线程。

⭐1. 使用 return 终止线程

  • 在线程调用的函数中使用 return 退出当前线程,但是在main函数中使用return代表整个进程退出,也就是说只要主线程退出了那么整个进程就退出了,此时该进程曾经申请的资源就会被释放,而其他线程会因为没有了资源,自然而然的也退出了。

举个例子

#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// 让新线程运行 5 秒之后退出for (size_t i = 0; i < 5; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}return nullptr;
}int main()
{pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");while (true){cout << "主线程正在运行" << endl;sleep(1);}return 0;
}

⭐ 2. 使用 pthread_exit 函数终止线程

#include <pthread.h>void pthread_exit(void *retval);	// retval 是线程在退出时,线程所调用函数的返回值
  • pthread_exit 或者 return 返回的指针所指向的内存单元必须是全局的或者是用malloc 分配的,不能在线程函数的栈上分配,因为当其他线程得到这个返回指针时,线程函数已经退出了。

举个例子

#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// 让新线程运行 5 秒之后退出for (size_t i = 0; i < 5; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}pthread_exit(nullptr);
}int main()
{pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");while (true){cout << "主线程正在运行" << endl;sleep(1);}return 0;
}

⭐ 3. 使用 pthread_cancel 函数终止线程

  • 该函数可以根据线程 ID 终止任意线程,可以用来终止自己或其他线程,不过一般建议是拿来终止其他线程。

举个例子

  • 在新线程运行 5s 后,用主线程将新线程终止。
#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);while (true){cout << thread_name << " 正在运行" << endl;sleep(1);}
}int main()
{pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");cout << "主线程正在运行" << endl;sleep(5);pthread_cancel(tid);    // 主线程终止新线程cout << "新线程已被终止" << endl;return 0;
}

image-20240914154513668

🌈 三、等待线程

  • 和进程等待一样,一个线程在被创建出来时,也需要被等待。
  • 新线程在退出时,主线程也要回收新线程所持有的资源,否则会产生类似进程的 “僵尸” 问题,从而造成内存泄漏。
  • 新线程退出时,主线程需要根据新线程的返回值,获取新线程的退出信息。
  • 此外,主线程不关心新线程异常退出的情况,因为线程一旦异常进程立马就会挂掉,只会关心进程退出的相关信息。

⭐ 1. 线程等待函数

  • 该函数在等待成功时会返回 0,失败时返回对应的错误码。
#include <pthread.h>int pthread_join(pthread_t thread,	/* 被等待的线程的线程 ID */ void **retval);		/* 获取被等待的线程在退出时的返回值 */
  • 调用该函数的线程将阻塞等待新线程,直到所等待的的新线程终止为止,被等待的线程以不同的方式终止时,通过 pthread_join 得到的终止状态也是不同的。

举个例子

#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// 让新线程运行 5 秒之后退出for (size_t i = 0; i < 5; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}return nullptr;
}int main()
{// 主线程创建新线程pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");cout << "主线程正在运行" << endl;// 主线程阻塞等待 tid 所描述的新线程int n = pthread_join(tid, nullptr);cout << "主线程运行完毕, n: " << n << endl;return 0;
}

⭐ 2. 获取返回值

  • pthread_create 创建出的线程所调用函数的返回值是一个 void* 类型的值,而 pthread_join 函数的第二个输出型参数是 void** 类型,就是为了获取新线程所调用函数的返回值。

1. 举个例子

  • 让新线程调用的函数返回一个字符串。
#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// 让新线程运行 5 秒之后退出for (size_t i = 0; i < 5; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}return (void*)"thread 1 done";  			// 返回这个字符串常量的起始地址// pthread_exit((void*)"thread 1 done");	// 这两种方法返回的内容一样
}int main()
{// 主线程创建新线程pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");cout << "主线程正在运行" << endl;// 主线程阻塞等待 tid 所描述的新线程void* ret = nullptr;            // 用来接收线程退出时的退出信息int n = pthread_join(tid, &ret);cout << "主线程运行完毕, n: " << n << endl;cout << "主线程获取到的新线程的退出信息为: " << (char*)ret << endl;return 0;
}

2. 线程退出时可以返回对象

  • 由于线程所调用的函数的返回值是 void* 类型的,意味着线程在完事之后还可以返回一个处理好的对象。
#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;// 保存线程退出时的相关信息
class thread_return
{
public:pthread_t _id;   // 哪个线程退了string _info;    // 退出时想传达的信息int _code;       // 线程退出的信息
public:thread_return(pthread_t id, const string& info, int code): _id(id), _info(info), _code(code){}
};// 新线程所执行的函数
void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// 让新线程运行 5 秒之后退出for (size_t i = 0; i < 5; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}thread_return* ret = new thread_return(pthread_self(), "线程正常退出", 10);pthread_exit(ret);
}int main()
{// 主线程创建新线程pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");cout << "主线程正在运行" << endl;// 主线程阻塞等待 tid 所描述的新线程void* ret = nullptr;            // 用来接收线程退出时的退出信息int n = pthread_join(tid, &ret);cout << "主线程运行完毕, n: " << n << endl;thread_return* r = static_cast<thread_return*>(ret);cout << "主线程获取到的新线程的退出信息为" << endl;cout << "id: " << r->_id << ", info: " << r->_info << ", code: " << r->_code << endl;delete r;return 0;
}

image-20240914153537503

  • 这种特性使得我们可以将任务分配给线程运行,运行完毕之后再将结果返回。

🌈 四、分离线程

⭐ 1. 线程分离概念

  • 一般情况下,主线程是需要阻塞等待新线程的,如果不等待线程退出,就有可能造成 “僵尸” 问题。
  • 但如果主线程就是不想等待新线程退出,也不关心新线程的返回值,此时就可以将新线程分离,被分离的线程在退出时会自动释放资源
  • 分离出的新线程依旧要使用进程的资源,且依旧在该进程内运行,甚至这个新线程崩溃了也会影响整个进程。线程分离只是让主线程不需要再阻塞等待整个新线程罢了,在新线程退出时系统会自动回收该线程所持有的资源。
  • 一个线程可以将其他线程分离出去,也可以将自己分离出去。
  • 等待和分离会发生冲突,一个线程不能既是可被等待的又是分离出去的。
  • 虽然分离出去的线程已经不归主线程管了,但一般还是建议让主线程最后再退出
  • 分离出去的线程可以被 pthread_cancel 函数终止,但不能被 pthread_join 函数等待。

⭐ 2. 线程分离函数

#include <pthread.h>int pthread_detach(pthread_t thread);	// thread 是要分离出去的线程的 ID
  • 线程分离成功时返回 0,失败时则返回对应错误码。

举个例子

  • 主线程将创建好的 thread 1 线程分离出去,之后主线程就不需要再 join 新线程了。
#include <string>
#include <unistd.h>
#include <iostream>
#include <pthread.h>using std::cout;
using std::endl;
using std::string;const int num = 5;// 新线程
void* thread_run(void* args)
{string thread_name = static_cast<const char*>(args);// pthread_detach(tid); // 新线程也可以将自己分离出去for (int i = 0; i < num; i++){cout << thread_name << " 正在运行" << endl;sleep(1);}pthread_exit(nullptr);
}int main()
{// 创建新线程pthread_t tid;pthread_create(&tid, nullptr, thread_run, (void*)"thread 1");pthread_detach(tid); // 主线程将目标进程分离出去while (true){cout << "I am a main thread" << endl;sleep(1);}return 0;
}

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

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

相关文章

召回02 Swing 召回通道

为了避免小圈子重合却误判物品相似度很高&#xff1a;降低小圈子对相似度的影响。

cc2530按键中断实现控制LED

1开启中断的步骤 1-1使能端口组的中断 IEN1 IEN2 实例 IEN2 | 0x10 //使能P1口中断 1-2 端口中断屏蔽 P0IEN和P1IEN P2IEN 实例 P1IEN |0x10&#xff1b; //使能P1_2口中断 1-3设置触发方式 PICTL 实例 PICTL |0X02 ;//P1_3到P1_2口下降沿触发 1-4设置中断优先级…

Android 13 固定systemUI的状态栏为黑底白字,不能被系统应用或者三方应用修改

目录 一.背景 二.思路 三.代码流程 1.colos.xml自定义颜色 2.设置状态栏的背景颜色 3.对View进行操作 ①.对Clock(状态栏左侧的数字时钟)进行操作 ②.对电池(BatteryMeterView)进行操作 4.锁屏状态栏 5.patch汇总 一.背景 客户需求将状态栏固定成黑底白字,并且不能让系…

《SpringBoot+Vue》Chapter01_SpringBoot介绍

SpringBoot的介绍 简单来说&#xff0c;SpringBoot就是Spring提供的用于Web开发的脚手架框架。配置简单、上手快速 SpringBoot的特性 自带tomcat、Jetty服务器可以部署war包自动配置Spring框架和第三方框架能够提供应用的健康监控和配置的监控没有代码生成&#xff0c;并且尽可…

爬虫逆向学习(六):补环境过某数四代

声明&#xff1a;本篇文章内容是整理并分享在学习网上各位大佬的优秀知识后的实战与踩坑记录 引用博客&#xff1a; https://blog.csdn.net/shayuchaor/article/details/103629294 https://blog.csdn.net/qq_36291294/article/details/128600583 https://blog.csdn.net/weixin_…

C++_20_多态

多继承会造成 菱形继承** 使用虚继承来解决 不是给爷爷类加 也不是给子类加 是给父类加 虚基指针和虚基表 多态 概念&#xff1a; 概念&#xff1a; 一个事物的多种形态&#xff0c;简称多态 如&#xff1a; 对象的多态 ​ 张三 ​ 在对象面前 怂 ​ 在朋友面前 谄媚 ​ 在父…

python 读取excel数据存储到mysql

一、安装依赖 pip install mysql-connector-python 二、mysql添加表students CREATE TABLE students (ID int(11) NOT NULL AUTO_INCREMENT,Name varchar(50) DEFAULT NULL,Sex varchar(50) DEFAULT NULL,PRIMARY KEY (ID) ) ENGINEInnoDB AUTO_INCREMENT13 DEFAULT CHARSETu…

二十三种设计模式之原型模式

一.什么是原型模式 ‌‌原型模式是一种创建型对象设计模式&#xff0c;它通过复制一个已经创建的实例&#xff08;即原型对象&#xff09;来创建一个和原型对象相同的新对象。‌ 这种模式在面向对象软件设计中非常有用&#xff0c;因为它允许通过复制现有对象来快速生成多个相似…

springboot修改组件扫描包位置

步骤很详细&#xff0c;直接上教程 问题分析 默认情况下组件扫描包范围为启动类所在包及其子包 解决方法 我们只需要在启动类上面加个注解配置扫描范围 效果演示 温馨提示 非必要不建议修改&#xff0c;按规范创建项目结构一般不会出现这个问题

AI+代码审核平台CodeSec获CCIA中国网络安全创新创业大赛总决赛三等奖

近日&#xff0c;由中央网信办指导&#xff0c;中国网络安全产业联盟&#xff08;CCIA&#xff09;主办的2024年中国网络安全创新创业大赛总决赛及颁奖典礼在国家网络安全宣传周落下帷幕。开源网安“AI代码审核平台CodeSec V4.0” 凭借在AI方向的技术创新、技术突破及功能应用创…

热门远程控制工具大盘点,职场必备

如果你想要进行远程数据操作那向日葵远程控制软件你肯定听说过吧。如果你是想要远程运维&#xff0c;远程办公&#xff0c;数据传输&#xff0c;这些远程控制工具都可以实现。这次我将介绍几款我身边小伙伴都在使用的远程控制工具。 1.向日葵远程控制 链接直达&#xff1a;ht…

Python 数学建模——Prophet 时间序列预测

文章目录 前言原理使用方法&#xff08;初级&#xff09;代码实例Prophet 高级应用add_seasonality 添加自定义周期性add_regressor 添加外生变量交叉检验 前言 Prophet 是 Facebook 团队开发的一个时间序列分析工具&#xff0c;相比传统的 ARMA 时间序列分析&#xff0c;能够综…

常见 HTTP 状态码详解与Nginx 文件上传大小限制

在我们日常使用 Nginx 搭建网站或应用服务时&#xff0c;可能会遇到很多与文件上传和请求响应相关的问题。今天我们就来聊聊 如何限制文件上传的大小&#xff0c;并介绍一些常见的 HTTP 状态码 及其在 Nginx 中的处理方式。 一、文件上传大小限制 有时&#xff0c;我们需要限…

通过覆写 url_for 将 flask 应用部署到子目录下

0. 缘起 最近用 flask 写了一个 web 应用&#xff0c;需要部署到服务器上。而服务器主域名已经被使用了&#xff0c;只能给主域名加个子目录进行部署&#xff0c;比如主域名 example.org &#xff0c;我需要在 example.org/flask 下部署。这时 flask 应用里的内部连接们就出现…

github远程仓库环境搭建及使用

目录 1、创建一台虚拟机 centos 源的配置 备份源 修改源 重新加载缓存 安装软件 配置epel 2、关闭防火墙和selinux 关闭防火墙 临时关闭SELinux 永久关闭SELinux&#xff1a;编辑SELinux的配置文件 配置文件的修改内容 3、git是本地仓库&#xff0c;linux系统中一…

Qt常用控件——QDateTimeEdit

文章目录 QDateTimeEdit核心属性及信号时间计算器 QDateTimeEdit核心属性及信号 QDateEdit作为日期的微调框QTimeEdit作为时间的微调框QDateTimeEdit作为时间日期的微调框 它们的使用方式都是类似的&#xff0c;本篇以QDateTimeEdit作为示例 核心属性&#xff1a; 属性说明…

【秒达开源】多功能中文工具箱源码:自部署 全开源 轻量级跨平台 GPT级支持+高效UI+Docker

【秒达开源】多功能中文工具箱源码发布&#xff1a;自部署、全开源、轻量级跨平台&#xff0c;GPT级支持高效UI&#xff0c;Docker/便携版任选&#xff0c;桌面友好丰富插件生态 这是一款集大成之作&#xff0c;专为追求高效与便捷的用户量身打造。它不仅支持完全自部署&#…

远程访问电脑共享文件

远程访问电脑共享文件&#xff0c;可以通过多种方法实现&#xff0c;每种方法都有其特点和适用场景。以下是一些常见的方法及其步骤&#xff1a; 一、使用Microsoft远程桌面 启用远程桌面&#xff1a; 在目标电脑上&#xff0c;打开“开始”菜单&#xff0c;选择“设置”>“…

教育培训小程序开发,简单实用的入门指南

教育培训小程序可以帮助教育机构和个人老师提供更灵活的在线教学服务&#xff0c;满足学生的学习需求。对于初学者来说&#xff0c;开发一个功能齐全的教育培训小程序并不复杂&#xff0c;只需掌握一些基础的开发知识和工具即可。本文将带你了解如何使用微信小程序开发工具&…

SpringBoot开发——使用@Slf4j注解实现日志输出

文章目录 1、Lombok简介2、SLF4J简介3、实现步骤3.1 创建SpringBoot项目3.2 添加依赖3.3 使用 Slf4j 注解3.4 输出日志信息 4、结论 在现代Java开发中&#xff0c;日志记录是至关重要的。它不仅帮助开发者调试代码&#xff0c;还便于监控系统运行状态和性能。 Lombok 和 SLF4J …