Linux——多线程(四)

前言

 这是之前基于阻塞队列的生产消费模型中Enqueue的代码

    void Enqueue(const T &in) // 生产者用的接口{pthread_mutex_lock(&_mutex);while(IsFull())//判断队列是否已经满了{pthread_cond_wait(&_product_cond, &_mutex); //满的时候就在此情况下等待// 1. pthread_cond_wait调用是: a. 让调用进程等待 b. 自动释放曾经持有的_mutex锁}// 进行生产_bq.push(in);// 通知消费者来消费pthread_cond_signal(&_consumer_cond);pthread_mutex_unlock(&_mutex);}

缺点:

当一个线程往阻塞队列中插入时,必须要满足一个条件"临界资源还没满",否则就需要放到条件变量的等待队列中去。

而判断临界资源是否为满需要先申请锁(检测临界资源的本质也是在访问临界资源),然后再进入临界区访问临界资源,才能判断临界资源是否为满。

那么只要我们对临界资源整体加锁,就默认会对这个临界资源整体使用(吗?)。实际上可能是:一份临界资源被划分为多个不同的区域,而且运行多个线程同时访问不同的区域。

 在访问临界资源之前,我们无法知道临界资源的情况。

多个线程不能同时访问临界资源的不同区域。

1.信号量

1.1信号量的概念 

我们之前在学进程间通信时,简单介绍过信号量。 

信号量:信号量本质其实是一计数器,这一计数器的作用是用来描述临界资源中资源数量的多少

申请信号量的本质其实就是:对临界资源中特定的小块资源预定机制。(资源不一定被我持有,才是我的,只要我预定了,在未来的某个时间,就是我的)

 信号量也是一种互斥量,只要申请到信号量的线程,在未来一定能够拥有一份临界资源。

假如要让多个线程同时去访问一块划分为n个区域的临界资源:

创建一个信号量,值为n

每来一个访问临界资源的线程都要先去申请信号量(信号量的值,n--),申请后才能访问

当n被减到0时说明临界资源中各个区域都有线程在访问资源,其它想要访问临界资源的线程就得阻塞等待,等这n个区域中的某个线程访问完将这个区域空出来才行(信号量的值,n++)

信号量解决了上面提到的问题:

线程不用访问临界资源就能知道资源的使用情况 (信号量申请成功就一定有资源可以使用,申请失败则说明条件不满足,只能阻塞等待)

注意:所有线程都得能看到信号量,信号量是一个公共资源,涉及到线程安全问题

信号量的基本操作就是对信号量进行++或--,而这两个操作时原子的

P操作:信号量--,就是在申请资源(此操作必须时原子的)

V操作:信号量++,返回资源(此操作也需是原子的)

1.2信号量的接口

信号量的使用需要引头文件:semaphore.h;还需要链接原生线程库-pthread 

sem_t sem;//创建信号量

初始化信号量

man sem_init

 参数:

sem:信号量指针

pshared:0表示线程间共享,非0表示进程间共享。(一般情况下为0)

value:信号量初始值,也就是计数器的值

返回值:类型int,成功返回0,失败返回-1,并将 errno 设置为指示错误

申请信号量,P操作,计数器--

man sem_wait

参数

sem:信号量指针

返回值:成功返回0,失败返回-1,设置errno

发布信号量,V操作,计数器++

man sem_post

参数

sem:信号量指针

返回值:成功返回0,失败返回-1,设置errno

信号量销毁

man sem_destroy

参数

sem:信号量指针

返回值:成功返回0,失败返回-1,设置errno

 2.基于环形队列的生产者消费者模型

POSIX信号量和SystemV信号量作用相同,都是用于同步操作,达到无冲突的访问共享资源的目的,但是POSIX可用于线程间同步

2.1分析

环形队列

 这里的环形队列用数组来模拟,取模来模拟其环状特性

当环形队列为空时,头尾都指向同一个位置;当环形队列为满时,头尾也指向同一个位置。这样不好判断为空或为满,可以通过加计数器或者标记位来判断满或空,也可以预留一个空位,作为满状态

但是我们现在有信号量这个计数器,就很简单的进行多线程间的同步过程

单生产和单消费两线程在访问环形队列时,生产者负责向环形队列中生产数据,消费者负责从环形队列中消费数据。

那么生产者和消费者什么时候会访问同一个位置呢?当环形队列为空/为满的时候

那么如果环形队列一定不为空&&一定不为满时,生产者、消费者的下标指向不是同一个位置

生产和消费的动作可以真正并发吗?是的 

环形队列的生产者消费者模型还需要两个必要条件:

