【Linux】POSIX版本 信号量

2024-08-29 03:52
文章标签 linux 信号量 版本 posix

本文主要是介绍【Linux】POSIX版本 信号量,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

信号量的基本操作

基于信号量和环形队列的生产消费模型


之前我们在System V版本的进程间通信说过信号量,这里我们说的是POSIX(Portable Operating System Interface for uniX  可移植操作系统接口)版本的并且会说的更加详细

我们之前对于信号量也有一定的理解,我们说它就是要给计数器,用来记录所需资源的数量,因为这个计数器是被多个线程所共享的,所以它本身就是共享资源,为了保证共享资源的安全,所以我们说PV(对计数器--和++)操作是原子的

今天我们还是想用信号量实现生产消费模型,之前我们使用阻塞队列当作生产者和消费者之间的缓冲区,并且这个阻塞队列同时只允许一个线程进入,我们就可以把阻塞队列认为成只有一个位置的信号量,也就是计数器为一

可实际上计数器不一定为一,它可以很大,那么此时我们应该用什么去充当存放任务的容器呢?我们可以选用环形队列,那么我们首先就需要了解一些环形队列的性质,比如我们有p(producer)和c(consumer),它们分别位于环形队列的某一位置,我们可以知道,队列为空和为满时,p、c位于同一位置,也就是说,如果p、c位于不同位置,那么环形队列一定既不为空,也不为满。这时是不是就不会像阻塞队列一样只同时允许一个线程进入了呢,而是一个生产者和一个消费者可以同时进入环形队列。因为不为空不为满时它们一定访问的是不同的位置。这样生产和消费就可以实现真正的并发;如果为空时就让生产者先跑;为满时就让消费者先跑。

也就是说:生产者不能套消费者圈,消费者不能超过生产者

那么我们如何实现上面的东西呢?就是基于信号量

信号量的基本操作

我们需要首先创建一个信号量,就用创建变量的形式去创建就可以

其次要对信号量进行初始化

man sem_init

第二个参数给0,第三个参数是想让计数器是几就填几

申请出信号量要对信号量进行PV操作

man sem_wait

man sem_post

最后要销毁信号量

man sem_destroy

以上就是关于信号量的一些操作,下面我们就实现基于信号量和环形队列的生产消费模型

基于信号量和环形队列的生产消费模型

