Linux POSIX信号量 线程池

Linux POSIX信号量 线程池

  • 一. 什么是POSIX信号量？
  • 二. POSIX信号量实现原理
  • 三. POSIX信号量接口函数
  • 四. 基于环形队列的生产消费模型
  • 五. 线程池

一. 什么是POSIX信号量？

POSIX信号量是一种用于同步和互斥操作的机制，属于POSIX（Portable Operating System Interface） 标准的一部分。这一标准定义了操作系统应该为应用程序提供的接口，而POSIX信号量是在多线程和多进程环境下实现同步的一种方式。

信号量本质上是一个计数器，用于描述临界资源的数量。在多线程或多进程的情况下，当多个执行单元（线程或进程）需要访问共享资源时，使用信号量可以有效地协调它们的行为，避免竞争条件和提高程序的可靠性。

二. POSIX信号量实现原理

POSIX信号量的实现原理基于一个计数器和一个等待队列。关键的操作包括P操作和V操作：

P操作：申请信号量，如果信号量计数器大于零，表示资源可用，计数器减一；如果计数器为零，线程将被阻塞，并加入等待队列。
V操作：释放信号量，计数器加一，并唤醒等待队列中的一个线程。

具体实现原理如下：

  1. 信号量结构包括计数器和等待队列。
  2. 当计数器为零时，表示资源不可用，线程申请信号量时将被阻塞，并放入等待队列。
  3. 当计数器大于零时，表示资源可用，线程申请信号量时计数器减一，线程获得资源。
  4. 当释放信号量时，计数器加一，如果等待队列不为空，唤醒等待队列中的一个线程。

三. POSIX信号量接口函数

  1. sem_t 是一个数据类型，用于表示信号量。作为同步机制的一部分，信号量用于协调共享资源的访问。用户通过提供的接口函数（如 sem_init、sem_wait、sem_post）来操作信号量，

  2. 初始化信号量

#include <semaphore.h>
int sem_init(sem_t *sem, int pshared, unsigned int value);

sem: 指向要初始化的信号量的指针。
pshared: 0表示信号量在线程间共享，非零表示在进程间共享。
value: 信号量的初始值。
返回值：成功时返回0，失败时返回-1。

  1. 等待信号量
#include <semaphore.h>
int sem_wait(sem_t *sem); // P()

sem: 指向要等待的信号量的指针。
功能：等待信号量，将信号量的值减1。如果信号量的值为0，线程将被阻塞。
返回值：成功时返回0，失败时返回-1。

  1. 释放信号量
#include <semaphore.h>
int sem_post(sem_t *sem); // V()

sem: 指向要发布的信号量的指针。
功能：释放信号量，表示资源使用完毕，将信号量的值加1。通常用于释放信号。
返回值：成功时返回0，失败时返回-1。

  1. 销毁信号量
#include <semaphore.h>
int sem_destroy(sem_t *sem);

sem: 要销毁的信号量的指针。
返回值：成功时返回0，失败时返回-1。

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

  1. 环形队列简介
    环形队列是一种基于数组或链表的数据结构，具有循环特性。其关键特点包括循环性、高效性和固定大小。常用于缓冲区、循环缓存和生产者-消费者模型等场景。由于采用模运算，插入和删除操作的时间复杂度为O(1)，使得其在实时系统和有限资源的应用中得以广泛应用。
    在这里插入图片描述

在这里插入图片描述
放数据操作：

等待生产者信号量： 通过 P(prodSemaphore)，生产者等待信号量，确保有足够的空间可供数据生产。
将数据放入缓冲区： 数据被放入环形缓冲区的当前生产者索引位置 (buffer_[prodIndex])。 生产者索引 prodIndex 被更新，并通过取模操作确保索引在缓冲区容量内循环。
发送消费者信号量： 通过 V(consSemaphore)，生产者通知消费者有新的数据可供消费。

拿数据操作：

等待消费者信号量： 通过 P(consSemaphore)，消费者等待信号量，确保有足够的数据可供消费。
从缓冲区取出数据： 数据被从环形缓冲区的当前消费者索引位置取出 (buffer_[consIndex])。 消费者索引 consIndex
被更新，并通过取模操作确保索引在缓冲区容量内循环。
发送生产者信号量： 通过 V(prodSemaphore)，消费者通知生产者有空间可供数据生产。

五. 线程池

什么是线程池？
线程池是一种常见的多线程使用模式。它通过维护一组线程，等待监督管理者分配可并发执行的任务。这种设计避免了在处理短时间任务时创建与销毁线程的开销，提高了系统性能。线程池通过保证内核的充分利用，同时防止过度调度，对于某些应用场景尤其有效。

