信号量机制:原语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

相关文章

Go语言开发实现查询IP信息的MCP服务器

《Go语言开发实现查询IP信息的MCP服务器》随着MCP的快速普及和广泛应用,MCP服务器也层出不穷,本文将详细介绍如何在Go语言中使用go-mcp库来开发一个查询IP信息的MCP... 目录前言mcp-ip-geo 服务器目录结构说明查询 IP 信息功能实现工具实现工具管理查询单个 IP 信息工具的实现服

SpringBoot基于配置实现短信服务策略的动态切换

《SpringBoot基于配置实现短信服务策略的动态切换》这篇文章主要为大家详细介绍了SpringBoot在接入多个短信服务商(如阿里云、腾讯云、华为云)后,如何根据配置或环境切换使用不同的服务商,需... 目录目标功能示例配置(application.yml)配置类绑定短信发送策略接口示例:阿里云 & 腾

Python ZIP文件操作技巧详解

《PythonZIP文件操作技巧详解》在数据处理和系统开发中,ZIP文件操作是开发者必须掌握的核心技能,Python标准库提供的zipfile模块以简洁的API和跨平台特性,成为处理ZIP文件的首选... 目录一、ZIP文件操作基础三板斧1.1 创建压缩包1.2 解压操作1.3 文件遍历与信息获取二、进阶技

Java中字符串转时间与时间转字符串的操作详解

《Java中字符串转时间与时间转字符串的操作详解》Java的java.time包提供了强大的日期和时间处理功能,通过DateTimeFormatter可以轻松地在日期时间对象和字符串之间进行转换,下面... 目录一、字符串转时间(一)使用预定义格式(二)自定义格式二、时间转字符串(一)使用预定义格式(二)自

python实现svg图片转换为png和gif

《python实现svg图片转换为png和gif》这篇文章主要为大家详细介绍了python如何实现将svg图片格式转换为png和gif,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录python实现svg图片转换为png和gifpython实现图片格式之间的相互转换延展:基于Py

Python利用ElementTree实现快速解析XML文件

《Python利用ElementTree实现快速解析XML文件》ElementTree是Python标准库的一部分,而且是Python标准库中用于解析和操作XML数据的模块,下面小编就来和大家详细讲讲... 目录一、XML文件解析到底有多重要二、ElementTree快速入门1. 加载XML的两种方式2.

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念(Stack)栈的实现代码队列(Queue)模拟实现队列(双链表实现)循环队列(循环数组

C++如何通过Qt反射机制实现数据类序列化

《C++如何通过Qt反射机制实现数据类序列化》在C++工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作,所以本文就来聊聊C++如何通过Qt反射机制实现数据类序列化吧... 目录设计预期设计思路代码实现使用方法在 C++ 工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作。由于数据类

Python实现图片分割的多种方法总结

《Python实现图片分割的多种方法总结》图片分割是图像处理中的一个重要任务,它的目标是将图像划分为多个区域或者对象,本文为大家整理了一些常用的分割方法,大家可以根据需求自行选择... 目录1. 基于传统图像处理的分割方法(1) 使用固定阈值分割图片(2) 自适应阈值分割(3) 使用图像边缘检测分割(4)

Android实现在线预览office文档的示例详解

《Android实现在线预览office文档的示例详解》在移动端展示在线Office文档(如Word、Excel、PPT)是一项常见需求,这篇文章为大家重点介绍了两种方案的实现方法,希望对大家有一定的... 目录一、项目概述二、相关技术知识三、实现思路3.1 方案一:WebView + Office Onl