【探索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.hqwc.cn/news/473408.html

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

相关文章

数据结构与算法:二叉树(寻找最近公共祖先、寻找后继节点、序列化和反序列化、折纸问题的板子和相关力扣题目)

最近公共祖先 第一版&#xff08;前提&#xff1a;p和q默认存在于这棵树中&#xff09; 可以层序遍历每个节点时用个HashMap存储该结点和其直接父节点的信息。然后从p开始溯源&#xff0c;将所有的父节点都添加到一个HashSet集合里。然后从q开始溯源&#xff0c;每溯源一步看…

数据库数据加密的 4 种常见思路的对比

应用层加解密方案数据库前置处理方案磁盘存取环节&#xff1a;透明数据加密DB 后置处理 最近由于工作需要&#xff0c;我对欧洲的通用数据保护条例做了调研和学习&#xff0c;其中有非常重要的一点&#xff0c;也是常识性的一条&#xff0c;就是需要对用户的个人隐私数据做好加…

webpack实际实践优化项目

参考&#xff1a; 如何通过性能优化&#xff0c;将包的体积压缩了62.7% 雅虎35条 20210526-webpack深入学习&#xff0c;搭建和优化react项目 本文只专注于性能优化的这个部分。 总体来说分为两个方面&#xff1a;第一是开发环境中主要优化打包速度&#xff0c;第二是线上环境…

BIG DATA —— 大数据时代

大数据时代 [英] 维克托 迈尔 — 舍恩伯格 肯尼斯 库克耶 ◎ 著 盛杨燕 周涛◎译 《大数据时代》是国外大数据研究的先河之作&#xff0c;本书作者维克托迈尔舍恩伯格被誉为“大数据商业应用第一人”&#xff0c;他在书中前瞻性地指出&#xff0c;大数据带来的信息…

python-自动化篇-运维-网络-IP

文章目录 IP自我介绍IPy安装模块windowsLinux IPy介绍支持大多数 IP 地址格式IPv4 地址IPv6 地址网络掩码和前缀 派生网络地址将地址转换为字符串使用多个网络多网络计算方法 IP自我介绍 IP地址规划是网络设计中非常重要的一个环节&#xff0c;规划的好坏会直接影响路由协议算…

2024年【天津市安全员B证】考试技巧及天津市安全员B证复审模拟考试

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 2024年天津市安全员B证考试技巧为正在备考天津市安全员B证操作证的学员准备的理论考试专题&#xff0c;每个月更新的天津市安全员B证复审模拟考试祝您顺利通过天津市安全员B证考试。 1、【多选题】《建设行政处罚决定…

力扣刷题之旅:进阶篇(六)—— 图论与最短路径问题

力扣&#xff08;LeetCode&#xff09;是一个在线编程平台&#xff0c;主要用于帮助程序员提升算法和数据结构方面的能力。以下是一些力扣上的入门题目&#xff0c;以及它们的解题代码。 --点击进入刷题地址 引言 在算法的广阔天地中&#xff0c;图论是一个非常重要的领域。…

《Go 简易速速上手小册》第8章:网络编程(2024 最新版)

文章目录 8.1 HTTP 客户端与服务端编程 - Go 语言的网络灯塔与探航船8.1.1 基础知识讲解服务端编程客户端编程 8.1.2 重点案例&#xff1a;简易博客服务服务端实现客户端实现运行示例 8.1.3 拓展案例 1&#xff1a;增加文章评论功能功能描述服务端实现客户端实现 8.1.4 拓展案例…

MATLAB导出图程序

本文将以代码的形式快速介绍MATLAB导出图到Paper 1 从simulation导出数 2 与simulation同源文件夹下创建导图m文件 代码如下&#xff1a; % 实验后的数据处理用 M-文件 % clear all % 清空工作空间 % close all      % 关闭所有图形窗口 % load adp.mat …

二叉树前序中序后序遍历(非递归)

大家好&#xff0c;又和大家见面啦&#xff01;今天我们一起去看一下二叉树的前序中序后序的遍历&#xff0c;相信这个对大家来说是信手拈来&#xff0c;但是&#xff0c;今天我们并不是使用常见的递归方式来解题&#xff0c;我们采用迭代方式解答。我们先看第一道前序遍历 1…

把Activity当做dialog对话框使用

1、引言 在安卓开发中对话框的使用是不可避免的&#xff0c;但是原生的对话框用起来总感觉差点意思&#xff0c;而且位置不好控制&#xff0c;在与界面的交互上也不够灵活&#xff0c;没有像activity那样的生命周期方法&#xff0c;以至于某些特殊的功能无法实现。此时我们就希…

MySQL 基础知识(八)之用户权限管理

目录 1 MySQL 权限管理概念 2 用户管理 2.1 创建用户 2.2 查看当前登录用户 2.3 修改用户名 2.4 删除用户 3 授予权限 3.1 授予用户管理员权限 3.2 授予用户数据库权限 3.3 授予用户表权限 3.4 授予用户列权限 4 查询权限 5 回收权限 1 MySQL 权限管理概念 关于 M…