实例：创建一个简单的固定数量线程池

#include <iostream>
#include <queue>
#include <vector>
#include <pthread.h>
#include <unistd.h>
using namespace std;// 线程数据结构
struct threaddata
{pthread_t tid;  // 线程ID
};// 任务类
class Task
{
public:Task(int data) : data_(data){}// 重载运算符，用于执行任务void operator()(){run();}
private:// 任务执行函数void run(){cout << "数据：" << data_ << endl;}int data_;
};// 线程池模板类
template<class T>
class ThreadPool
{
public:// 构造函数，默认线程数为6ThreadPool(int n = 6) : td(6){pthread_mutex_init(&mutex_, nullptr);  // 初始化互斥锁pthread_cond_init(&cond_, nullptr);    // 初始化条件变量}// 析构函数~ThreadPool(){pthread_mutex_destroy(&mutex_);    // 销毁互斥锁pthread_cond_destroy(&cond_);      // 销毁条件变量}// 线程处理函数static void* handler(void* args){ThreadPool<T>* tp = static_cast<ThreadPool<T>*>(args);while (1){tp->lock();  // 加锁，保护临界区while (tp->isQueueEmpty()){tp->wait();  // 当任务队列为空时，等待条件变量}T data = tp->queueFront();  // 获取任务队列的队首元素tp->queuePop();  // 弹出任务队列的队首元素tp->unlock();  // 解锁，释放临界区data();  // 执行任务}}// 启动线程池void start(){for (int i = 0; i < td.size(); i++){pthread_create(&(td[i].tid), nullptr, handler, static_cast<void*>(this));  // 创建线程}}// 将任务放入任务队列void push(T& data){lock();               // 加锁，确保线程安全task.push(data);      // 将任务加入队列wakeup();             // 唤醒等待的线程unlock();             // 解锁，释放锁，允许其他线程访问任务队列}// 判断任务队列是否为空bool isQueueEmpty(){return task.empty();}// 获取任务队列的队首元素T& queueFront(){return task.front();}// 弹出任务队列的队首元素void queuePop(){task.pop();}public:// 加锁操作void lock(){pthread_mutex_lock(&mutex_);}// 解锁操作void unlock(){pthread_mutex_unlock(&mutex_);}// 等待条件变量void wait(){pthread_cond_wait(&cond_, &mutex_);}// 唤醒等待条件变量的线程void wakeup(){pthread_cond_signal(&cond_);}private:vector<threaddata> td;  // 线程数据queue<T> task;          // 任务队列pthread_mutex_t mutex_; // 互斥锁pthread_cond_t cond_;   // 条件变量
};int main()
{srand(time(nullptr));ThreadPool<Task> thread(6);  // 创建线程池，设置线程数为6thread.start();  // 启动线程池while (1){Task d(rand() % 100);thread.push(d);  // 将任务放入线程池sleep(1);}return 0;
}

线程池模板类 ThreadPool： 创建了一个线程池类，模板参数为任务类型 T，默认线程数为6。 使用 pthread 库提供的互斥锁和条件变量来实现线程同步。 提供了启动线程池的 start 函数，创建指定数量的线程，并在这些线程中执行 handler
函数。 提供了将任务推送到任务队列的 push 函数，该函数会将任务加入队列，唤醒等待中的线程。

任务类 Task： 任务类用于封装线程池中执行的具体任务，其中包含一个整数类型的数据。 通过重载 () 运算符实现了任务的执行函数，输出任务的数据。

线程处理函数 handler： 作为线程的入口函数，不断从任务队列中取出任务并执行。 使用互斥锁保护任务队列，条件变量用于在任务队列为空时等待新任务。 通过调用线程池的成员函数来实现任务的执行、入队、出队等操作。

主函数 main： 在主函数中，创建了一个 ThreadPool 对象，设置线程数为6，并启动线程池。 进入无限循环，每次循环生成一个随机数，创建一个包含该随机数的 Task 对象，并通过线程池的 push 函数将任务推送到任务队列中。
程序不断创建新的任务，由线程池中的线程执行。

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

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

相关文章

项目管理工具软件Maven趣闻

项目管理工具软件Maven趣闻

版权声明 本文原创作者&#xff1a;谷哥的小弟作者博客地址&#xff1a;http://blog.csdn.net/lfdfhl Maven这个单词来自于意第绪语&#xff08;Yiddish&#xff09;&#xff0c;这是一种与德语和希伯来语有密切关系的犹太民族语言。在这个语境中&#xff0c;Maven意为“知识的…
阅读更多...
ChatGPT高效提问—prompt实践（智能辅导-心理咨询-职业规划）

