【探索Linux】—— 强大的命令行工具 P.22(POSIX信号量)

在这里插入图片描述

阅读导航

  • 引言
  • 一、POSIX信号量的基本概念
  • 二、信号量的相关操作
    • 1 . 初始化信号量sem_init ( )
      • (1)原型
      • (2)参数
      • (3)返回值
      • (4)示例代码
    • 2 . 等待信号量
      • (1)sem_wait ( )
        • - 原型
        • - 参数
        • - 返回值
      • (2)sem_trywait ( )
        • - 原型
        • - 参数
        • - 返回值
      • (3)sem_timedwait
        • - 原型
        • - 参数
        • - 返回值
      • (4)示例代码
    • 3 . 发布信号量sem_post( )
      • (1)原型
      • (2)参数
      • (3)返回值
      • (4)示例代码
      • 🚨 注意事项
    • 4 . 销毁信号量sem_destroy()
      • (1)原型
      • (2)参数
      • (3)返回值
      • (4)示例代码
  • 三、 使用场景与注意事项
  • 温馨提示

引言

在上一篇文章中,我们深入探讨了多线程编程的核心概念,包括线程同步、条件变量以及线程安全等关键技术,为读者揭示了并发编程的复杂性及其解决方案。这些概念和技术是实现高效、稳定并发应用程序的基础。继续在并发编程的旅途上前进,本篇文章将引导我们走进Linux操作系统下的另一个重要概念——POSIX信号量(Semaphore)。

POSIX信号量是一种用于进程或线程间同步的机制,它提供了一种控制资源访问的方法,确保在任何时刻只有特定数量的线程可以访问特定的资源。这在处理资源共享问题时尤其重要,比如,在操作系统、数据库管理系统等领域,正确的使用信号量可以有效避免死锁和竞态条件,保证系统的稳定运行。

随着并发编程的普及,掌握各种同步机制成为每位开发者的必备技能。POSIX信号量作为其中的重要组成部分,其重要性不言而喻。让我们一起深入探索POSIX信号量,解锁并发编程的新技能。

一、POSIX信号量的基本概念

POSIX信号量是一种在POSIX-compliant系统(如Linux)中实现的线程或进程间同步机制。它提供了一组标准化的API,用于控制对共享资源的访问。信号量本质上是一个计数器,用于表示可用资源的数量。它支持两个基本操作:等待wait)和信号signal),在不同的文献中,这两个操作也被称为P(Proberen,尝试)和V(Verhogen,增加)操作。

二、信号量的相关操作

POSIX信号量定义在<semaphore.h>头文件中,主要包括以下几个函数

1 . 初始化信号量sem_init ( )

初始化:在使用信号量之前,必须先对其进行初始化,设定信号量的初始值,即可用资源的数量。

(1)原型

int sem_init(sem_t *sem, int pshared, unsigned int value);

(2)参数

  • sem指向信号量对象的指针
  • pshared此参数指示信号量是在进程间共享还是仅限于线程间的共享。如果pshared的值为0,则信号量仅在同一进程的线程间共享;如果pshared的值非0,则信号量可以在多个进程间共享
  • value用于指定信号量的初始值

(3)返回值

  • 成功时返回0
  • 失败时返回-1,并设置errno以指示错误原因

(4)示例代码

下面是一个使用sem_init初始化信号量的简单示例:

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;void* thread_function(void* arg) {// 等待信号量sem_wait(&sem);printf("Entered..\n");// 临界区代码...printf("Exiting..\n");// 释放信号量sem_post(&sem);
}int main() {// 初始化信号量,初始值设为1if (sem_init(&sem, 0, 1) != 0) {perror("sem_init");return 1;}pthread_t t1, t2;// 创建两个线程pthread_create(&t1, NULL, thread_function, NULL);pthread_create(&t2, NULL, thread_function, NULL);// 等待线程结束pthread_join(t1, NULL);pthread_join(t2, NULL);// 销毁信号量sem_destroy(&sem);return 0;
}

在这个示例中,我们创建了一个初始值为1的信号量,这意味着它可以被一个线程获取,从而进入临界区。当信号量的值为0时,其他试图获取该信号量的线程将会阻塞,直到信号量的值再次变为正数。通过调用sem_waitsem_post函数,线程在进入和退出临界区时分别等待和释放信号量,从而实现了线程间的同步。

