互斥锁和信号量_Lewin~的博客-程序员宅基地_信号量和互斥锁

技术标签: linux应用编程  多线程  

一、同步互斥概述

  • 在多任务操作系统中,同时运行的多个任务可能都需要访问/使用同一种资源 多个任务之间有依赖关系,某个任务的运行依赖于另一个任务
    同步和互斥就是用于解决这两个问题的。

  • 互斥:一个公共资源同一时刻只能被一个进程或线程使用,多个进程或线程不能同时使用公共资源。POSIX标准中进程和线程同步和互斥的方法,主要有信号量和互斥锁两种方式。

  • 同步:两个或两个以上的进程或线程在运行过程中协同步调,按预定的先后次序运行。 同步就是在互斥的基础上有顺序

二、互斥锁

2.1 互斥锁的概念
mutex是一种简单的加锁的方法来控制对共享资源的访问,mutex只有两种状态,即上 锁(lock)和解锁(unlock)。 在访问该资源前,首先应申请mutex,如果mutex处于unlock状态,则会申请到 mutex并立即lock; 如果mutex处于lock状态,则默认阻塞申请者。 unlock操作应该由lock者进行。

2.2 互斥锁的操作
包含头文件:#include <pthread.h>
参数:mutex:互斥锁地址。
返回值: 成功:0 失败:非0
(1)初始化互斥锁
mutex用pthread_mutex_t数据类型表示,在使用互斥锁前,必须先对它进行初始化,一般将互斥锁定义为全局变量。

静态分配的互斥锁:
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
动态分配互斥锁:
pthread_mutex_t mutex; pthread_mutex_init(&mutex, NULL);

在所有使用过此互斥锁的线程都不再需要使用时候,应调用pthread_mutex_destroy销毁互斥锁。

(2) 互斥锁上锁
int pthread_mutex_lock(pthread_mutex_t *mutex);
功能:对互斥锁上锁,若已经上锁,则调用者一直阻塞到互斥锁解锁

int pthread_mutex_trylock(pthread_mutex_t *mutex);
功能:对互斥锁上锁,若已经上锁,则上锁失败,函数立即返回。

(3) 互斥锁解锁
int pthread_mutex_unlock(pthread_mutex_t * mutex);
功能:对指定的互斥锁解锁。

(4) 销毁互斥锁
int pthread_mutex_destroy(pthread_mutex_t *mutex);
功能:销毁指定的一个互斥锁。

死锁的理解
死锁就是两个线程各自占有1个资源,但又在彼此等待对方释放锁。
在这里插入图片描述

代码案例:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>

//通过互斥锁解决线程间互斥问题

int money = 10000;

//第一步:创建互斥锁(由于两个线程操作同一个互斥锁,所以定义在全局更加方便一点)
pthread_mutex_t mymutex;

void *pthread_fun1(void *arg)
{
    
    int get, yu, shiji;
    get = 10000;
    
    //第三步:对共享资源的操作进行上锁
    pthread_mutex_lock(&mymutex);

    printf("张三正在查询余额...\n");
    sleep(1);
    yu = money;

    printf("张三正在取钱...\n");
    sleep(1);
    if(get > yu)
    {
    
        shiji = 0;
    }
    else 
    {
    
        shiji = get;
        yu = yu - get;
        money = yu;
    }

    printf("张三想取%d元,实际取了%d元,余额为%d元\n", get, shiji, yu);

    //第四步:当共享资源的操作执行完毕后,对互斥锁执行解锁操作
    pthread_mutex_unlock(&mymutex);

    pthread_exit(NULL);
}