1.生产者不能把消费者超过一个圈以上(当环形队列满了后,生产者继续生产,那么生产者生产的数据会覆盖消费者还未消费的,消费者就无法消费被覆盖的数据了)

2.消费者不能超过生产者(生产者还没生产,消费者无法消费。当消费者超过生产者时,消费者访问的区域无数据)

对于生产者而言,它最关心的是空间

空间资源可以定义一个信号量,用来统计空闲空间的个数

对于消费者而言,它最关心的是数据

数据资源也可以用一个信号量来统计数据个数

所以生产者每次访问临界资源之前,需要先申请空间资源的信号量,申请到才可以进行生产,不然就得老实的阻塞等待

消费者也一样,访问临界资源之前,要先申请数据资源的信号量,申请成功才能够去消费数据,不然还是阻塞等待

空间资源信号量的申请(P)由生产者进行,归还(V)由消费者进行

数据资源信号量的申请(P)由消费者进行,归还(V)由生产者进行

伪代码

生产者

P(room);//申请空间资源

//信号量申请成功,继续向下运行;失败则阻塞

ringbuffer[p_index] = x;

p_index++;

p_index%=10;

V(data);

消费者

P(data);//申请数据资源

//信号量申请成功——数据资源一定存在

out = ringbuffer[c_index];

c_index++;

c_index%=10;\

V(room);

2.2代码

ringqueue.hpp