2 . 等待信号量

等待(P操作):当线程尝试获取一个资源时,会执行等待操作。如果信号量的值大于0,表示有资源可用,它就会减1并继续执行。如果信号量的值为0,表示没有可用资源,执行等待操作的线程将被阻塞,直到信号量的值变为大于0

(1)sem_wait ( )

sem_wait 函数用于等待信号量。如果信号量的值大于0,该函数会将它减1并立即返回,让调用线程继续执行。如果信号量的值为0,调用线程将阻塞,直到信号量的值变为大于0

- 原型
int sem_wait(sem_t *sem);
- 参数
  • sem:指向信号量对象的指针。
- 返回值
  • 成功时返回0
  • 失败时返回-1,并设置errno以指示错误原因

(2)sem_trywait ( )

sem_trywait 函数尝试等待信号量,但与sem_wait不同的是,如果信号量的值为0,sem_trywait不会阻塞调用线程,而是立即返回一个错误。

- 原型
int sem_trywait(sem_t *sem);
- 参数
  • sem:指向信号量对象的指针。
- 返回值
  • 成功时返回0。
  • 如果信号量的值为0,则返回-1,并设置errno为EAGAIN,表示没有获取到信号量。

(3)sem_timedwait

sem_timedwait 函数也用于等待信号量,但它允许指定一个超时时间。如果在指定的时间内信号量没有变为可用状态,函数将返回一个错误。

- 原型
int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);
- 参数
  • sem:指向信号量对象的指针。
  • abs_timeout:指向timespec结构的指针,该结构指定了一个绝对超时时间。这个时间是从Epoch(1970-01-01 00:00:00 UTC)开始计算的。
- 返回值
  • 成功时返回0。
  • 如果在指定时间内未能获取信号量,则返回-1,并设置errno为ETIMEDOUT。

(4)示例代码

下面是一个使用sem_wait等待信号量的简单示例:

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;void* thread_function(void* arg) {// 等待信号量sem_wait(&sem);printf("Entered..\n");// 模拟临界区代码sleep(1);printf("Exiting..\n");// 释放信号量sem_post(&sem);
}int main() {// 初始化信号量,初始值设为1if (sem_init(&sem, 0, 1) != 0) {perror("sem_init");return 1;}pthread_t t1, t2;// 创建两个线程pthread_create(&t1, NULL, thread_function, NULL);pthread_create(&t2, NULL, thread_function, NULL);// 等待线程结束pthread_join(t1, NULL);pthread_join(t2, NULL);// 销毁信号量sem_destroy(&sem);return 0;
}

在这个示例中,sem_wait被用于确保在任何时刻只有一个线程可以进入临界区执行。这是通过在进入临界区之前调用sem_wait来实现的,它会等待信号量变为可用(即信号量的值大于0)。成功进入临界区的线程在离开时通过调用sem_post来增加信号量的值,从而可能允许其他等待中的线程进入临界区。

3 . 发布信号量sem_post( )

信号(V操作)当线程释放一个资源时,会执行信号操作。信号操作会将信号量的值加1。如果有其他线程因等待该信号量而被阻塞,其中一个线程将被唤醒,以便它可以获取资源

sem_post 函数用于增加信号量的值。当信号量的值从0变为正数时,如果有线程因调用 sem_wait 而阻塞在该信号量上,那么其中一个线程将被唤醒(即解除阻塞状态并获得信号量)。

(1)原型

int sem_post(sem_t *sem);

(2)参数

  • sem:指向信号量对象的指针。

(3)返回值

  • 成功时返回0。
  • 失败时返回-1,并设置errno以指示错误原因。

(4)示例代码

