Linux 第三十四章

🐶博主主页：@ᰔᩚ. 一怀明月ꦿ 

❤️‍🔥专栏系列：线性代数，C初学者入门训练，题解C，C的使用文章，「初学」C++，linux

🔥座右铭：“不要等到什么都没有了，才下定决心去做”

🚀🚀🚀大家觉不错的话，就恳求大家点点关注，点点小爱心，指点指点🚀🚀🚀

目录

封装线程

Linux线程互斥

加锁 

创建一个锁（互斥量）

pthread_mutex_lock(&mutex);加锁/pthread_mutex_unlock(&mutex);解锁

源码实现

封装线程

//开发方
#pragma once#include<iostream>
#include<string>
#include<functional>
#include<pthread.h>using namespace std;//typedef function<void()> func_t
template<class T>using func_t=function<void(T)>;template<class T>class Thread{
public:
Thread(func_t<T> func,const string& threadname,T data):_tid(0),_threadname(threadname),_isrunning(false),_func(func),_data(data)
{}static void* Threadroutine(void* args)//类内成员方法，其第一个参数是this指针，所以会导致编译错误//这里使用static，让Thraedroutine成为类的方法，
{
(void)args;//仅仅是为了消除警告，变量未使用Thread* ts=static_cast<Thread*>(args);ts->_func(ts->_data);
return nullptr;}bool Start(){
int n=pthread_create(&_tid,nullptr,Threadroutine,this);//把当前对象传递给线程执行的方法if(n==0)
{
_isrunning=true;
return true;}
else return false;}bool Join(){
if(!_isrunning)return true;int n=pthread_join(_tid,nullptr);if(n==0)
{
_isrunning=false;
return true;}
return false;}bool Isrunning(){
return _isrunning;}string Threadname(){
return _threadname;}
private:
pthread_t _tid;string _threadname;bool _isrunning;func_t<T> _func;T _data;};//应用方
#include<iostream>
#include"thread.hpp"
#include<unistd.h>
#include<vector>void Print(int num){
while(num)
{
cout<<"hello world :"<<num--<<endl;
sleep(1);
}
}string Getthreadname(){
static int number=1;//全局变量char name[64];snprintf(name,sizeof(name),"Thread-%d",number++);
return name;}int main(){
//**1**
// Thread t(Print,Getthreadname());
// cout<<"is thread running?"<<t.Isrunning()<<endl;
// t.Start();
// cout<<"is thread running?"<<t.Isrunning()<<endl;
// t.Join();//**2**
// const int num=5;
// vector<Thread> threads;// for(int i=0;i<num;i++)
// {
// Thread t(Print,Getthreadname());
// threads.push_back(t);
// }// for( auto& thread:threads)
// {
// cout<<thread.Threadname()<<"is running: "<<thread.Isrunning()<<endl;
// }// for(auto& thread:threads)
// {
// thread.Start();
// }// for( auto& thread:threads)
// {
// cout<<thread.Threadname()<<"is running: "<<thread.Isrunning()<<endl;
// }// //不让主线程退出，让主线程等待子线程
// for( auto& thread:threads)
// {
// thread.Join();
// }//**3**Thread<int> t(Print,Getthreadname(),10);t.Start();
t.Join();return 0;}

Linux线程互斥

1.直接实验？（不确定性高）

多线程抢票的逻辑

抢票系统

Thread-4 get a ticket:0 

Thread-1 get a ticket:-1 

Thread-2 get a ticket:-2 

票被抢到负数是不合理的

2.看到现象—输出概念

1）数据不一致，共享资源（票）

2）任何一个时刻，只允许一个线程正在访问的资源——临界资源（互斥）

3）我们把我们进程中访问临界资源的代码——临界区（被保护起来的重点区域）

4）互斥：任何时刻，互斥保证有且只有一个执行流进入临界区，访问临界资源，通常对临界资源起保护作用

3.解释问题

int cnt=0;

cnt++; 

这种操作不是原子的

抢票中的临界区

抢票中的临界区
int ticket = 10000;
void Getticket(string name)
{
while (true)
{
if (ticket > 0)//判断ticket也是计算
{
usleep(1000); // 模拟抢票的话费时间
printf("%s get a ticket:%d \n", name.c_str(), ticket);
ticket—;//在汇编层面，会执行三步
//我的理解：读是在每个线程的上下文数据中，—是在内存中
}
else
break;
}
// 实际情况还有后续的动作
}