ChatGPT高效提问—prompt实践（智能辅导-心理咨询-职业规划）

ChatGPT高效提问—prompt实践&#xff08;智能辅导-心理咨询-职业规划&#xff09; ​ 智能辅导是指利用人工智能技术&#xff0c;为学习者提供个性化、高效的学习辅助服务。它基于大数据分析和机器学习算法&#xff0c;可以针对学习者的学习行为、状态和能力进行评估和预测&a…
阅读更多...
Shell - 学习笔记 - 2.15 - Shell关联数组（下标是字符串的数组）

Shell - 学习笔记 - 2.15 - Shell关联数组（下标是字符串的数组）

现在最新的 Bash Shell 已经支持关联数组了。关联数组使用字符串作为下标&#xff0c;而不是整数&#xff0c;这样可以做到见名知意。 关联数组也称为“键值对&#xff08;key-value&#xff09;”数组&#xff0c;键&#xff08;key&#xff09;也即字符串形式的数组下标&…
阅读更多...
AutoSAR（基础入门篇）10.1-Autosar_Ecum模式管理概述

AutoSAR（基础入门篇）10.1-Autosar_Ecum模式管理概述

目录 一、什么是模式管理 二、再谈BswM 1、BswM概述 2、BswM执行流程 三、再谈EcuM 模式管理应该算是我们实践篇中较难的内容了，还有就是诊断那章也比较难。因为模式管理里面可能回涉及到很多的名词，很多的特性，所以博主准 备分个8次左右来讲解这些内容。但是在实际的应…
阅读更多...
如何在 Angular 中使用环境变量

如何在 Angular 中使用环境变量

简介 如果你正在构建一个使用 API 的应用程序&#xff0c;你会想在开发过程中使用测试环境的 API 密钥&#xff0c;而在生产环境中使用生产环境的 API 密钥。在 Angular 中&#xff0c;你可以通过 environment.ts 文件创建环境变量。 在本教程中&#xff0c;你将学习如何在 A…
阅读更多...
【Java万花筒】数据流的舵手：大数据处理和调度库对比指南

【Java万花筒】数据流的舵手：大数据处理和调度库对比指南

智慧的导航仪&#xff1a;为您的数据流选择正确的大数据处理和调度库 前言 在如今的信息时代&#xff0c;大数据处理和调度已经成为许多企业和组织中关键的任务。为了有效地处理和管理大规模数据流&#xff0c;选择适合的调度库是至关重要的。本文将介绍几种常用的大数据处理…
阅读更多...
【前端工程化面试题】使用 webpack 来优化前端性能/ webpack的功能

【前端工程化面试题】使用 webpack 来优化前端性能/ webpack的功能

这个题目实际上就是来回答 webpack 是干啥的&#xff0c;你对webpack的理解&#xff0c;都是一个问题。 &#xff08;1&#xff09;对 webpack 的理解 webpack 为啥提出 webpack 是啥 webpack 的主要功能 前端开发通常是基于模块化的&#xff0c;为了提高开发效率&#xff0…
阅读更多...
MATLAB知识点：datasample函数（★★☆☆☆）随机抽样的函数，能对矩阵数据进行随机抽样

MATLAB知识点：datasample函数（★★☆☆☆）随机抽样的函数，能对矩阵数据进行随机抽样

讲解视频&#xff1a;可以在bilibili搜索《MATLAB教程新手入门篇——数学建模清风主讲》。​ MATLAB教程新手入门篇&#xff08;数学建模清风主讲&#xff0c;适合零基础同学观看&#xff09;_哔哩哔哩_bilibili 节选自第3章&#xff1a;课后习题讲解中拓展的函数 在讲解第三…
阅读更多...
数据类型与变量

数据类型与变量

目录 作业回顾 有关JDK, JRE, JVM三者&#xff1a; 判断题 新课学习 字面常量 数据类型 变量 整型变量 长整型变量 短整型变量 字节型变量 浮点型变量 字符型变量 布尔型变量 类型转换 自动类型转换&#xff08;隐式&#xff09; 强制类型转换&#xff08;显式…
阅读更多...
Navicat安装使用连接MySQL

Navicat安装使用连接MySQL

目录 安装登录MySQL登录MySQL用Navicat连接MySQL 安装 选择“我同意”&#xff0c;点击下一步。 选择安装的目标文件夹&#xff0c;点击下一步。 点击下一步。 点击下一步。 点击安装。 软件安装需要一些时间&#xff0c;请耐心等待 点击“完成”。 注册 输入 密钥&#x…
阅读更多...
Crypto-RSA3

Crypto-RSA3