以下是一个使用 sem_post 来发布(释放)信号量的简单示例,它演示了如何在一个线程中使用 sem_post 来允许另一个线程继续执行。

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;void* thread_function(void* arg) {printf("Thread waiting for the semaphore...\n");sem_wait(&sem); // 等待信号量printf("Semaphore acquired by thread.\n");// 执行一些操作...sleep(1); // 模拟耗时操作printf("Thread releasing the semaphore.\n");sem_post(&sem); // 释放信号量
}int main() {// 初始化信号量,初始值设为0if (sem_init(&sem, 0, 0) != 0) {perror("sem_init failed");return 1;}pthread_t t1;pthread_create(&t1, NULL, thread_function, NULL);printf("Main thread sleeping for 2 seconds...\n");sleep(2); // 让线程有足够的时间进入等待状态printf("Main thread posting the semaphore.\n");sem_post(&sem); // 主线程释放信号量,允许子线程继续执行pthread_join(t1, NULL); // 等待子线程结束sem_destroy(&sem); // 销毁信号量return 0;
}

在这个示例中,主线程初始化一个信号量并创建一个工作线程,然后休眠2秒钟。工作线程启动后会尝试通过调用 sem_wait 获取信号量,但由于信号量的初始值被设置为0,所以它将被阻塞。主线程在休眠结束后通过调用 sem_post 增加信号量的值,这导致阻塞的工作线程被唤醒并继续执行。

🚨 注意事项

  • 使用 sem_post 时,应确保信号量已经通过 sem_init 或其他方式正确初始化
  • sem_post 可以在任何时候被调用,不仅限于信号量的持有者线程。这意味着,即使一个线程没有通过 sem_wait 获取信号量,它也可以调用 sem_post 来增加信号量的值。
  • 在多线程程序中合理使用信号量,可以有效地控制线程间的同步和互斥,但需要注意避免死锁和竞争条件

4 . 销毁信号量sem_destroy()

在使用POSIX信号量进行线程同步和互斥操作后,正确地销毁信号量是非常重要的。这不仅有助于释放系统资源,还可以避免资源泄漏。POSIX提供了sem_destroy函数来销毁信号量。

sem_destroy函数用于销毁信号量,释放与之关联的资源。一旦信号量被销毁,它就不能再被使用,除非再次被初始化。

(1)原型

int sem_destroy(sem_t *sem);

(2)参数

  • sem:指向信号量对象的指针。

(3)返回值

  • 成功时返回0。
  • 失败时返回-1,并设置errno以指示错误原因。

(4)示例代码

以下是一个简单的示例,演示了如何创建、使用和销毁一个信号量:

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;void* thread_function(void* arg) {sem_wait(&sem); // 等待信号量printf("Thread entered critical section.\n");// 执行临界区代码...sleep(1); // 模拟耗时操作printf("Thread leaving critical section.\n");sem_post(&sem); // 释放信号量
}int main() {// 初始化信号量,初始值设为1if (sem_init(&sem, 0, 1) != 0) {perror("sem_init failed");return 1;}pthread_t t1, t2;pthread_create(&t1, NULL, thread_function, NULL);pthread_create(&t2, NULL, thread_function, NULL);// 等待线程完成pthread_join(t1, NULL);pthread_join(t2, NULL);// 销毁信号量if (sem_destroy(&sem) != 0) {perror("sem_destroy failed");}return 0;
}

在这个示例中,我们创建了一个初始值为1的信号量,允许两个线程依次进入临界区。在线程执行完毕后,我们通过调用sem_destroy来销毁信号量,以确保程序优雅地释放了所有分配的资源。

三、 使用场景与注意事项

POSIX信号量广泛用于多线程和多进程环境中,以实现对共享资源的同步访问控制。在设计并发程序时,正确使用信号量是保证数据一致性和系统稳定性的关键。

在使用POSIX信号量时,需要注意以下几点:

  • 确保在适当的时候初始化和销毁信号量。
  • 避免死锁,确保每个等待信号量的线程最终都能够继续执行。
  • 谨慎处理信号量操作可能失败的情况,特别是sem_wait可能由于中断而提前返回。

通过合理使用POSIX信号量,开发者可以有效地解决多线程编程中的同步和互斥问题,提高程序的稳定性和效率。

温馨提示

感谢您对博主文章的关注与支持!如果您喜欢这篇文章,可以点赞、评论和分享给您的同学,这将对我提供巨大的鼓励和支持。另外,我计划在未来的更新中持续探讨与本文相关的内容。我会为您带来更多关于Linux以及C++编程技术问题的深入解析、应用案例和趣味玩法等。如果感兴趣的话可以关注博主的更新,不要错过任何精彩内容!

