【C语言】线程----同步、互斥、条件变量

目录

3. 同步

3.1 概念

3.2 同步机制

3.3 函数接口

1. 同步

1.1 概念

同步(synchronization)指的是多个任务(线程)按照约定的顺序相互配合完成一件事情

1.2 同步机制

通过信号量实现线程间的同步

信号量：通过信号量实现同步操作；由信号量来决定线程是继续运行还是阻塞等待.

信号量代表某一类资源，其值表示系统中该资源的数量:

信号量的值>0,表示有资源可以用, 可以申请到资源,

信号量的值<=0, 表示没有资源可以用, 无法申请到资源, 阻塞.

信号量还是一个受保护的变量，只能通过三种操作来访问：初始化、Ｐ操作(申请资源)、Ｖ操作(释放资源)

sem_init: 信号量初始化

sem_wait: 申请资源,P操作, 如果没有资源可以用, 阻塞,-1

sem_post: 释放资源,V操作, 非阻塞 +1

1.3 函数接口

int  sem_init(sem_t *sem,  int pshared,  unsigned int value)  功能：初始化信号量   
参数：sem：初始化的信号量对象pshared：信号量共享的范围(0: 线程间使用   非0:1进程间使用)value：信号量初值
返回值：成功 0失败 -1int  sem_wait(sem_t *sem)  功能：申请资源  P操作 
参数：sem：信号量对象
返回值：成功 0失败 -1注：此函数执行过程，当信号量的值大于0时，表示有资源可以用，则继续执行，同时对信号量减1；当信号量的值等于0时，表示没有资源可以使用，函数阻塞int  sem_post(sem_t *sem)   功能：释放资源  V操作      
参数：sem：信号量对象
返回值：成功 0失败 -1注：释放一次信号量的值加1，函数不阻塞
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;
char str[32];void *handler_thread(void *arg)
{while (1) //输出{//申请资源sem_wait(&sem); //P操作，申请到资源-1，申请不到会阻塞等待着申请资源if (strcmp(str, "quit") == 0)break;printf("%s\n", str);}
}int main(int argc, char const *argv[])
{pthread_t tid;if (pthread_create(&tid, NULL, handler_thread, NULL) != 0){perror("thread create err");return -1;}//信号量初始化if (sem_init(&sem, 0, 0) != 0){perror("sem_init err");return -1;}while (1) //输入{scanf("%s", str);//输入完成之后，释放资源sem_post(&sem); //V操作 +1if (strcmp(str, "quit") == 0)break;}pthread_join(tid,NULL);return 0;
}

两个信号量：

#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>sem_t sem;
sem_t sem1;
char str[32];void *handler_thread(void *arg)
{while (1) //输出{//申请资源sem_wait(&sem); //P操作，申请到资源-1，申请不到会阻塞等待着申请资源if (strcmp(str, "quit") == 0)break;printf("%s\n", str);sem_post(&sem1);}
}int main(int argc, char const *argv[])
{pthread_t tid;if (pthread_create(&tid, NULL, handler_thread, NULL) != 0){perror("thread create err");return -1;}//信号量初始化if (sem_init(&sem, 0, 0) != 0){perror("sem_init err");return -1;}if (sem_init(&sem1, 0, 1) != 0){perror("sem_init err");return -1;}while (1) //输入{sem_wait(&sem1);scanf("%s", str);//输入完成之后，释放资源sem_post(&sem); //V操作 +1if (strcmp(str, "quit") == 0)break;}pthread_join(tid,NULL);return 0;
}

2. 互斥

2.1 概念

互斥：多个线程在访问临界资源时，同一时间只能一个线程访问

临界资源：一次仅允许一个线所使用的资源

临界区：指的是一个访问共享资源的程序片段

互斥锁：通过互斥锁可以实现互斥机制，主要用来保护临界资源，每个临界资源都由一个互斥锁来保护，线程必须先获得互斥锁才能访问临界资源，访问完资源后释放该锁。如果无法获得锁，线程会阻塞直到获得锁为止。