题目&#xff1a;&#xff08;BUUCTF在线评测 (buuoj.cn)&#xff09; 共模攻击 ​ 前提&#xff1a;有两组及以上的RSA加密过程&#xff0c;而且其中两次的m和n都是相同的&#xff0c;那么就可以在不计算出d而直接计算出m的值。 ​ 设模数为n&#xff0c;两个用户的公钥分别为…
阅读更多...
全栈笔记_浏览器扩展篇（manifest.json文件介绍）

全栈笔记_浏览器扩展篇（manifest.json文件介绍）

manifest.json介绍 是web扩展技术必不可少的插件配置文件，放在根目录作用： 指定插件的基本信息 name：名称manifest_version：manifest.json文件的版本号，可以写2或3version：版本description：描述定义插件的行为： browser_action：添加一个操作按钮到浏览器工具栏，点击按…
阅读更多...
LeetCode 0103.二叉树的锯齿形层序遍历：层序遍历 + 适时翻转

LeetCode 0103.二叉树的锯齿形层序遍历：层序遍历 + 适时翻转

【LetMeFly】103.二叉树的锯齿形层序遍历&#xff1a;层序遍历 适时翻转 力扣题目链接&#xff1a;https://leetcode.cn/problems/binary-tree-zigzag-level-order-traversal/ 给你二叉树的根节点 root &#xff0c;返回其节点值的 锯齿形层序遍历 。&#xff08;即先从左往…
阅读更多...
关于C++中的深拷贝

关于C++中的深拷贝

说到深拷贝&#xff0c;是相对于浅拷贝而言的。弄清了浅拷贝&#xff0c;深拷贝也就不言自明了。对C初学者而言&#xff0c;所谓浅拷贝在编写程序过程中往往是无感的。我们一般在写一个类时&#xff0c;多数情况我们只是写了成员变量、成员函数&#xff0c;有时为了赋初值方便&…
阅读更多...
Java与JavaScript同源不同性

Java与JavaScript同源不同性

Java是目前编程领域使用非常广泛的编程语言&#xff0c;相较于JavaScript&#xff0c;Java更被人们熟知。很多Java程序员想学门脚本语言&#xff0c;一看JavaScript和Java这么像&#xff0c;很有亲切感&#xff0c;那干脆就学它了&#xff0c;这也间接的帮助了JavaScript的发展…
阅读更多...
HTML | DOM | 网页前端 | 常见HTML标签总结

HTML | DOM | 网页前端 | 常见HTML标签总结

文章目录 1.前端开发简单分类2.前端开发环境配置3.HTML的简单介绍4.常用的HTML标签介绍 1.前端开发简单分类 前端开发&#xff0c;这里是一个广义的概念&#xff0c;不单指网页开发&#xff0c;它的常见分类 网页开发&#xff1a;前端开发的主要领域&#xff0c;使用HTML、CS…
阅读更多...
OpenCV中的边缘检测技术及实现

OpenCV中的边缘检测技术及实现

介绍: 边缘检测是计算机视觉中非常重要的技术之一。它用于有效地识别图像中的边缘和轮廓&#xff0c;对于图像分析和目标检测任务至关重要。OpenCV提供了多种边缘检测技术的实现&#xff0c;本博客将介绍其中的两种常用方法&#xff1a;Canny边缘检测和Sobel边缘检测。 理论介…
阅读更多...
【C语言】（25）文件包含include

【C语言】（25）文件包含include

#include是C语言中的预处理指令之一&#xff0c;用于在当前文件中包含另一个文件的内容。用于模块化和代码重用的基本机制。合理使用#include可以使代码结构更加清晰&#xff0c;易于管理和维护。 #include主要用于包含标准库头文件或自定义头文件。 两种形式的#include #in…
阅读更多...
C语言程序设计（第四版）—习题7程序设计题

C语言程序设计（第四版）—习题7程序设计题

目录 1.选择法排序。 2.求一批整数中出现最多的数字。 3.判断上三角矩阵。 4.求矩阵各行元素之和。 5.求鞍点。 6.统计大写辅音字母。 7.字符串替换。 8.字符串转换成十进制整数。 1.选择法排序。 输入一个正整数n&#xff08;1&#xff1c;n≤10&#xff09;&#xf…
阅读更多...
简易绘图软件（水一期）

简易绘图软件（水一期）

哈哈&#xff01; 1、编写代码&#xff1a; 代码&#xff1a; main: #include <graphics.h> #include <music.h> #include <heker.h> #pragma comment( linker, "/subsystem:\"windows\" /entry:\"mainCRTStartup\"" )using…
阅读更多...
最新文章

Copyright @ 2022~2023