Linux多线程C++版（九） 线程同步和互斥-----线程信号量

news2024/11/16 2:23:43

目录

        • 1.基本概念
        • 2.信号量创建和销毁
        • 3.信号量加和减操作
        • 4.代码理解信号量
        • 5.信号量实例银行账户取款----实现互斥
        • 6.信号量实例计算和取结果----实现线程同步

1.基本概念

  • 信号量从本质上是一个非负整数计数器，是共享资源的的数目，通常被用来控制对共享资源的访问。
  • 信号量可以实现线程的同步和互斥
  • 通过sem_post()和sem_wait函数对信号量进行加减操作从而解决线程的同步和互斥
  • 信号量数据类型 sem_t

2.信号量创建和销毁

//信号量的定义
sem_t sem;
int sem_t_init(sem_t *sem,int pshared,unsigned value);
int sem_t_destroy(sem_t *sem);
返回：成功返回0 出错返回错误编号
  • 参数
    • sem：信号量指针
    • pshared：是否可以跨进程使用，0为不共享，1为共享
    • value：信号量的初始值

3.信号量加和减操作

int sem_post(sem_t *sem); //功能：增加信号量的值
int sem_wait(sem_t *sem); //功能：减少信号量的值
int sem_trywait(sem_t *sem);//sem_wait()非阻塞版本
返回：成功返回0 出错返回错误编号
  • 调用sem_post() 一次信号量做 加1操作
  • 调用sem_wait() 一次信号量做 减1操作
  • 当线程调用sem_wait()后，若信号量的值小于0则线程阻塞。只有其他线程在调用sem_post()对信号量做加操作后并且其值大于或等于0时，阻塞的线程才能继续运行

4.代码理解信号量

/*
	创建三个子线程，使用信号量去控制三个子线程的运行顺序。
*/
#include<semaphore.h>
#include<pthread.h>
#include<stdio.h>
#include<stdlib.h>
//定义两个线程信号量
sem_t sem1,sem2;
void* a_fn(void *arg){
    sem_wait(sem1);//此时sem1为0，再减一 线程堵塞
    printf("thread a running\n");
    return(void*)0;
}
void* b_fn(void *arg){
    sem_wait(sem2);//此时sem2为0，再减一 线程堵塞
    printf("thread b running\n");
    //释放线程a,让阻塞的线程a继续操作
    sem_post(sem1)
    return(void*)0;
}
void* c_fn(void *arg){
    printf("thread c running\n");
    //释放线程b(此时sem2为0，加1)
    //让阻塞的线程b继续运行
    sem_post(sem2);
    return(void*)0;
}
int main(void){
    int err;
	pthread_t a,b,c;
    
    //线程信号量的初始化，初始值为0
    sem_t_init(&sem1,0,0);
    sem_t_init(&sem2,0,0);
    
    //创建线程
	if ((err = pthread_create(&a, null, a_fn, (void*)0)) != 0) {
		perror("pthread_create error");
	}
    if ((err = pthread_create(&b, null, b_fn, (void*)0)) != 0) {
		perror("pthread_create error");
	}
    if ((err = pthread_create(&c, null, c_fn, (void*)0)) != 0) {
		perror("pthread_create error");
	}
    
    //主线程要等三个子线程执行完毕
    pthread_join(a,null);
    pthread_join(b,null);
    pthread_join(c,null);
    //线程信号的销毁
   	sem_t_destroy(&sem1);
    sem_t_destroy(&sem2);
    return 0;
}

5.信号量实例银行账户取款----实现互斥

头文件 account.h

#ifndef __ACCOUNT_H__
#define __ACCOUNT_H__
#include <pthread.h>
#include <semaphore.h>
//银行账户结构体
typedef struct{
    int code;//卡号
    double balance;//余额
    sem_t sem;//线程信号量
    
}Account;
//创建账户
extern Account* creat_account(int code,double balance);
//销毁账户
extern void destory_account(Account *a);
//取款
extern double withdraw(Account *a,double amt);
//存款
extern double deposit(Account *a,double amt);
//查看账户余额
extern double get_balance(Account *a);
#endif

功能文件account.c

