信号量机制:原语PV操作的实现|源代码和解释

2024-01-01 23:44

本文主要是介绍信号量机制:原语PV操作的实现|源代码和解释,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

信号量机制

**目的:**实现互斥访问共享资源,实现进程同步。

一共3个操作

  1. 初始化
  2. P原语
  3. V原语

类型:

  1. 整型信号量:只包含临界资源数量。当资源不足的时候会自旋,会发生忙等,违背“让权等待”
  2. 记录型信号量:包含等待队列等信息。当资源不足的时候,会进入等待队列。

单词解释: 源于荷兰语
P-V原语操作
P = plantinga = Probeer(’try’)=尝试
V= Verhoog = increment = 增加1

整型信号量

了解即可

加锁确保原子操作
wait(S)原语:P操作,上锁+检查,避免了异步并发导致的死锁的问题。
signal(S)原语:V操作 上锁+检查

伪代码实现:

// 初始化,共享资源(临界资源)的数量
int S = 1;// P操作
void wait(int S) lock();     //加锁  while (S <= 0); ///< 如果s<0,会自旋,忙等S = S + 1;unlock();    //解锁  
}
// V操作
void signal(int S) {lock();//加锁S = S + 1;unlock();//解锁
}
/**********************************/
// 进程访问访问临界资源
wait(S);	// 进入临界区
访问临界资源;  //  临界区
signal(S);  // 退出临界区

为了解决“自旋”问题,引入等待队列。

记录型信号量的原理

引用维基百科解释 Semaphore_(programming)

A simple way to understand wait § and signal (V) operations is:
wait: Decrements the value of semaphore variable by 1. If the new value of the semaphore variable is negative, the process executing wait is blocked (i.e., added to the semaphore’s queue). Otherwise, the process continues execution, having used a unit of the resource.
signal: Increments the value of semaphore variable by 1. After the increment, if the pre-increment value was negative (meaning there are processes waiting for a resource), it transfers a blocked process from the semaphore’s waiting queue to the ready queue.

这是阿里云给出的步骤,与原版一致

P (S):
① reduce the semaphore s value by 1, that is, S = S-1;
② If S> = 0, the process continues to run; otherwise, the process is set to the waiting status and is discharged into the waiting queue.
V (s):
① Add 1 to the semaphore s value, that is, S = S + 1;
② If S> 0, the process continues; otherwise, the first process in the queue is released waiting for the semaphore.

翻译过来
P原语操作:
sem减1;
若sem减1后仍大于或等于0,则P原语返回,该进程继续执行;
若sem减1后小于0,则该进程被阻塞后进入与该信号相对应的队列中,然后转进程调度。

V原语操作:
sem加1;
若相加结果大于0,V原语停止执行,该进程返回调用处,继续执行;
若相加结果小于或等于0,则从该信号的等待队列中唤醒一个等待进程,然后再返回原进程继续执行或转进程调度。

总的来说,就是先修改信号量,然后再检查。

但是:
在信号量的实现中,通常的做法是首先检查信号量的状态,然后根据这个状态来决定是否减少信号量的值。这是为了确保只有在资源确实可用的情况下,线程才会减少信号量的值并进入临界区。在资源不可用时,线程应该等待,直到资源变得可用。

然而,在通过添加互斥锁的前提下,两者的实现一致



记录型信号量的实现

下面与原版保持一致