pthread_mutex_init

pthread_mutex_lock

pthread_mutex_unlock

2.2 函数接口

int  pthread_mutex_init(pthread_mutex_t  *mutex, pthread_mutexattr_t *attr)  功能：初始化互斥锁  
参数：mutex：互斥锁attr:  互斥锁属性  //  NULL表示缺省属性
返回值：成功 0失败 -1int  pthread_mutex_lock(pthread_mutex_t *mutex)   功能：申请互斥锁     
参数：mutex：互斥锁
返回值：成功 0失败 -1注：和pthread_mutex_trylock区别：pthread_mutex_lock是阻塞的；pthread_mutex_trylock不阻塞，如果申请不到锁会立刻返回int  pthread_mutex_unlock(pthread_mutex_t *mutex)   功能：释放互斥锁     
参数：mutex：互斥锁
返回值：成功 0失败 -1int  pthread_mutex_destroy(pthread_mutex_t  *mutex)  功能：销毁互斥锁     
参数：mutex：互斥锁

例如：打印倒置数组功能

#include<stdio.h>
#include<pthread.h>
#include<unistd.h>int a[10] = {0,1,2,3,4,5,6,7,8,9};
pthread_mutex_t lock;void *handler_swap(void *arg)
{int t;while (1){pthread_mutex_lock(&lock);for(int i=0;i<5;i++){t=a[i];a[i]=a[9-i];a[9-i]=t;}pthread_mutex_unlock(&lock);}return NULL;
}void *handler_printf(void *arg)
{while (1){pthread_mutex_lock(&lock);for (int i = 0; i < 10; i++)printf("%d ",a[i]);printf("\n");     pthread_mutex_unlock(&lock);sleep(1);   //互斥锁里面减少耗时大的操作}
}int main(int argc, char const *argv[])
{pthread_t t1,t2;pthread_create(&t1,NULL,handler_swap,NULL);pthread_create(&t2,NULL,handler_printf,NULL);//初始化互斥锁if(pthread_mutex_init(&lock,NULL) != 0){perror("mutex init err");return -1;}pthread_join(t1,NULL);pthread_join(t2,NULL);return 0;
}

补充：死锁

是指两个或两个以上的进程在执行过程中，由于竞争资源或者由于彼此通信而造成的一种阻塞的现象，若无外力作用，它们都将无法推进下去。

死锁产生的四个必要条件

1、互斥使用，即当资源被一个线程使用(占有)时，别的线程不能使用

2、不可抢占，资源请求者不能强制从资源占有者手中夺取资源，资源只能由资源占有者主动释放。

3、请求和保持，即当资源请求者在请求其他的资源的同时保持对原有资源的占有。

4、循环等待，即存在一个等待队列：P1占有P2的资源，P2占有P3的资源，P3占有P1的资源。这样就形成了一个等待环路。

注意：当上述四个条件都成立的时候，便形成死锁。当然，死锁的情况下如果打破上述任何一个条件，便可让死锁消失。

 

3. 条件变量

条件变量用于在线程之间传递信号，以便某些线程可以等待某些条件发生。当某些条件发生时，条件变量会发出信号，使等待该条件的线程可以恢复执行。

一般和互斥锁搭配使用，实现同步机制:

pthread_cond_init(&cond,NULL); //初始化条件变量

使用前需要上锁：

pthread_mutex_lock(&lock); //上锁

判断条件

pthread_cond_wait(&cond, &lock); //阻塞等待条件产生，没有条件产生时阻塞，同时解锁，当条件产生时结束阻塞，再次上锁

pthread_cond_signal(&cond); //产生条件，不阻塞

pthread_cond_destroy(&cond); //销毁条件变量

注意： 必须保证让pthread_cond_wait先执行，pthread_cond_signal再产生条件

为什么pthread_cond_wait前要加互斥锁：防止调用 pthread_cond_wait之前其他线程改变条件，从而发生错乱。

例如：当value满足大于等于0才做某事

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>int value = 0;
pthread_mutex_t lock;
pthread_cond_t cond;//从线程
void *slave(void *arg)
{pthread_mutex_lock(&lock);if (value <= 0) //需要value>0,所以value<=0就是条件不满足，value初值为0{//阻塞等待条件产生，没有条件产生时，阻塞并解锁，当条件产生时结束阻塞，再次上锁。pthread_cond_wait(&cond, &lock);//条件满足，进行相关处理printf("make samething!\n");}pthread_mutex_unlock(&lock);return NULL;
}int main(int argc, char const *argv[])
{pthread_t tid;pthread_create(&tid, NULL, slave, NULL);pthread_mutex_init(&lock, NULL);pthread_cond_init(&cond, NULL);sleep(2); //保证从线程先执行，先pthread_cond_waitpthread_mutex_lock(&lock);scanf("%d", &value);while (value <= 0){value++;printf("%d\n", value);}if (value > 0)pthread_cond_signal(&cond);pthread_mutex_unlock(&lock);pthread_join(tid, NULL);pthread_cond_destroy(&cond);return 0;
}

例如： 赚钱和花钱

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>int money = 0;
pthread_mutex_t lock;
pthread_cond_t cond;
pthread_cond_t cond1;//花钱
void *spend_money(void *arg)
{while (1){pthread_mutex_lock(&lock);if (money < 100)    //<100就没钱花了等待赚钱线程赚钱，达到>=100才开始花钱pthread_cond_wait(&cond, &lock);while (money >= 100){money -= 100;printf("money:%d trillion\n", money);}if (money < 100)    //花完钱告诉赚钱线程继续下次赚钱pthread_cond_signal(&cond1);pthread_mutex_unlock(&lock);}return NULL;
}int main(int argc, char const *argv[])
{pthread_t tid;pthread_create(&tid, NULL, spend_money, NULL);pthread_mutex_init(&lock, NULL);pthread_cond_init(&cond, NULL);pthread_cond_init(&cond1, NULL);//赚钱while (1){// sleep(1);pthread_mutex_lock(&lock);if (money >= 100)  //>=100就不用赚钱了阻塞等待花钱，等花完钱再继续赚钱。pthread_cond_wait(&cond1, &lock);scanf("%d", &money);if (money >= 100)  //赚够>=100的钱就告诉花钱线程去花钱pthread_cond_signal(&cond);pthread_mutex_unlock(&lock);}return 0;
}

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

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

相关文章

Linux内核的启动

Linux内核的启动

一、需求 Linux系统中内核处于硬件和应用层之间。整个系统启动和初始化的过程&#xff0c;Linux内核是在主处理器启动之后才会执行。不同的处理器启动流程并不相同&#xff0c;这就要求内核能支持各种处理器的初始化操作。Liux内核各个模块&#xff0c;大部分设计时做到了体系…
阅读更多...
[手机Linux] ubuntu 错误解决

[手机Linux] ubuntu 错误解决

Ubuntu: 1,ttyname failed: Inappropriate ioctl for device 将 /root/.profile 文件中的 mesg n || true 改为如下内容。 vim /root/.profile tty -s && mesg n || true 2,Errors were encountered while processing: XXX XXXX sudo apt-get --purge remove xxx…
阅读更多...
Docker的入门

Docker的入门

一、安装Docker 本教程参考官网文档&#xff0c;链接如下: CentOS | Docker Docs 这个教程是基于你的虚拟机已经弄好了&#xff08;虚拟机用的CentOS&#xff09;&#xff0c;并且有SecureCRT或者MobaXterm等等任意一个工具 1.1 卸载旧版 如果系统中存在旧版本的Docker&a…
阅读更多...
Onedrive精神分裂怎么办（有变更却不同步）

Onedrive精神分裂怎么办（有变更却不同步）

Onedrive有时候会分裂&#xff0c;你在本地删除文件&#xff0c;并没有同步到云端&#xff0c;但是本地却显示同步成功。 比如删掉了一个目录&#xff0c;在本地看已经删掉&#xff0c;onedrive显示已同步&#xff0c;但是别的电脑并不会同步到这个删除操作&#xff0c;在网页版…
阅读更多...
机器学习06-正则化

机器学习06-正则化

机器学习06-正则化 文章目录 机器学习06-正则化0-核心逻辑脉络1-参考网址3-大模型训练中的正则化1.正则化的定义与作用2.常见的正则化方法及其应用场景2.1 L1正则化&#xff08;Lasso&#xff09;2.2 L2正则化&#xff08;Ridge&#xff09;2.3 弹性网络正则化&#xff08;Elas…
阅读更多...
windows 极速安装 Linux （Ubuntu）-- 无需虚拟机

windows 极速安装 Linux （Ubuntu）-- 无需虚拟机

1. 安装 WSL 和 Ubuntu 打开命令行&#xff0c;执行 WSL --install -d ubuntu若报错&#xff0c;则先执行 WSL --update2. 重启电脑 因安装了子系统&#xff0c;需重启电脑才生效 3. 配置 Ubuntu 的账号密码 打开 Ubuntu 的命令行 按提示&#xff0c;输入账号&#xff0c;密…
阅读更多...
微信小程序实现个人中心页面

微信小程序实现个人中心页面

文章目录 1. 官方文档教程2. 编写静态页面3. 关于作者其它项目视频教程介绍 1. 官方文档教程 https://developers.weixin.qq.com/miniprogram/dev/framework/ 2. 编写静态页面 mine.wxml布局文件 <!--index.wxml--> <navigation-bar title"个人中心" ba…
阅读更多...
Qt/C++进程间通信：QSharedMemory 使用详解（附演示Demo）

Qt/C++进程间通信：QSharedMemory 使用详解（附演示Demo）

在开发跨进程应用程序时&#xff0c;进程间通信&#xff08;IPC&#xff09;是一个关键问题。Qt 框架提供了多种 IPC 技术&#xff0c;其中 QSharedMemory 是一种高效的共享内存方式&#xff0c;可以实现多个进程之间快速交换数据。本文将详细讲解 QSharedMemory 的概念、用法及…
阅读更多...
[UE4图文系列] 5.字符串转中文乱码问题说明

[UE4图文系列] 5.字符串转中文乱码问题说明

原文连接&#xff1a;[UE4图文系列] 5.字符串转中文乱码问题说明 - 哔哩哔哩 本例以原生C和UE4 C字符串传输中出现的中文乱码问题进行说明 一.乱码示例: 1.直接用中文字符串初始化FString,在蓝图中进行打印 FString GetStrWithChinese() {FString fstr"这是一句中文"…
阅读更多...
人工智能任务19-基于BERT、ELMO模型对诈骗信息文本进行识别与应用

人工智能任务19-基于BERT、ELMO模型对诈骗信息文本进行识别与应用

大家好&#xff0c;我是微学AI&#xff0c;今天给大家介绍一下人工智能任务19-基于BERT、ELMO模型对诈骗信息文本进行识别与应用。近日&#xff0c;演员王星因接到一份看似来自知名公司的拍戏邀约&#xff0c;被骗至泰国并最终被带到缅甸。这一事件迅速引发了社会的广泛关注。该…
阅读更多...
题解 CodeForces 430B Balls Game 栈 C/C++

题解 CodeForces 430B Balls Game 栈 C/C++

题目传送门&#xff1a; Problem - B - Codeforceshttps://mirror.codeforces.com/contest/430/problem/B翻译&#xff1a; Iahub正在为国际信息学奥林匹克竞赛&#xff08;IOI&#xff09;做准备。有什么比玩一个类似祖玛的游戏更好的训练方法呢&#xff1f; 一排中有n个球…
阅读更多...
通过proto文件构建 完整的 gRPC 服务端和客户端案例

通过proto文件构建 完整的 gRPC 服务端和客户端案例

基础教程-简单案例&#xff08;快入入门java-grpc框架&#xff09; 参考官方入门案例教程&#xff1a;里面我看proto编译&#xff0c;其实直接用maven就能直接将.proto文件编译成java代码。快速入门 | Java | gRPC 框架https://grpc.org.cn/docs/languages/java/quickstart/ …
阅读更多...
Mysql--运维篇--备份和恢复（逻辑备份，mysqldump，物理备份，热备份，温备份，冷备份，二进制文件备份和恢复等）

Mysql--运维篇--备份和恢复（逻辑备份，mysqldump，物理备份，热备份，温备份，冷备份，二进制文件备份和恢复等）

MySQL 提供了多种备份方式&#xff0c;每种方式适用于不同的场景和需求。根据备份的粒度、速度、恢复时间和对数据库的影响&#xff0c;可以选择合适的备份策略。主要备份方式有三大类&#xff1a;逻辑备份&#xff08;mysqldump&#xff09;&#xff0c;物理备份和二进制文件备…
阅读更多...
如何修复Android上未安装的应用程序

如何修复Android上未安装的应用程序

在Android设备上安装应用程序通常是一个简单的过程。然而&#xff0c;“ Android上未安装应用程序”是一种常见的智能手机错误消息&#xff0c;由于一个或多个原因而经常遇到。发现由于即将出现故障而无法充分利用手机&#xff0c;这当然会非常令人沮丧&#xff0c;但幸运的是&…
阅读更多...
干净卸载Windows的Node.js环境的方法

干净卸载Windows的Node.js环境的方法

本文介绍在Windows电脑中&#xff0c;彻底删除Node.js环境的方法。 在之前的文章Windows系统下载、部署Node.js与npm环境的方法&#xff08;https://blog.csdn.net/zhebushibiaoshifu/article/details/144810076&#xff09;中&#xff0c;我们介绍过在Windows电脑中&#xff0…
阅读更多...
初始Java4

初始Java4

目录 一.继承 1.定义&#xff1a; 2.继承的语法&#xff1a; 3.子类访问父类 4.子类构造方法 5.super与this 6.继承方法 7.final关键字 &#xff08;1&#xff09;.变量不变 &#xff08;2&#xff09;.方法不变 &#xff08;3&#xff09;.类不可继承 8.继承与组合…
阅读更多...
算法竞赛（蓝桥杯）贪心算法1——数塔问题

算法竞赛（蓝桥杯）贪心算法1——数塔问题

题目描述 有如下所示的数塔&#xff0c;要求从底层走到顶层&#xff0c;若每一步只能走到相邻的结点&#xff0c;则经过的结点的数字之和最大是多少&#xff1f; 输入 输入数据首先包括一个整数整数 N (1≤N≤100)&#xff0c;表示数塔的高度&#xff0c;接下来用 N 行数字表示…
阅读更多...
MATLAB学习笔记-table

MATLAB学习笔记-table

1.在table中叠加table table 的每一列具有固定的数据类型。如果要让表的所有单元格都可以任意填充&#xff0c;就得让每一列都是 cell 类型&#xff0c;这样表中每个单元格都是“一个元胞”。创建时可以先构造一个 空 cell 数组&#xff08;大小为行数列数&#xff09;&#x…
阅读更多...
RabbitMQ(三)

RabbitMQ(三)

RabbitMQ中的各模式及其用法 工作队列模式一、生产者代码1、封装工具类2、编写代码3、发送消息效果 二、消费者代码1、编写代码2、运行效果 发布订阅模式一、生产者代码二、消费者代码1、消费者1号2、消费者2号 三、运行效果四、小结 路由模式一、生产者代码二、消费者代码1、消…
阅读更多...
django在线考试系统

django在线考试系统

Django在线考试系统是一种基于Django框架开发的在线考试平台&#xff0c;它提供了完整的在线考试解决方案。 一、系统概述 Django在线考试系统旨在为用户提供便捷、高效的在线考试环境&#xff0c;满足教育机构、企业、个人等不同场景下的考试需求。通过该系统&#xff0c;用…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023