CPU的基本功能
算：算数运算
逻：逻辑运算
中：处理内外中断
控：控制单元

加锁 

加锁（牺牲效率为代价的，解决安全性问题）

1.我们要尽可能的给少的代码加锁

2.一般加锁，都是给临界区加锁

根据互斥的定义，任何时刻，只允许一个线程申请锁成功！多个线程申请锁的失败，失败的线程怎么办？在mutex上阻塞，（等待其他线程释放掉锁，再被唤醒申请锁）

申请锁本身是安全的，原子的（只能一个线程申请成功）

一个线程在临界区中访问临界资源的时候，可不可能发生切换？

可能，完全允许，因为该线程被切换，但是没有解锁，其他线程就申请不到锁，只能被阻塞（就不会发生并发访问数据不一致的问题）

创建一个锁（互斥量）

pthread_mutex_t mutex;

pthread_mutex_lock(&mutex);加锁/pthread_mutex_unlock(&mutex);解锁

在Linux系统中，pthread_mutex_lock 是一个 POSIX 线程库提供的函数，用于加锁互斥量（mutex）。它的作用是尝试锁定一个互斥量，如果这个互斥量已经被其他线程锁定了，则调用线程会被阻塞直到获取到该互斥量为止。

事例

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
pthread_mutex_t mutex;int shared_data = 0;//公共资源void* thread_function(void* arg) {// 加锁pthread_mutex_lock(&mutex);// 访问共享资源shared_data++;printf("Thread ID %ld, shared data: %d\n", pthread_self(), shared_data);// 解锁pthread_mutex_unlock(&mutex);return NULL;
}int main() {pthread_t tid1, tid2;// 初始化互斥量if (pthread_mutex_init(&mutex, NULL) != 0) {perror("Mutex initialization failed");exit(EXIT_FAILURE);}// 创建线程pthread_create(&tid1, NULL, thread_function, NULL);pthread_create(&tid2, NULL, thread_function, NULL);// 等待线程结束pthread_join(tid1, NULL);pthread_join(tid2, NULL);// 销毁互斥量pthread_mutex_destroy(&mutex);return 0;
}
在上面的示例中，我们首先创建了一个互斥量 pthread_mutex_t mutex，并在主线程中初始化它。然后创建了两个线程，它们会执行 thread_function 函数。在 thread_function 中，通过调用 pthread_mutex_lock 来锁定互斥量，确保对 shared_data 的访问是互斥的，然后进行相应操作，最后再用 pthread_mutex_unlock 解锁。
这样就确保了在任意时刻只有一个线程能够访问 shared_data，避免了数据竞争问题。请注意，对于互斥量的使用需要谨慎处理，以避免死锁等问题。

源码实现

main

