互斥锁应用实例

谁借莪１个温暖的怀抱￠ 2022-11-26 09:48 152阅读 0赞

更多资料请点击：[我的目录][Link 1]  
本篇仅用于记录自己所学知识及应用，代码仍可优化，仅供参考，如果发现有错误的地方，尽管留言于我，谢谢。

此实例已解决：库存数量num小于线程个数出现负数的问题

#include <stdio.h>
    #include <stdlib.h>
    #include <signal.h>
    #include <unistd.h>
    #include <pthread.h>
    
    int num=5;												//定义变量表示库存
    
    pthread_t id1,id2,id3,id4;
    pthread_mutex_t mymutex;								//定义互斥锁
    pthread_cond_t mycond;									//定义条件变量
    	
    void finish(int num)
    { 
    	pthread_mutex_destroy(&mymutex);					//销毁锁
    	pthread_cancel(id1);								//取消四个子线程
    	pthread_cancel(id2);
    	pthread_cancel(id3);
    	pthread_cancel(id4);
    	exit(0);
    }
    
    void *sale1(void *arg)
    { 
    	while(1)
    	{ 
    		pthread_mutex_lock(&mymutex);
    		if(num <= 0)
    		{ 
    			printf("阻塞在wait这个位置了!\n");
    			pthread_cond_wait(&mycond,&mymutex); 		//解除阻塞后从此处开始往下运行
    			pthread_mutex_unlock(&mymutex);				//解锁操作，防止重复上锁造成堵塞
    			continue;									//跳出此次循环，重新上锁再进行num值的判断
    		}	
    		num--;
    		
    		printf("销售一部卖出一件产品，剩下:%d\n",num);
    		sleep(1);
    		pthread_mutex_unlock(&mymutex);
    		sleep(1);
    	}
    }
    
    void *sale2(void *arg)
    { 
    	while(1)
    	{ 
    		pthread_mutex_lock(&mymutex);
    		if(num <= 0)
    		{ 
    			printf("阻塞在wait这个位置了!\n");
    			pthread_cond_wait(&mycond,&mymutex); 		//解除阻塞后从此处开始往下运行
    			pthread_mutex_unlock(&mymutex);				//解锁操作，防止重复上锁造成堵塞
    			continue;									//跳出此次循环，重新上锁再进行num值的判断
    		}
    		num--;
    		
    		printf("销售二部卖出一件产品，剩下:%d\n",num);
    		sleep(1);
    		pthread_mutex_unlock(&mymutex);
    		sleep(1);
    	}
    }
    
    void *sale3(void *arg)
    { 
    	while(1)
    	{ 
    		pthread_mutex_lock(&mymutex);
    		if(num <= 0)
    		{ 
    			printf("阻塞在wait这个位置了!\n");			
    			pthread_cond_wait(&mycond,&mymutex); 		//解除阻塞后从此处开始往下运行
    			pthread_mutex_unlock(&mymutex);				//解锁操作，防止重复上锁造成堵塞
    			continue;									//跳出此次循环，重新上锁再进行num值的判断
    		}
    		num--;
    		
    		printf("销售三部卖出一件产品，剩下:%d\n",num);
    		sleep(1);
    		pthread_mutex_unlock(&mymutex);
    		sleep(1);
    	}
    }
    
    void *sale4(void *arg)
    { 
    	while(1)
    	{ 	
    		pthread_mutex_lock(&mymutex);
    		if(num <= 0)
    		{ 
    			printf("阻塞在wait这个位置了!\n");
    			pthread_cond_wait(&mycond,&mymutex); 		//解除阻塞后从此处开始往下运行
    			pthread_mutex_unlock(&mymutex);				//解锁操作，防止重复上锁造成堵塞
    			continue;									//跳出此次循环，重新上锁再进行num值的判断
    		}
    		
    		num--;
    		printf("销售四部卖出一件产品，剩下:%d\n",num);
    		sleep(1);
    		pthread_mutex_unlock(&mymutex);
    		sleep(1);
    	}
    }
    
    int main()
    { 
    	signal(SIGINT,finish);
    	
    	pthread_mutex_init(&mymutex,NULL);					//初始化锁
    	pthread_cond_init(&mycond,NULL);					//初始化条件变量
    	
    	pthread_create(&id1,NULL,sale1,NULL);				//创建四个线程分别表示四个销售部门
    	pthread_create(&id2,NULL,sale2,NULL);
    	pthread_create(&id3,NULL,sale3,NULL);
    	pthread_create(&id4,NULL,sale4,NULL);
    	
    
    	while(1)											//生产部门
    	{ 
    		if(num == 0)
    		{ 
    			printf("产品已售完，请生产\n");
    			scanf("%d",&num);
    			pthread_cond_broadcast(&mycond);			//解除所有线程的阻塞状态
    		}
    	}
    	return 0;
    }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzc5MzE4MQ_size_16_color_FFFFFF_t_70]

[Link 1]: http://note.youdao.com/noteshare?id=1370b0e8f4a16b80e7dede7836df3c08
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mzc5MzE4MQ_size_16_color_FFFFFF_t_70]: /images/20221124/77a94ba3a87d49e192a4a7e6a82b85b7.png