//Main.cc#include"RingQueue.hpp"
#include"Task.hpp"
#include"MyThread.hpp"
using namespace MyThread;
#include<vector>
#include<unistd.h>
using namespace std;
void Producercode(RingQueue<Task_t>*prq,string name)
{while(1){sleep(1);prq->Enqueue(print);cout<<name<<" produce a task"<<endl;}}
void Consumercode(RingQueue<Task_t>*prq,string name)
{sleep(10);while(1){sleep(1);Task_t t;prq->Pop(&t);cout<<name<<" get a task...";t();}
}
void InitProducer(vector<Thread<RingQueue<Task_t>*>>&threads,int num,RingQueue<Task_t>*prq)
{for(int i=1;i<=num;i++){string name="producer thread-"+to_string(i);threads.emplace_back(Producercode,prq,name);}}
void InitConsumer(vector<Thread<RingQueue<Task_t>*>>&threads,int num,RingQueue<Task_t>*prq)
{for(int i=1;i<=num;i++){string name="consumer thread-"+to_string(i);threads.emplace_back(Consumercode,prq,name);}
}
void StartAll(vector<Thread<RingQueue<Task_t>*>>&threads)
{for(auto&e:threads)e.start();
}
void WaitAll(vector<Thread<RingQueue<Task_t>*>>&threads)
{for(auto&e:threads)e.join();
}
int main()
{RingQueue<Task_t> rq(5);vector<Thread<RingQueue<Task_t>*>>threads;//要把环形队列指针传给各个线程InitProducer(threads,3,&rq);InitConsumer(threads,4,&rq);StartAll(threads);WaitAll(threads);return 0;
}
//RingQueue.hpp#include <iostream>
#include <vector>
#include <semaphore.h>
#include <pthread.h>
template <class T>
class RingQueue
{
public:RingQueue(int cap = 10): _ring_queue(cap), _cap(cap), _producer_step(0), _consumer_step(0){sem_init(&_room_sem, 0, _cap);sem_init(&_data_sem, 0, 0);pthread_mutex_init(&_producer_mutex, nullptr);pthread_mutex_init(&_consumer_mutex, nullptr);}void Enqueue(const T &in){sem_wait(&_room_sem);//对空间进行--操作(P操作)pthread_mutex_lock(&_producer_mutex);//加锁为了只允许一个生产者进入_ring_queue[_producer_step++]=in;_producer_step%=_cap;pthread_mutex_unlock(&_producer_mutex);sem_post(&_data_sem);//对数据进行++操作(V操作)}void Pop(T *out){sem_wait(&_data_sem);pthread_mutex_lock(&_consumer_mutex);*out=_ring_queue[_consumer_step++];_consumer_step%=_cap;pthread_mutex_unlock(&_consumer_mutex);sem_post(&_room_sem);}~RingQueue(){sem_destroy(&_room_sem);sem_destroy(&_data_sem);pthread_mutex_destroy(&_producer_mutex);pthread_mutex_destroy(&_consumer_mutex);}private:std::vector<T> _ring_queue;int _cap;// 生产者和消费者的下标int _producer_step;int _consumer_step;sem_t _room_sem; // 生产者关心sem_t _data_sem; // 消费者关心pthread_mutex_t _producer_mutex; // 生产者之间去竞争锁,竞争锁成功进入环形队列pthread_mutex_t _consumer_mutex;
};
//MyThread.hpp#pragma once
#include <iostream>
#include <string>
#include <functional>
#include <pthread.h>
using namespace std;namespace MyThread
{template<class T>using fun_t = function<void(T,string)>;template <class T>class Thread{private:void excute(){_func(_pdata,_name);}public:Thread(fun_t<T> func, T pdata, const string&name="noname"): _func(func), _pdata(pdata), _name(name), _stop(true) {}static void *threadrun(void *args)//如果不是静态,会有this指针{Thread<T> *ptr = reinterpret_cast<Thread<T> *>(args);ptr->excute();return nullptr;}bool start(){int n = pthread_create(&_id, nullptr, threadrun, this);//把this当参数传过去if (n == 0){_stop = false;return true;}else{return false;}}void join(){if (!_stop){pthread_join(_id, nullptr);}}void detach(){if (!_stop){pthread_detach(_id);}}void stop(){_stop = true;}private:pthread_t _id;string _name;bool _stop;fun_t<T> _func;T _pdata;};
}
//makefilecp:Main.ccg++ -o $@ $^ -std=c++11 -lpthread
.PHONY:clean
clean:rm -f cp
//task.hpp#include<iostream>
#include<functional>
using std::cout;
using std::endl;
using Task_t=std::function<void()>;
void print()
{cout<<"I am a task..."<<endl;
}

这篇关于【Linux】POSIX版本 信号量的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1116765

相关文章

linux-基础知识3

打包和压缩 zip 安装zip软件包 yum -y install zip unzip 压缩打包命令: zip -q -r -d -u 压缩包文件名 目录和文件名列表 -q:不显示命令执行过程-r:递归处理,打包各级子目录和文件-u:把文件增加/替换到压缩包中-d:从压缩包中删除指定的文件 解压:unzip 压缩包名 打包文件 把压缩包从服务器下载到本地 把压缩包上传到服务器(zip

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如,在当前目录下创建一个名为 myenv 的虚拟环境: python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行: source myenv/bin/activate 3.与notebook连接 在虚拟环境中,使用 pip 安装 Jupyter 和 ipykernel: pip instal

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

Linux_kernel驱动开发11

一、改回nfs方式挂载根文件系统         在产品将要上线之前,需要制作不同类型格式的根文件系统         在产品研发阶段,我们还是需要使用nfs的方式挂载根文件系统         优点:可以直接在上位机中修改文件系统内容,延长EMMC的寿命         【1】重启上位机nfs服务         sudo service nfs-kernel-server resta

【Linux 从基础到进阶】Ansible自动化运维工具使用

Ansible自动化运维工具使用 Ansible 是一款开源的自动化运维工具,采用无代理架构(agentless),基于 SSH 连接进行管理,具有简单易用、灵活强大、可扩展性高等特点。它广泛用于服务器管理、应用部署、配置管理等任务。本文将介绍 Ansible 的安装、基本使用方法及一些实际运维场景中的应用,旨在帮助运维人员快速上手并熟练运用 Ansible。 1. Ansible的核心概念

Linux服务器Java启动脚本

Linux服务器Java启动脚本 1、初版2、优化版本3、常用脚本仓库 本文章介绍了如何在Linux服务器上执行Java并启动jar包, 通常我们会使用nohup直接启动,但是还是需要手动停止然后再次启动, 那如何更优雅的在服务器上启动jar包呢,让我们一起探讨一下吧。 1、初版 第一个版本是常用的做法,直接使用nohup后台启动jar包, 并将日志输出到当前文件夹n

[Linux]:进程(下)

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 🎈🎈养成好习惯,先赞后看哦~🎈🎈 所属专栏:Linux学习 贝蒂的主页:Betty’s blog 1. 进程终止 1.1 进程退出的场景 进程退出只有以下三种情况: 代码运行完毕,结果正确。代码运行完毕,结果不正确。代码异常终止(进程崩溃)。 1.2 进程退出码 在编程中,我们通常认为main函数是代码的入口,但实际上它只是用户级

【Linux】应用层http协议

一、HTTP协议 1.1 简要介绍一下HTTP        我们在网络的应用层中可以自己定义协议,但是,已经有大佬定义了一些现成的,非常好用的应用层协议,供我们直接使用,HTTP(超文本传输协议)就是其中之一。        在互联网世界中,HTTP(超文本传输协议)是一个至关重要的协议,他定义了客户端(如浏览器)与服务器之间如何进行通信,以交换或者传输超文本(比如HTML文档)。