再次感谢您的支持和关注。我们期待与您建立更紧密的互动,共同探索Linux、C++、算法和编程的奥秘。祝您生活愉快,排便顺畅!
在这里插入图片描述

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

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

相关文章

Linux第56步_根文件系统第3步_将busybox构建的根文件系统烧录到EMMC

1、第1次将“rootfs”打包 1)、打开第1个终端&#xff0c;准备在“mnt”目录下创建挂载目录“rootfs”&#xff1b; 输入“ls回车” 输入“cd /mnt回车” 输入“ls回车”&#xff0c;查看“mnt”目录下的文件和文件夹 输入“sudo mkdir rootfs回车”&#xff0c;在“mnt”…

如何在30天内使用python制作一个卡牌游戏

如何在30天内使用python制作一个卡牌游戏 第1-5天&#xff1a;规划和设计第6-10天&#xff1a;搭建游戏框架第11-20天&#xff1a;核心游戏机制开发第21-25天&#xff1a;游戏界面和用户体验第26-30天&#xff1a;测试和发布附加建议游戏类型游戏规则设计界面设计技术选型第6-…

Linux操作系统基础(九):Linux用户与权限

文章目录 Linux用户与权限 一、文件权限概述 二、终端命令&#xff1a;组管理 三、终端命令&#xff1a;用户管理 1、创建用户 、 设置密码 、删除用户 2、查看用户信息 3、su切换用户 4、sudo 4.1、给指定用户授予权限 4.2、使用 用户 zhangsan登录, 操作管理员命令…

第五节 zookeeper集群与分布式锁_2

1.分布式锁概述 1.1 什么是分布式锁 1&#xff09;要介绍分布式锁&#xff0c;首先要提到与分布式锁相对应的是线程锁。 线程锁&#xff1a;主要用来给方法、代码块加锁。当某个方法或代码使用锁&#xff0c;在同一时刻仅有一个线程执行该方法或该代码段。 线程锁只在同一J…

【LeetCode: 107. 二叉树的层序遍历 II + BFS】

&#x1f680; 算法题 &#x1f680; &#x1f332; 算法刷题专栏 | 面试必备算法 | 面试高频算法 &#x1f340; &#x1f332; 越难的东西,越要努力坚持&#xff0c;因为它具有很高的价值&#xff0c;算法就是这样✨ &#x1f332; 作者简介&#xff1a;硕风和炜&#xff0c;…

微信网页版能够使用(会顶掉微信app的登陆)

一、文件结构 新建目录chrome新建icons&#xff0c;其中图片你自己找吧新建文件manifest.json新建文件wx-rules.json 二、文件内容 对应的png你们自己改下 1、manifest.json {"manifest_version": 3,"name": "wechat-need-web","author…

用HTML、CSS和JS打造绚丽的雪花飘落效果

目录 一、程序代码 二、代码原理 三、运行效果 一、程序代码 <!DOCTYPE html> <html><head><meta http-equiv"Content-Type" content"text/html; charsetGBK"><style>* {margin: 0;padding: 0;}#box {width: 100vw;heig…

qml之Control类型布局讲解,padding属性和Inset属性细讲

1、Control布局图 2、如何理解&#xff1f; *padding和*Inset参数如何理解呢&#xff1f; //main.qml import QtQuick 2.0 import QtQuick.Controls 2.12 import QtQuick.Layouts 1.12 import QtQuick.Controls 1.4 import QtQml 2.12ApplicationWindow {id: windowvisible: …

单片机学习笔记---直流电机驱动(PWM)

直流电机介绍 直流电机是一种将电能转换为机械能的装置。一般的直流电机有两个电极&#xff0c;当电极正接时&#xff0c;电机正转&#xff0c;当电极反接时&#xff0c;电机反转 直流电机主要由永磁体&#xff08;定子&#xff09;、线圈&#xff08;转子&#xff09;和换向器…

DolphinScheduler安装与配置

DolphinScheduler概述 Apache DolphinScheduler是一个分布式、易扩展的可视化DAG工作流任务调度平台。致力于解决数据处理流程中错综复杂的依赖关系&#xff0c;使调度系统在数据处理流程中开箱即用。 DolphinScheduler的主要角色如下&#xff1a; MasterServer采用分布式无…