#include <iostream>
#include <string>
#include <vector>
#include <semaphore.h>
#include <pthread.h>template<typename T>
class RingQueue
{
private:void P(sem_t &sem)//申请信号量P操作{sem_wait(&sem);}void V(sem_t &sem)//发布信号量V操作{sem_post(&sem);}void Lock(pthread_mutex_t &mutex)//加锁{pthread_mutex_lock(&mutex);}void UnLock(pthread_mutex_t &mutex)//解锁{pthread_mutex_unlock(&mutex);}
public:RingQueue(int cap):_rq(cap),_cap(cap),_productor_step(0),_consumer_step(0){sem_init(&_room_sem,0,_cap);sem_init(&_data_sem,0,0);pthread_mutex_init(&_productor_mutex,nullptr);pthread_mutex_init(&_consumer_mutex,nullptr);}void Enqueue(const T&in){P(_room_sem);Lock(_productor_mutex);//开始生产_rq[_productor_step] = in;_productor_step %= _cap;//环形队列UnLock(_productor_mutex);V(_data_sem);}void Pop(T *out){P(_data_sem);Lock(_consumer_mutex);//消费*out = _rq[_consumer_step];_consumer_step++;_consumer_step%=_cap;UnLock(_consumer_mutex);V(_room_sem);}~RingQueue(){sem_destroy(&_room_sem);sem_destroy(&_data_sem);pthread_mutex_destroy(&_productor_mutex);pthread_mutex_destroy(&_consumer_mutex);}
private:std::vector<T> _rq;int _cap;int _productor_step;//生产者步数int _consumer_step;//消费者步数//定义信号量sem_t _room_sem;//空间信号量,生产者关心sem_t _data_sem;//数据信号量,消费者关心//锁pthread_mutex_t _productor_mutex;pthread_mutex_t _consumer_mutex;
};

thread.hpp

#include<iostream>
#include<signal.h>
#include<unistd.h>
#include<functional>
#include<pthread.h>namespace Thread_Module
{template <typename T>using func_t = std::function<void(T&)>;// typedef std::function<void(const T&)> func_t;template <typename T>class Thread{public:void Excute(){_func(_data);}public:Thread(func_t<T> func,T &data,const std::string &threadname = "none"):_threadname(threadname),_func(func),_data(data){}static void* threadrun(void *args)//线程函数{Thread<T> *self = static_cast <Thread<T>*>(args);self->Excute();return nullptr;}bool Start()//线程启动!{int n = pthread_create(&_tid,nullptr,threadrun,this);if(!n)//返回0说明创建成功{_stop = false;//说明线程正常运行return true;}else{return false;}}void Stop(){_stop = true;}void Detach()//线程分离{if(!_stop){pthread_detach(_tid);}}void Join()//线程等待{if(!_stop){pthread_join(_tid,nullptr);}}std::string threadname()//返回线程名字{return _threadname;}~Thread(){}private:pthread_t _tid;//线程tidstd::string  _threadname;//线程名T &_data;//数据func_t<T> _func;//线程函数bool _stop; //判断线程是否停止 为true(1)停止,为false(0)正常运行};
}

main.cc

#include "ringqueue.hpp"
#include "Thread.hpp"
#include<string>
#include<vector>
#include<unistd.h>
#include<functional>
#include<pthread.h>using namespace Thread_Module;void* consumer(RingQueue<int> &rq)
{while(true){int data;rq.Pop(&data);std::cout<<"消费一个数据:"<<data<<std::endl;sleep(1);}  
}void* productor(RingQueue<int> &rq)
{   int a = 1;while(true){rq.Enqueue(a);std::cout<<"生产一个数据 :"<<a<<std::endl;a++;}
}void Comm(std::vector<Thread<RingQueue<int>>> *threads,int num,RingQueue<int> &rq,func_t<RingQueue<int>> func)
{for(int i=0;i<num;i++){std::string name = "thread-"+std::to_string(i+1);threads->emplace_back(func,rq,name);}
}void ProductorStart(std::vector<Thread<RingQueue<int>>> *threads,int num,RingQueue<int> &rq)
{Comm(threads,num,rq,productor);
}void ConsumerStart(std::vector<Thread<RingQueue<int>>> *threads,int num,RingQueue<int> &rq)
{Comm(threads,num,rq,consumer);
}void StartAll(std::vector<Thread<RingQueue<int>>> &threads)
{for(auto &thread:threads){std::cout<<"Start:"<<thread.threadname()<<std::endl;thread.Start();}
}void WaitAllThread(std::vector<Thread<RingQueue<int>>> &threads)
{for(auto &thread:threads){thread.Join();}
}int main()
{RingQueue<int> *rq = new RingQueue<int>(10);std::vector<Thread<RingQueue<int>>> threads;ProductorStart(&threads,1,*rq);ConsumerStart(&threads,2,*rq);StartAll(threads);WaitAllThread(threads);return 0;
}

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

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

相关文章

C++中的模板(一)

首先&#xff0c;我们做一个简单的假设&#xff1a;假如现在你有穿越回古代的机会&#xff0c;然而你在古代的身份是曹植的管家&#xff0c;这天曹植写了一首《洛神赋》&#xff0c;他命令你把这首诗广泛的传播出去&#xff0c;那么在当时的技术条件下&#xff0c;你只能先制作…

自定义刷题工具-python实现

背景&#xff1a; 最近想要刷题&#xff0c;虽然目前有很多成熟的软件&#xff0c;网站。但是能够支持自定义的导入题库的非常少&#xff0c;或者是要么让你开会员&#xff0c;而直接百度题库的话&#xff0c;正确答案就摆在你一眼能看见的地方&#xff0c;看的时候总觉得自己…

Gymnasium 借游戏来学习人工智能

既然有了免费的linux系统GPU&#xff0c;干脆演示一下使用drivecolab套件来训练模型。 !apt-get install -y build-essential swig !pip install box2d-py !pip install gymnasium[all] !pip install gymnasium[atari] gymnasium[accept-rom-license] !pip install stable_bas…

dify/api/models/task.py文件中的数据表

源码位置&#xff1a;dify/api/models/task.py CeleryTask 表结构 字段英文名数据类型字段中文名字备注idIntegerID自增主键&#xff0c;任务ID序列task_idString任务ID唯一任务标识statusString状态默认值为 PENDINGresultPickleType结果可为空date_doneDateTime完成日期默认…

OJ-0709

示例&#xff1a; 输入&#xff1a; 5 100 10 10 20 30 40 50 3 4 5 6 10 20 30 20 40 30 输出&#xff1a; 0 30 0 40 0import java.util.Scanner;public class Main {public static void main(String[] args) {Scanner scanner new Scanner(System.in);int number scanner…

项目收获总结--Redis的知识收获

一、概述 最近几天公司项目开发上线完成&#xff0c;做个收获总结吧~ 今天记录Redis的收获和提升。 二、Redis异步队列 Redis做异步队列一般使用 list 结构作为队列&#xff0c;rpush 生产消息&#xff0c;lpop 消费消息。当 lpop 没有消息的时候&#xff0c;要适当sleep再…

2024.7.9总结(找对象的逻辑)

今天口语表达训练5分钟&#xff0c;阅读1h,然后电脑坏了&#xff0c;学python计划估计是完不成了。 然后&#xff0c;今天想聊聊毕业后要不开的两件事&#xff0c;工作和找对象。事业是前期最应该关注和重视的&#xff0c;但找对象结婚关乎后半生的幸福&#xff0c;也不能不做…

SSL证书到期自动巡检脚本-推送钉钉告警

1. 编写SSL证书巡检脚本 cat /hao/batch_check_ssl_expire.sh #!/bin/bash# 域名列表文件绝对路径 domains_file"/hao/domains.txt"#钉钉webhook webhook_url"https://oapi.dingtalk.com/robot/send?access_token99999999999999999999999999999999999999999…

深度学习pytorch多机多卡网络配置桥接方法

1 安装pdsh&#xff08;Parallel Distributed Shell&#xff09; sudo apt install pdsh sudo -s # 切换超级用户身份 …

oracle查询出表中某几个字段值不唯一的数据

假设有一张学生表&#xff0c;建表语句如下&#xff1a; --学生 student表 create table student( sno varchar2(10) primary key, sname varchar2(20), sage number(2), ssex varchar2(5), birthday date );现计划创建唯一索引&#xff08;sno&#xff0c;sname&#xff09;&…

决策树构建精要:算法步骤与实现细节

决策树构建&#xff1a;算法流程与步骤 决策树是一种强大的机器学习算法&#xff0c;用于分类和回归问题。下面将详细介绍决策树的构建流程和具体步骤&#xff0c;帮助您理解并实现决策树算法。 1. 算法流程 决策树的构建流程可以概括为以下几个主要步骤&#xff1a; 特征选…

如何查看Impala集群的状态和日志

查看Impala集群状态 使用Impala Shell 登录到任何集群节点&#xff0c;通过Impala Shell可以查询集群状态。执行命令 invalidate metadata; 可以强制Impala重新加载元数据&#xff0c;有助于识别任何元数据同步问题。此外&#xff0c;可以运行简单的SQL查询&#xff08;如 SEL…

MATLAB备赛资源库(1)建模指令

一、介绍 MATLAB&#xff08;Matrix Laboratory&#xff09;是一种强大的数值计算环境和编程语言&#xff0c;特别设计用于科学计算、数据分析和工程应用。 二、使用 数学建模使用MATLAB通常涉及以下几个方面&#xff1a; 1. **数据处理与预处理**&#xff1a; - 导入和处理…

Redis 中的跳表(Skip List)

Redis 中的跳表&#xff08;Skip List&#xff09;是一种用于实现有序集合&#xff08;Sorted Set&#xff09;的数据结构。跳表是一种非平衡的、概率性的数据结构&#xff0c;它提供了与平衡树类似的性能&#xff0c;但在实现上更简单&#xff0c;通常更容易理解和编码。跳表的…

模型计算量 MAC/FLOPs 的手动统计方法

文章目录 简介背景为什么理解神经网络中的MAC和FLOPs很重要&#xff1f;资源效率内存效率能耗功耗效率 模型优化性能基准研究与发展 FLOPs 和 MACs 定义1. 全连接层 FLOPs 计算步骤 1&#xff1a;识别层参数步骤 2&#xff1a;计算 FLOPs 和 MACs步骤 3&#xff1a;总结结果使用…

行列视(RCV)是否支持批量共享和自定义共享设置,以提高共享效率?

行列视&#xff08;RCV&#xff09;确实支持批量共享和自定义共享设置&#xff0c;以提高共享效率。以下是根据参考文章信息&#xff0c;对RCV在共享功能方面的详细说明&#xff1a; 1. 批量共享&#xff1a; - RCV系统支持大规模数据或报表的共享&#xff0c;这意味着用户可以…

Echarts实现github提交记录图

最近改个人博客&#xff0c;看了github的提交记录&#xff0c;是真觉得好看。可以移植到自己的博客上做文章统计 效果如下 代码如下 <!DOCTYPE html> <html lang"en" style"height: 100%"><head><meta charset"utf-8"> …

240709_昇思学习打卡-Day21-文本解码原理--以MindNLP为例

240709_昇思学习打卡-Day21-文本解码原理–以MindNLP为例 今天做根据前文预测下一个单词&#xff0c;仅作简单记录及注释。 一个文本序列的概率分布可以分解为每个词基于其上文的条件概率的乘积 &#x1d44a;_0:初始上下文单词序列&#x1d447;: 时间步当生成EOS标签时&a…

企业级网关设计

tips&#xff1a;本文完全来源于卢泽龙&#xff01;&#xff01;&#xff01; 一、Gateway概述 1.1设计目标 1.2gateway基本功能 中文文档参考&#xff1a;https://cloud.tencent.com/developer/article/1403887?from15425 三大核心&#xff1a; 二、引入依赖和yaml配置…

Interpretability 与 Explainability机器学习

在机器学习的范畴中&#xff0c;“Interpretability”&#xff08;可解释性&#xff09;和“Explainability”&#xff08;可解释性&#xff09;尽管在含义上有重叠部分&#xff0c;但仍存在一些微妙的差异和重点的不同。 “Interpretability”主要强调模型自身的结构和运作方式…