#include <iostream>#include "thread.hpp"#include <unistd.h>#include <vector>void Print(int num){
while (num){
cout << "hello world :" << num-- << endl;sleep(1);
}
}string Getthreadname(){
static int number = 1; // 全局变量char name[64];snprintf(name, sizeof(name), "Thread-%d", number++);return name;}int ticket = 10000;pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; // 锁有了，被定义初始化，这是一把全局的锁// 加锁（牺牲效率为代价的，解决安全性问题）
// 1.我们要尽可能的给少的代码加锁
// 2.一般加锁，都是给临界区加锁
void Getticket(string name){
while (true){
// 加锁
// 根据互斥的定义，任何时刻，只允许一个线程申请锁成功！多个线程申请锁的失败，失败的线程怎么办？在mutex上阻塞，（等待其他线程释放掉锁，再被唤醒申请锁）
pthread_mutex_lock(&mutex); // 申请锁本身是安全的，原子的（只能一个线程申请成功）// 一个线程在临界区中访问临界资源的时候，可不可能发生切换？
// 可能，完全允许，因为该线程被切换，但是没有解锁，其他线程就申请不到锁，只能被阻塞
//
if (ticket > 0){
usleep(1000); // 模拟抢票的话费时间printf("%s get a ticket:%d \n", name.c_str(), ticket);ticket--;
// 解锁
pthread_mutex_unlock(&mutex);
}
else
{
// 解锁
pthread_mutex_unlock(&mutex);
break;
}
}
// 实际情况还有后续的动作
}int main(){
string name1 = Getthreadname();Thread<string> t1(name1, Getticket, name1);string name2 = Getthreadname();Thread<string> t2(name2, Getticket, name2);string name3 = Getthreadname();Thread<string> t3(name3, Getticket, name3);string name4 = Getthreadname();Thread<string> t4(name4, Getticket, name4);t1.Start();
t2.Start();
t3.Start();
t4.Start();t1.Join();
t2.Join();
t3.Join();
t4.Join();
return 0;}

thread.hpp

#pragma once#include<iostream>
#include<string>
#include<functional>
#include<pthread.h>using namespace std;//typedef function<void()> func_t
template<class T>using func_t=function<void(T)>;template<class T>class Thread{
public:
Thread(const string& threadname,func_t<T> func,T data):_tid(0),_threadname(threadname),_isrunning(false),_func(func),_data(data)
{}static void* Threadroutine(void* args)//类内成员方法，其第一个参数是this指针，所以会导致编译错误//这里使用static，让Thraedroutine成为类的方法，
{
(void)args;//仅仅是为了消除警告，变量未使用Thread* ts=static_cast<Thread*>(args);ts->_func(ts->_data);
return nullptr;}bool Start(){
int n=pthread_create(&_tid,nullptr,Threadroutine,this);//把当前对象传递给线程执行的方法if(n==0)
{
_isrunning=true;
return true;}
else return false;}bool Join(){
if(!_isrunning)return true;int n=pthread_join(_tid,nullptr);if(n==0)
{
_isrunning=false;
return true;}
return false;}bool Isrunning(){
return _isrunning;}string Threadname(){
return _threadname;}
private:
pthread_t _tid;string _threadname;bool _isrunning;func_t<T> _func;T _data;};

进程是资源的分配单位，所以线程并不拥有系统资源，而是共享使用进程的资源，进程的资源由系统进行分配


pthread_self() 用于获取用户态线程的tid，而并非轻量级进程ID

主线程调用pthread_cancel(pthread_self())函数来退出自己， 则主线程对应的轻量级进程状态变更成为Z， 其他线程不受影响，这是正确的（正常情况下我们也不会这么做....）
主线程调用pthread_exit只是退出主线程，并不会导致进程的退出

 🌸🌸🌸如果大家还有不懂或者建议都可以发在评论区，我们共同探讨，共同学习，共同进步。谢谢大家！ 🌸🌸🌸   

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

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

相关文章

基础之音视频2

基础之音视频2

01 前言 02 mp 03 mp实例 简易音乐播放器 04 音频 sound-pool 1.作用 播放多个音频&#xff0c;短促音频 2.过程 加载load- 3.示例 模拟手机选铃声 步骤&#xff1a; 创建SoundPool对象&#xff0c;设置相关属性 音频流存入hashmap 播放音频 05 videoview 3gp 体积小 mp4 …
阅读更多...
掌握Linux常用命令，扫平面试需求障碍

掌握Linux常用命令，扫平面试需求障碍

cd 切换目录。 > cd ../ #切换到父级目录 > cd /tmp # 切换到/tmp目录 > cd ~ # 切换到当前用户的家目录 ls命令 查看文件与目录的命令&#xff0c;list 的缩写。 > ls -l #列出长数据串&#xff0c;包含文件的属性与权限数据等 > ls -a #列出隐藏…
阅读更多...
Oracle 自治数据库 Select AI 初体验

Oracle 自治数据库 Select AI 初体验

这几天有点时间&#xff0c;准备尝试下Oracle Select AI&#xff0c;虽然此功能2023年就已经发布了。 Oracle自治数据库已经集成好了Select AI&#xff0c;本文也是讲的这个。 配置 Select AI 需要以下步骤&#xff1a; 创建ADB申请Cohere/OpenAI免费账号设置ADB测试Select…
阅读更多...
NSSCTF | [SWPUCTF 2021 新生赛]ez_unserialize

NSSCTF | [SWPUCTF 2021 新生赛]ez_unserialize

打开题目&#xff0c;发现是一个GIF动图页面&#xff0c;什么都没有。我们来查看一下源代码&#xff0c;看看有没有什么发现 其实只要足够了解网站的构成&#xff0c;看到绿色的注释字样就能知道它这里在提示robots.txt文件。 但是对于小白来说&#xff0c;也不知道它是什么&a…
阅读更多...
2、快速搭建Vue框架以及项目工程

2、快速搭建Vue框架以及项目工程

本篇文章详细讲解在配置完vue2环境后如何快速搭建一个Vue框架和项目工程。&#xff08;以智慧农业云平台为例&#xff09; 2.1 Vue工程创建 2.1.1创建想要存放的Vue文件夹 找到想要存放的文件夹并在目录搜索框中&#xff0c;并用管理员的方式打开。 2.1.2创建Vue工程 2、安装…
阅读更多...
Shopline和Shopify哪个更好？Shopline和Shopify的区别

Shopline和Shopify哪个更好？Shopline和Shopify的区别

Shopline和Shopify哪个更好取决于用户面向的市场&#xff0c;面向亚洲市场就更适合有本地化支持的Shopline&#xff0c;而如果希望拓展全球业务&#xff0c;Shopify可能更好。 Shopline和Shopify都是知名的电子商务平台&#xff0c;可以很好的帮助商家搭建和管理在线商店&…
阅读更多...
软件测试常见面试题合集（内附详细答案）

软件测试常见面试题合集（内附详细答案）

01 软件测试理论部分 1.1 测试概念 1. 请你分别介绍一下单元测试、集成测试、系统测试、验收测试、回归测试 单元测试&#xff1a;完成最小的软件设计单元&#xff08;模块&#xff09;的验证工作&#xff0c;目标是确保模块被正确的编码 集成测试&#xff1a;通过测试发现与…
阅读更多...
Milvus的存储/计算分离

Milvus的存储/计算分离

前言 根据数据面与控制面相隔离的原则&#xff0c;从可扩展性和灾难恢复来看&#xff0c;Milvus由4个相互独立的层组成 访问层 由一系列无状态的代理组成&#xff0c;访问层是系统和用户之间的第一层&#xff0c;它主要是验证客户端请求和规整返回的结果 代理是无状态的&am…
阅读更多...
点量云流分享：关于实时渲染云推流技术

点量云流分享：关于实时渲染云推流技术

提到云串流或者云推流很多人可能和游戏关联起来&#xff0c;其实这个技术的应用领域不仅仅是游戏&#xff0c;还有云上旅游、考古、智慧园区、智慧城市、虚拟仿真等等行业。其解决的问题是将一些大型的3D应用程序放在云端&#xff0c;程序在运行的时候也是在云端&#xff0c;这…
阅读更多...
【Win】一键恢复IE11工具：让旧版浏览器在新系统中重生

【Win】一键恢复IE11工具：让旧版浏览器在新系统中重生

微软在2020年8月的时候就已经公告IE11的生命周期终点&#xff0c;多次提醒将在2022年6月15日起不再支持IE 11&#xff0c;呼吁用户尽快转换到Chromium-based Microsoft Edge。微软也陆续终止旗下服务支持这个旧式浏览器。2021年3月&#xff0c;Chrome浏览器已不支持旧IE App。2…
阅读更多...
学习Nginx（一）：基础

学习Nginx（一）：基础

介绍 Nginx是一个高性能的HTTP和反向代理的web服务器&#xff0c;它的设计重点是高并发、高性能和低内存消耗。它常被用于提供静态内容、负载均衡和作为Web服务器。 Nginx具有以下功能和特点&#xff1a; 静态文件服务&#xff1a;作为一个Web服务器&#xff0c;Nginx可以处…
阅读更多...
vue3专栏项目 -- 四、前后端结合（上）

vue3专栏项目 -- 四、前后端结合（上）

一、前后端分离是什么 前面我们一直在和静态数据打交道&#xff0c;虽然流程可以跑个半通&#xff0c;但是静态数据还是给我们造成了诸多不便&#xff0c;现在我们是时候用上后端了。 现在的应用开发模式&#xff0c;自从SPA出现以后&#xff0c;前端和后端可以平行的进行对应…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023