PV操作的c语言实现

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>/// 定义信号量,包含其他信息。
typedef struct {int value;   ///<  信号量的值,临界资源数量pthread_mutex_t mutex; ///< 互斥锁,用于原语操作/// 条件变量实现了等待队列pthread_cond_t cond; ///< 条件变量,下面有详解
} semaphore;/// 初始化信号量
void semaphore_init(semaphore *s, int value) {s->value = value;pthread_mutex_init(&s->mutex, NULL);pthread_cond_init(&s->cond, NULL);
}/// P操作wait(S)
void P(semaphore *s) {pthread_mutex_lock(&s->mutex); ///< 加锁s->value--;/// 先判断的话是<=,后判断是<while (s->value < 0) {pthread_cond_wait(&s->cond, &s->mutex);	///< 进程进入等待队列}pthread_mutex_unlock(&s->mutex); ///< 释放锁
}/// S操作signal(S)
void V(semaphore *s) {pthread_mutex_lock(&s->mutex); ///< 加锁s->value++;///< 如果等待队列中存在进程,进行唤醒,让它去使用临界资源if (s->value <= 0){ ///< 其实可以不加判断,pthread_cond_signal函数中包含判断pthread_cond_signal(&s->cond);  ///< 唤醒等待列中的进程}pthread_mutex_unlock(&s->mutex);///< 释放锁
}/// 测试函数
void *thread_function(void *arg) {semaphore *s = (semaphore *)arg;printf("Thread %ld: Waitling to enter critical section...\n", pthread_self());P(s);printf("Thread %ld: Entered critical section.\n", pthread_self());sleep(1);  // 模拟访问临界资源printf("Thread %ld: Exiting critical section.\n", pthread_self());V(s);return NULL;
}int main() {pthread_t t1, t2;semaphore sem;sephore_init(&sem, 1);pthread_create(&t1, NULL, thread_function, &sem);pthread_create(&t2, NULL, thread_function, &sem);pthread_join(t1, NULL);pthread_join(t2, NULL);return 0;
}

条件变量(cond)的作用可以通过一个现实生活中的比喻来解释,让我们以餐厅里的顾客和服务员的互动为例:

想象你在一家餐厅里等待你的食物。餐厅里有很多桌子,每个桌子上都有一个按钮,当你按下这个按钮时,就表示你的食物准备好了。在这个比喻中,每个桌子上的按钮就像一个条件变量。

  1. 等待条件变量(pthread_cond_wait:你(一个线程)到达餐厅并下了订单。然后,你等待食物准备好。在这个时候,你不会一直盯着服务员(忙等),而是会做一些其他事情,比如聊天或看手机。这个等待过程就像是线程在条件变量上的等待。你知道,直到你的食物准备好(条件发生变化),你都不需要做任何事。
  2. 通知条件变量(pthread_cond_signal:当厨师准备好你的食物后,服务员(另一个线程)会按下你桌子上的按钮。这个动作就像是在条件变量上发送信号。按下按钮后,你知道你的食物已经准备好了,你可以停止等待,开始吃饭。
  3. 互斥锁(pthread_mutex_t:为了保证订单不会混乱(避免数据竞争),每个订单都是在一种互斥的方式下处理的。这就像是每个服务员在处理一个订单时都拿着一个特定的笔(互斥锁),该订单只能由携带该笔的服务员处理,且这个笔一次只能由一个服务员使用(互斥)。当服务员处理完订单后,他们会放下笔,让其他服务员可以使用(释放锁)。

在这个比喻中,你等待的过程是非活跃的,不会占用资源(如不会一直盯着服务员)。这正是条件变量在多线程编程中的作用:允许线程在某些条件尚未满足时,以非忙等的方式等待,从而提高资源的利用效率和程序的响应性。当条件满足(比如食物准备好了),通过发送信号的方式通知等待的线程,允许它们继续执行。

这篇关于信号量机制:原语PV操作的实现|源代码和解释的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

SpringBoot3实现Gzip压缩优化的技术指南

《SpringBoot3实现Gzip压缩优化的技术指南》随着Web应用的用户量和数据量增加,网络带宽和页面加载速度逐渐成为瓶颈,为了减少数据传输量,提高用户体验,我们可以使用Gzip压缩HTTP响应,... 目录1、简述2、配置2.1 添加依赖2.2 配置 Gzip 压缩3、服务端应用4、前端应用4.1 N

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》:本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.

MySQL双主搭建+keepalived高可用的实现

《MySQL双主搭建+keepalived高可用的实现》本文主要介绍了MySQL双主搭建+keepalived高可用的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录一、测试环境准备二、主从搭建1.创建复制用户2.创建复制关系3.开启复制,确认复制是否成功4.同

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例:修改表在数据库中,表的操作主要

C# WinForms存储过程操作数据库的实例讲解

《C#WinForms存储过程操作数据库的实例讲解》:本文主要介绍C#WinForms存储过程操作数据库的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、存储过程基础二、C# 调用流程1. 数据库连接配置2. 执行存储过程(增删改)3. 查询数据三、事务处