void *pthread_fun2(void *arg)
{
    
    int get, yu, shiji;
    get = 10000;

    //第三步:对共享资源的操作进行上锁
    pthread_mutex_lock(&mymutex);
    
    printf("李四正在查询余额...\n");
    sleep(1);
    yu = money;

    printf("李四正在取钱...\n");
    sleep(1);
    if(get > yu)
    {
    
        shiji = 0;
    }
    else 
    {
    
        shiji = get;
        yu = yu - get;
        money = yu;
    }

    printf("李四想取%d元,实际取了%d元,余额为%d元\n", get, shiji, yu);

    //第四步:当共享资源的操作执行完毕后,对互斥锁执行解锁操作
    pthread_mutex_unlock(&mymutex);

    pthread_exit(NULL);
}

int main(int argc, char const *argv[])
{
    
    //第二步:初始化互斥锁
    pthread_mutex_init(&mymutex, NULL);

    pthread_t thread1, thread2;

    if(pthread_create(&thread1, NULL, pthread_fun1, NULL) != 0)
    {
    
        perror("fail to pthread_create");
        exit(1);
    }

    if(pthread_create(&thread2, NULL, pthread_fun2, NULL) != 0)
    {
    
        perror("fail to pthread_create");
        exit(1);
    }

    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);

    //第五步:当互斥锁使用完毕后,要销毁
    pthread_mutex_destroy(&mymutex);
    
    return 0;
}

执行结果:
在这里插入图片描述

三、信号量

3.1 信号量的概念

  • 信号量广泛用于进程或线程间的同步和互斥,信号量本质上是一个非负的整数计数器, 它被用来控制对公共资源的访问。
  • 编程时可根据操作信号量值的结果判断是否对公共资源具有访问的权限,当信号量值大于0时,则可以访问,否则将阻塞。
  • 对信号量的操作又称之为PV操作,PV原语是对信号量的操作,一次P操作使信号量sem减1,一次V操作使信号量sem加1,对于P操作,如果信号量的sem值为等于0,则P操作就会阻塞,如果信号量的值大于0,才可以执行P操作进行减1

信号量主要用于进程或线程间的同步和互斥这两种典型情况。
1、若用于互斥,几个进程(或线程)往往只设置一个信号量。
2、若用于同步操作,往往会设置多个信号量,并且安排不同的初始值,来实现它们之间的 执行顺序。

信号量用于互斥
在这里插入图片描述
信号量用于同步
在这里插入图片描述
3.2 对信号量的基本操作
包含头文件:#include <semaphore.h>
返回值:成功返回 0,失败返回-1。
(1) 信号量的初始化
int sem_init(sem_t *sem, int pshared,unsigned int value);
功能:创建一个信号量并初始化它的值。
参数:

  • sem:信号量的地址。
  • pshared:等于 0,信号量在线程间共享;不等于 0,信号量在进程间共享。
  • value:信号量的初始值。

(2) 信号量 P 操作
int sem_wait(sem_t *sem);
功能:将信号量的值减 1,若信号量的值小于等于 0,此函数会引起调用者阻塞。
参数:sem:信号量地址。

int sem_trywait(sem_t *sem);
功能:将信号量的值减 1,若信号量的值小于等于 0,则对信号量的操作失败,函数立即返回。
参数:sem:信号量地址。

(3) 信号量的 V 操作
int sem_post(sem_t *sem);
功能:将信号量的值加 1 并发出信号唤醒等待线程。
参数:sem:信号量地址。

(4) 获取信号量的计数值
int sem_getvalue(sem_t *sem, int *sval);
功能: 获取 sem 标识的信号量的值,保存在 sval 中。
参数:

  • sem:信号量地址。
  • sval:保存信号量值的地址。

(5) 信号量的销毁
int sem_destroy(sem_t *sem);
功能:删除 sem 标识的信号量。
参数:sem:信号量地址。

代码案例1:信号量实现互斥功能

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <semaphore.h>

//通过信号量实现互斥操作

//第一步:创建一个信号量
sem_t sem;