#include "account.h"
#include <malloc.h>
#include <assert.h>
#include <string.h>
#include <semaphore.h>
//创建账户
Account* creat_account(int code,double balance){
    //创建账户在堆当中
    Account *a = (Account*)malloc(sizeof(Account));
    assert(a != NULL);//用来判断a指针所需要开辟的空间，开辟成功了吗，成功就继续，否则就程序终止运行。
    a->code = code;
    a->balance = balance;
   //线程信号量的初始化，初始值为1
    sem_t_init(&a->sem,0,1);
    return a;
}
//销毁账户
void destory_account(Account *a){
    assert(a != NULL);
    //销毁线程信号量
    	sem_t_destroy(&a->sem);
    free(a);//释放空间
}
//取款
double withdraw(Account *a,double amt){
    assert(a != NULL);//判断指针a是否为空
    //使信号量减一  锁定
    sem_wait(&a->sem);
    if(amt < 0 || amt > a->balance){
        //使信号量加一  解锁
        sem_post(&a->sem);
        return 0.0;
    }
    double balance = a->balance;
    sleep(1);
    balance -= amt;
    a->balance = balance;
    //使信号量加一   解锁
    sem_post(&a->sem);
    return amt;
}
//存款
double deposit(Account *a,double amt){
   assert(a != NULL);
   //使信号量减一  锁定
   sem_wait(&a->sem);
   if(amt < 0){
       //使信号量加一   解锁
       sem_post(&a->sem);
       return 0.0;
   }
    double balance = a->balance;
    sleep(1);
    balance += amt;
    a->balance = balance;
    //使信号量加一   解锁
    sem_post(&a->sem);
    return amt;
}
//查看账户余额
double get_balance(Account *a){
    assert(a != NULL);
   	//使信号量减一  锁定
   	sem_wait(&a->sem);
    double balance = a->balance;
    //使信号量加一   解锁
    sem_post(&a->sem);
    return balanec;
}

执行文件 account_test.c

#include "account.h"
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