leetcode hot100 拆分整数

在本题目中&#xff0c;我们需要拆分一个整数n&#xff0c;让其拆分的整数积最大。因为每拆分一次都和之前上一次拆分有关系&#xff0c;比如拆分6可以拆成2x4&#xff0c;还可以拆成2x2x2&#xff0c;那么我们可以采用动态规划来做。 首先确定dp数组的含义&#xff0c;这里dp…

第13章 网络 Page738~741 13.8.3 TCP/UDP简述

libcurl是C语言写成的网络编程工具库&#xff0c;asio是C写的网络编程的基础类型库 libcurl只用于客户端&#xff0c;asio既可以写客户端&#xff0c;也可以写服务端 libcurl实现了HTTP\FTP等应用层协议&#xff0c;但asio却只实现了传输层TCP/UDP等协议。 在学习http时介绍…

C语言—函数

1.编写一个函数&#xff0c;通过输入一个数字字符&#xff0c;返回该数字29. /*1.编写一个函数&#xff0c;通过输入一个数字字符&#xff0c;返回该数字 */#include <stdio.h>//函数定义,返回类型为int int char_num(char c) {if(c > 0 && c < 9) //检查…

基于springboot智慧外贸平台源码和论文

网络的广泛应用给生活带来了十分的便利。所以把智慧外贸管理与现在网络相结合&#xff0c;利用java技术建设智慧外贸平台&#xff0c;实现智慧外贸的信息化。则对于进一步提高智慧外贸管理发展&#xff0c;丰富智慧外贸管理经验能起到不少的促进作用。 智慧外贸平台能够通过互…

leetcode206. 反转链表

leetcode206. 反转链表 题目 代码 新链表逐个存储 提取单个节点&#xff0c;添加到新链表的头结点处 class Solution:def reverseList(self, head: Optional[ListNode]) -> Optional[ListNode]:new_node Nonecurrent headwhile current:rest current.nexttemp_head …

【2024】如何订阅Netflix奈飞?Netflix奈飞购买教程

【2024】如何订阅Netflix奈飞&#xff1f;Netflix奈飞购买教程 Netflix奈飞作为全球领先的在线流媒体平台之一&#xff0c;拥有丰富的影视资源和独家内容&#xff0c;成为了人们追剧的热门选择。本文将为您介绍如何订阅Netflix奈飞&#xff0c;并提供详细的购买教程&#xff0…

详解结构体内存对齐及结构体如何实现位段~

目录 ​编辑 一&#xff1a;结构体内存对齐 1.1对齐规则 1.2.为什么存在内存对齐 1.3修改默认对齐数 二.结构体实现位段 2.1什么是位段 2.2位段的内存分配 2.3位段的跨平台问题 2.4位段的应用 2.5位段使用的注意事项 三.完结散花 悟已往之不谏&#xff0c;知来者犹可…

Springboot+vue的社区养老服务平台(有报告)。Javaee项目,springboot vue前后端分离项目

演示视频&#xff1a; Springbootvue的社区养老服务平台&#xff08;有报告&#xff09;。Javaee项目&#xff0c;springboot vue前后端分离项目 项目介绍&#xff1a; 本文设计了一个基于Springbootvue的前后端分离的社区养老服务平台&#xff0c;采用M&#xff08;model&…

IT行业顶级证书盘点:提升职业含金量的必备证书

IT行业有哪些证书含金量高? 在竞争激烈的IT行业&#xff0c;持有一些知名的顶级证书可以显著提升个人的职业含金量和竞争力。本文将盘点IT行业中那些含金量高的顶级证书&#xff0c;并介绍它们的考试内容、培训途径以及对职业发展的重要性&#xff0c;帮助读者更好地规划自己…

设计模式Python实现

过年在家瞎折腾&#xff0c;闲着无聊看到设计模式&#xff0c;于是就想着用Python实现一下。 简单工厂 根据传入的参数决定创建出哪一种产品类的实例。 class CashFactory:def createCashAdapter(self, type):if type "满100减20":return CashReturn(100, 20)elif…