void printer(char *str)
{
    
    //第三步:执行P操作
    //由于使用信号量实现互斥,信号量的初始值设置为1,则两个线程执行P操作,
    //先执行P操作的线程继续执行,后执行P操作的先阻塞等待
    sem_wait(&sem);
	while(*str)
	{
    
		putchar(*str);	
		fflush(stdout);
		str++;
		sleep(1);
	}
    //第四步:执行V操作
    sem_post(&sem);
}

void *thread_fun1(void *arg)
{
    
	char *str1 = "hello";
	printer(str1);
}

void *thread_fun2(void *arg)
{
    
	char *str2 = "world";
	printer(str2);
}

int main(void)
{
    
    //第二步:初始化信号量
    sem_init(&sem, 0, 1);

	pthread_t tid1, tid2;
	
	pthread_create(&tid1, NULL, thread_fun1, NULL);
	pthread_create(&tid2, NULL, thread_fun2, NULL);
	
	pthread_join(tid1, NULL);
	pthread_join(tid2, NULL); 

    printf("\n");
    
    //第五步:使用完毕后销毁信号量
    sem_destroy(&sem);

	return 0;
}

执行结果:
在这里插入图片描述

代码案例2:信号量实现同步功能

#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
#include <semaphore.h>

//使用信号量实现同步功能,如果两个线程实现同步,需要通过两个信号量

char ch = 'a';

//第一步:创建两个信号量
sem_t sem_g, sem_p;

void * pthread_g(void *arg) 
{
    
	while(1)
	{
    
        //第四步:后执行的线程中,信号量的初始值设置为0的信号量执行P操作
        sem_wait(&sem_g);

		ch++;
		sleep(1);

        //第六步:后执行的线程执行完毕后,信号量初始值为1的信号量执行V操作
        sem_post(&sem_p);
	}
}
void * pthread_p(void *arg)  //此线程打印ch的值
{
    
	while(1)
	{
    
        //第三步:先执行的线程中,信号量初始值设置为1的信号量执行P操作
        sem_wait(&sem_p);

		printf("%c",ch);
		fflush(stdout);

        //第五步:当先执行的线程执行完毕后,信号量初始值为0的信号量执行V操作
        sem_post(&sem_g);
	}
}

int main(int argc, char *argv[])
{
    
    //初始化信号量
    sem_init(&sem_g, 0, 0);
    sem_init(&sem_p, 0, 1);

	pthread_t tid1,tid2;
	
	pthread_create(&tid1,NULL,pthread_g,NULL);
	pthread_create(&tid2,NULL,pthread_p,NULL);
	
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);

    printf("\n");

    //第七步:使用完毕后销毁信号量
    sem_destroy(&sem_g);
    sem_destroy(&sem_p);

	return 0;
}

执行结果:
在这里插入图片描述

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_53762042/article/details/119704477

智能推荐

echart图表控件配置入门(常用图表数据动态绑定)_我笔记的博客-程序员宅基地

效果显著,码到病除现在分别对折线图、柱状图、饼图、中国地图四类图表的数据绑定进行详细的介绍。echarts中其它的图表方法都差不多,只要了解官方的demo,按照指定的数据结构进行解析都能很方便的得到想要的结果;echarts中提供了setOption、setSeries两个方法可以对图表的相关数据和属性进行动态设置,setOption一定要在setSeries之前设置;

虚拟主机的开端_旋枫在线的博客-程序员宅基地