//操作者的结构体
typedef struct{
    char  name[20];//操作者姓名
    Account *account;//账户
    double amt;//金额
}OperArg
//定义取款操作的线程运行函数
void* withdraw_fn(void *arg){
    OperArg *oa = (OperArg*)arg;
    //deposit存款函数
    double amt = deposit(oa->account,oa->amt);
    printf("%8s(0x%lx) deposit %f from account %d/n",oa->name,pthread_self(),amt,oa->account->code);
    return (void*)0;
}
//定义存款操作的线程运行函数
void* deposit_fn(void *arg){
    OperArg *oa = (OperArg*)arg;
    //withdraw取款函数
    double amt = withdraw(oa->account,oa->amt);
    printf("%8s(0x%lx) withdraw %f from account %d/n",oa->name,pthread_self(),amt,oa->account->code);
    return (void*)0;
}
//定义查看银行账户的线程运行函数
void* check_fn(void *arg){
    
}
int main(void){
    int err;
    pthread_t boy,girl;
    Account *a = create_account(10001,10000)//卡号，余额
        
    OperArg o1 , o2;//两个操作者
    strcpy(o1.name,"boy");//strcpy()把第二个参数值，放到第一个参数中
    o1.account = a;
    o1.amt = 10000;
    
    strcpy(o2.name,"girl");
    o2.account = a;
    o2.amt = 10000;
    
    //启动两个子线程（boy和girl）同时去操作同一个银行账户
    if((err = pthread_create(&boy,null,withdraw_fn,(void*)&o1)!=0){
        printf("pthread create error");
    }
    if((err = pthread_create(&girl,null,withdraw_fn,(void*)&o2)!=0){
        printf("pthread create error");
    }
    
    pthread_join(boy,null);
    pthread_join(girl,null);
       
    //查看账户余额
    printf("account balance %f/n",get_balance(a));
    //销毁账户
    destroy_account(a);
    return 0;
}

程序运行结果：
在这里插入图片描述

6.信号量实例计算和取结果----实现线程同步

思路：

在这里插入图片描述

#include<pthread.h>
#include<stdio.h>
#include<stdlib.h>
#include<semaphore.h>
/*
	一个线程赋值计算结果，一个线程负责获取结果
	当计算结果的线程没有执行完毕，获取结果的线程要等待(阻塞)
*/
typedef struct{
    int res;//存放运算结果
    sem_t sem//线程信号量
}Result;

//计算并将结果放置Result中的线程运行函数
void* set_fn(void *arg){
    int sum;
    for(int i =1;i<=100;i++){
        sum +=i;
    }
    //将结果存放到Result
    Result *r = (Result*)arg;
    r->res = sum;
    //对线程信号量 加一  
    sem_post(&r->sem);
    return(void*) 0;
}

//获得结果的线程运行函数
void* get_fn(void *arg){
    Result *r = (Result*)arg;
    
    //对线程信号量 减一  
    sem_wait(&r->sem);
    //去获取计算的结果
    int res = r->res;
    printf("ox%lx get sum is %d\n",pthread_self(),res);
    return(void*)0;
}

int main(void){
    int err;
	//定义线程标识符cal get
	pthread_t cal, get;
    
    //线程信号量初始化
    sem_init(&r.sem,0.0);
 
    //启动获取结果的线程
	if ((err = pthread_create(&get, NULL, get_fn, (void*)&r)) != 0) {
		perror("pthread_create error");
	}
    //启动计算结果的线程
    if ((err = pthread_create(&cal, NULL, set_fn, (void*)&r)) != 0) {
		perror("pthread_create error");
	}
    
    //主线程要等两个子线程执行完毕
    pthread_join(get,null);
    pthread_join(cal,null);
    
    //线程信号量的销毁
    sem_destroy(&r.sem);
    return 0;
}

程序运行结果：

在这里插入图片描述

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

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

相关文章

[附源码]JAVA毕业设计同学录网站（系统+LW）

[附源码]JAVA毕业设计同学录网站（系统+LW）

[附源码]JAVA毕业设计同学录网站&#xff08;系统LW&#xff09; 项目运行 环境项配置&#xff1a; Jdk1.8 Tomcat8.5 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#…
阅读更多...
从源码出发剖解正则表达式

从源码出发剖解正则表达式

✨✨hello&#xff0c;愿意点进来的小伙伴们&#xff0c;你们好呐&#xff01; &#x1f43b;&#x1f43b;系列专栏&#xff1a;【JavaSE】 &#x1f432;&#x1f432;本篇内容&#xff1a;详解正则表达式 &#x1f42f;&#x1f42f;作者简介:一名现大二的三非编程小白&…
阅读更多...
[ MySQL ] 使用Navicat进行MySQL数据库备份 / 还原（备份.nb3文件方式）

[ MySQL ] 使用Navicat进行MySQL数据库备份 / 还原（备份.nb3文件方式）

本文主要讲解如何用Navicat&#xff08;Navicat Premium &#xff0c;或者Navicat for mysql&#xff09;进行MySQL备份和恢复数据库。 本文主要大纲为&#xff1a;使用Navicat备份工具方式进行备份和还原&#xff0c;其中包括还原自身数据库和还原到其他目标库。 文章目录一、…
阅读更多...
Jenkins 中 shell 脚本执行失败却不自行退出

Jenkins 中 shell 脚本执行失败却不自行退出

Jenkins 中 执行 shell 脚本时&#xff0c;有时候 shell 执行失败了&#xff0c;或者判断结果是错误的&#xff0c;但是 Jenkins 执行完成后确提示成功 success 。 此时&#xff0c;可以通过条件判断来解决这个问题&#xff0c;让 Jenkins 强制退出并提示执行失败 failed 。 …
阅读更多...
Tensorflow笔记

Tensorflow笔记

Tensorflow笔记基础概念计算图Eager Execution&#xff08;即刻执行&#xff09;eager模式下计算梯度基本使用tf.app加载flag&#xff08;tf.app.flags&#xff09;启动( tf.app.run )基础概念 计算图 Tensor&#xff08;张量&#xff09;&#xff0c;在Tensorflow中可以理解…
阅读更多...
畅聊两小时后谈谈chatGPT体验感受

畅聊两小时后谈谈chatGPT体验感受

文章目录背景注册聊天实录基于自然语言的SQL翻译shell解析k8s回答其他类型我的问题为何这么接近人类的回答&#xff1f;回答是离线的吗&#xff1f;背景 最近几周不管是T还是微信公众号&#xff0c;大家都在疯玩这个东西。 我姑且将这个应用叫小C吧。我和小C愉快的聊了几个小…
阅读更多...
ComponentOne Studio Enterprise 2022

ComponentOne Studio Enterprise 2022

ComponentOne Studio Enterprise 2022 添加了Microsoft.NET 7支持。 FlexGrid for.NET MAUI预览版-您现在可以使用以前使用的相同.NET数据网格&#xff0c;只是它是为MAUI本机开发的&#xff0c;因此您不必学习多种移动开发平台。 WinForms 2022 v3中的新功能 增强的.NET 6控件…
阅读更多...
Android系统属性文件浅析

Android系统属性文件浅析

Android的属性文件是Android系统攻防中重要的一环，属性中的一些只读字段(以ro开头)通常会被当作大厂的指纹而加入检测，于是如何mock和检测mock成了安全中举足轻重的知识。属性的检测有几种方案： 通过java标准接口的Build类读取通过shell的getprop [属性key]的方式读取通过sh…
阅读更多...
Python作业题：函数和代码复用

Python作业题：函数和代码复用

本次练习题涉及到的知识点&#xff1a; Python中函数的定义和使用传入函数的参数个数不固定的使用语法lambda函数的使用语法Python异常处理的相关语法 1.关于函数的描述&#xff0c;错误的选项是&#xff08;A&#xff09;。 解析&#xff1a;Python使用保留字def定义一个函…
阅读更多...
聚类算法OPTICS的理解及实现

聚类算法OPTICS的理解及实现

前言 前面给大家介绍到了聚类算法中比较经典的 DBSCAN 算法&#xff0c;对于数据量小而且相对比较密集、密度相似的数据集来说&#xff0c;是比较合适的。那么接下来给大家介绍它的改进版 OPTICS (Ordering points to identify the clustering structure)&#xff0c;针对 DBS…
阅读更多...
4年外包终上岸，我只能说这类公司以后能不去就不去

4年外包终上岸，我只能说这类公司以后能不去就不去

我大学学的是计算机专业&#xff0c;毕业的时候&#xff0c;对于找工作比较迷茫&#xff0c;也不知道当时怎么想的&#xff0c;一头就扎进了一家外包公司&#xff0c;一干就是4年。现在终于跳槽到了互联网公司了&#xff0c;我想说的是&#xff0c;但凡有点机会&#xff0c;千万…
阅读更多...
vue使用axios+element上传文件

vue使用axios+element上传文件

引言 springboot后端接口类型&#xff1a;post&#xff0c;其它接口信息如下图 后端接口的实现 代码示例 post 请求头改成’Content-Type’: ‘multipart/form-data’用new FormData() 方式去传对象数据 axios封装请求 import request from /utils/request export function up…
阅读更多...
线性表-顺序表

线性表-顺序表

线性表 线性表是最基本、最简单、也是最常用的一种数据结构。一个线性表是n个具有相同特性的数据元素的有限序列。 前驱元素&#xff1a;若A元素在B元素的前面&#xff0c;则称A为B的前驱元素后继元素&#xff1a;若B元素在A元素的后面&#xff0c;则称B为A的后继元素 线性表…
阅读更多...
将gitee上的项目拉取到本地

将gitee上的项目拉取到本地

gitee&#xff1a;中国最大的开源代码共享社区 目录 一、安装git 二、拉取项目 1、首先在gitee上找到自己想要学习的项目 2、在本地新建一个文件夹&#xff08;用来存放你从gitee上拉下来的项目&#xff09; 3、输入命令 4、选择下载的分支代码&#xff08;我这里是mas…
阅读更多...
【web课程设计】基于html鲜花商城项目的设计与实现

【web课程设计】基于html鲜花商城项目的设计与实现

&#x1f389;精彩专栏推荐 &#x1f4ad;文末获取联系 ✍️ 作者简介: 一个热爱把逻辑思维转变为代码的技术博主 &#x1f482; 作者主页: 【主页——&#x1f680;获取更多优质源码】 &#x1f393; web前端期末大作业&#xff1a; 【&#x1f4da;毕设项目精品实战案例 (10…
阅读更多...
windows下使用免安装（.zip）MariaDB数据库

windows下使用免安装（.zip）MariaDB数据库

1. 下载 https://downloads.mariadb.org/ 2. 解压 3. 配置 cmd 进入bin目录 命令行输入&#xff1a;./mysqld.exe --install MariaDB 输出&#xff1a; 至此 安装成功 接下来进行data配置和初始化 4. 初始化 提示&#xff1a;非必要 如果直接执行服务启动命令&#xff1…
阅读更多...
TF3-MongoDB基础

TF3-MongoDB基础

TF3-MongoDB基础课程介绍1、通用设置1.1 需求分析1.1.1 需求分析1.1.2 数据库表1.1.3 搭建提供者环境实体类mapper接口api接口api服务实现类1.2 查询通用设置1.2.1 接口文档1.2.2 代码实现vo对象SettingsControllerSettingServiceQuestionApiSettingApi1.2 陌生人问题1.2.1 接口…
阅读更多...
STM32单片机软件模拟I2C读取AM2320温湿度传感器数据

STM32单片机软件模拟I2C读取AM2320温湿度传感器数据

STM32单片机使用软件模拟IIC读取AM2320温湿度传感器的数据并显示在0.96寸OLED屏上。 我用的单片机是STM32F103C8T6&#xff0c;程序用的是ST标准库写的。 STM32使用硬件I2C读取SHTC3温湿度传感器&#xff1a;https://blog.zeruns.tech/archives/692.html STM32单片机读取AHT1…
阅读更多...
力扣242.有效的字母异位词(Java语言，排序法、散列表法)

力扣242.有效的字母异位词(Java语言，排序法、散列表法)

题目描述&#xff1a; 给定两个字符串 s 和 t &#xff0c;编写一个函数来判断 t 是否是 s 的字母异位词。 注意&#xff1a;若 s 和 t 中每个字符出现的次数都相同&#xff0c;则称 s 和 t 互为字母异位词。 解题思路&#xff1a; 思路1&#xff1a;排序法 根据题目意思…
阅读更多...
[附源码]Python计算机毕业设计SSM基于微信的基层党建信息系统（程序+LW)

[附源码]Python计算机毕业设计SSM基于微信的基层党建信息系统（程序+LW)

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023