<br />什么叫虚拟主机?<br />  定义1:虚拟主机(Virtual Host Virtual Server)是使用特殊的软硬件技术,把一台计算机主机分成一台台“虚拟”的主机,每一台虚拟主机都具有独立的域名和IP地址(或共享的IP地址),具有完整的Internet服务器功能。   <br />    定义2:虚拟主机是使用特殊的软硬件技术,把一台真实的物理电脑主机分割成多个的逻辑存储单元,每个单元都没有物理实体,但是每一个物理单元都能像真实的物理主机一样在网络上工作,具有单独的域名、IP地址(或共享

java中的catch中的异常e_java – catch(异常e)后跟if(e instanceof Exception)_weixin_39744606的博客-程序员宅基地

今天我偶然发现了这段代码try {...} catch (Exception e) {if (e instanceof Exception) {...} else {...}}if-else分支是否有意义?不会被捕获异常e永远是异常的一个实例?解决方法:是的,e永远是异常的一个实例.因此,您发布的代码没有多大意义.即使您想要处理不同的异常,您也可以执行以下操作之一(示例):catch( IOExc...

情报收集利器一NMAP_qq_37051023的博客-程序员宅基地

nmap(网络映射器)是一种与来探测计算机网络上的主机和服务的安全扫描器。Nmap会发送特制的数据报到目标主机上,然后分析其返回的数据报,从而达到绘制网络拓扑图的效果。Nmap是一款枚举和测试网络的强大工具,有主机探测、端口扫描、版本探测、系统检测以及支持探测脚本编写等功能。nmap安装:https://nmap.org/download.html#purpleheader(选择对应操作系统的安装包)cmd下输出“nmap”,如下图所示就代表成功。常用语句:1、扫描指定主机的指定端口

RHEL6 sysbench libtool error_weixin_34049032的博客-程序员宅基地

../libtool:line838:X--tag=CC:commandnotfound ../libtool:line871:libtool:ignoringunknowntag:commandnotfound ../libtool:line838:X--mode=link:commandnotfound ...

在MeterSphere中使用数据库提取和断言_撼地的神牛的博客-程序员宅基地_metersphere数据库断言

关于MeterSphereMeterSphere是一款由FIT2CLOUD发起的开源持续测试平台,目的是打造测试一体化管理,提高测试人员能效,降低测试成本。在其功能上包含测试用例管理、接口测试、性能测试,查看官网(https://www.fit2cloud.com/metersphere/index.html)架构描述,后续还会增加UI测试,MOCK服务等,还是比较期待的。MeterSphere目前在测试圈非常火,打破了测试圈工具近几年的一层不便,笔者也是朋友介绍,尝试了下MeterSphere平台,并

随便推点

linux下java程序与C语言程序通过SOCKET通信的简单例子_guan506713512的博客-程序员宅基地

本例中C语言端作为服务器,java端作为客户端代码如下:/****************** server program *****************/#include #include #include #include #incl

KMP 字符串匹配算法_Java_SuSheng的博客-程序员宅基地

字符串匹配算法,Knuth-Morris-Pratt算法(简称KMP),需要达成的目标是,找出某字符串a“ABCDABD” 在字符串b“BBC ABCDAB ABCDABCDABDE JDKAB”中是否存在,读了一些文章,暂时觉得,阮一峰的文章解释的还比较通俗易懂,以下,是我基于文章做出的代码及逻辑分析/** * KMP 算法 * http://www.ruanyif...

从AlexNet到BERT,深度学习这些年那些超重要的idea回顾总结_人工智能与算法学习的博客-程序员宅基地

本文作者Denny Britz按时间总结的深度学习比较重要的idea集锦,推荐新人看,几乎给自12年以来最重要的idea 都列了出来,这些 idea 可以说得上是养活了无数人,大家都基于这...

swift -SnapKit一些基本使用_weixin_30555753的博客-程序员宅基地

参考:SnapKit - 修改约束https://blog.csdn.net/longshihua/article/details/80289061import SnapKitclass ViewController: UIViewController { private var isUpdateSnapkitV = false ...

小白大数据工程师的养成之路3 关于zookeeper_佳减乘除。的博客-程序员宅基地

Zookeeper集群的安装部署推荐这个传送门 http://www.cnblogs.com/lilixin/p/5722402.html Zookeeper分布式协调简单介绍主要用来解决分布式环境当中多个进程之间的同步控制,让他们有序的去访问某种临界资源,防止造成&quot;脏数据&quot;的后果上图是分布式系统分析一波每台机器各跑一个应用程序。然后我们将这三台机器通过网络...

推荐文章

热门文章

相关标签