当前位置:首页>编程日记>正文

哲学家就餐问题--信号量和互斥量预防死锁

哲学家就餐问题可以采取预防死锁的方案,就是使用互斥量和信号量锁定资源。

互斥量:

对资源进行锁定的意思就是说,当一个哲学家使用叉子的时候,他首先要先把叉子锁定,然后,拿起来。这个时候如果别的哲学家也来拿相同的叉子,发现,该叉子是被互斥量锁定了,不能够拿,那么,他就不会来抢占这个叉子,而是在排等待队列中。这样就可以避免死锁的发生。

信号量:

同样,没有资源的时候,信号量的值是0,有的时候就不断地加1。“0,1”信号和互斥量是相似的。

使用互斥量预防死锁代码:

哲学家就餐问题--信号量和互斥量预防死锁 配图01哲学家就餐问题--信号量和互斥量预防死锁 配图02
/***哲学家吃饭问题:几个哲学家吃饭,假定哲学家有五个人,这五个哲学家坐在一张圆桌上面,*每个哲学家的左手旁边都放有一个叉子(fork),那么,这围城一圈的五个哲学家有五个叉子*。每个哲学家有三种状态,thinking(思考),trying(尝试去拿叉子吃饭),eating(已*经拿起叉子,正在吃饭)。每次吃饭需要两个叉子,也就是哲学家左右手边的叉子。* *//*** 本例使用pthread库实现哲学家进餐的问题。* *//***在这个例子中使用互斥量解决死锁问题。 * */#include <stdio.h>
#include <pthread.h>
#include <stdlib.h> 
#include <sys/wait.h>//为了使用sleep()函数
 #include <unistd.h>//参数的识别
#include <getopt.h> //长命令的解析//哲学家的数目
int  Number;//声明共享变量fork,其中fork的数目和哲学家数目是相同的
pthread_mutex_t *pfork;//定义一个philosopher的三个状态
#define Thinking 1
#define Trying 2
#define Eating 3int *state;void *EatMeal();//得到参数
void GetArg(char* argv[] /*in*/,int* number /*out*/);
void main(int argc,  char* argv[])
{int k =0;while(k<1){int option_index = 0;int rvalue = 0;struct option long_option[] = {{"normal",0,0,0 },{"method1",0,0,0},{"method2",0,0,0}};rvalue = getopt_long_only(argc,argv, "a:bc::", long_option,&option_index);switch(option_index){case 0 : printf("%s
",long_option[option_index].name);break;case 1 : printf("%s
",long_option[option_index].name);break;case 2 : printf("%s
",long_option[option_index].name);break;}k++;}GetArg(argv, &Number);pfork = malloc(Number*sizeof(pthread_mutex_t));state = malloc(Number*sizeof(int));//声明进程数组,每一个进程代表一个哲学家
    pthread_t philosopher[Number];int i;//初始化每一个资源实例for( i = 0; i < Number; i++){pthread_mutex_init(&pfork[i],NULL);}//创建和哲学家数量想对应的进程,并且每个进程开始进行吃饭的活动for( i = 0; i < Number; i++){//记录当前进程的编号,并传递到Meal()函数中int j = i;pthread_create(&philosopher[i], NULL, EatMeal, &j);printf("I am philosopher %d
", j);}//将所有的进程进行Join操作。for( i=0; i < Number; i++){pthread_join(philosopher[i], NULL);}//退出程序pthread_exit(0);return ;}void *EatMeal(int *i)
{//记录当前的线程id号int id = *i;state[id] = Thinking; //线程初始化的时候为Thinkingint leftFork = (id + Number -1) % Number;int rightFork = (id + Number +1) % Number;int mealTime = 5;int mymealTime = 0;while (mymealTime < mealTime) //每个philosopher必须吃得符合规定
    {if(state[id] == Thinking){printf("Philosopher %d is thinking
", id);sleep(1);state[id] = Trying;}else if(state[id] == Trying){printf("Philosopher %d is Trying
", id);sleep(1);pthread_mutex_lock(&pfork[leftFork]);pthread_mutex_lock(&pfork[rightFork]);state[id] = Eating;}else {printf("Philosopher %d is Eating
", id);sleep(1);mymealTime++;pthread_mutex_unlock(&pfork[leftFork]);pthread_mutex_unlock(&pfork[rightFork]);}}}void GetArg(char * argv[],int* number)
{*number = strtol(argv[1], NULL, 10);
}

http://www.coolblog.cn/news/9fcfa072b14864d0.html

相关文章:

  • asp多表查询并显示_SpringBoot系列(五):SpringBoot整合Mybatis实现多表关联查询
  • s7day2学习记录
  • 【求锤得锤的故事】Redis锁从面试连环炮聊到神仙打架。
  • 矿Spring入门Demo
  • 拼音怎么写_老师:不会写的字用圈代替,看到孩子试卷,网友:人才
  • Linux 实时流量监测(iptraf中文图解)
  • Win10 + Python + GPU版MXNet + VS2015 + RTools + R配置
  • 美颜
  • shell访问php文件夹,Shell获取某目录下所有文件夹的名称
  • 如何优雅的实现 Spring Boot 接口参数加密解密?
  • LeCun亲授的深度学习入门课:从飞行器的发明到卷积神经网络
  • Mac原生Terminal快速登录ssh
  • java受保护的数据与_Javascript类定义语法,私有成员、受保护成员、静态成员等介绍...
  • mysql commit 机制_1024MySQL事物提交机制
  • 支撑微博千亿调用的轻量级RPC框架:Motan
  • jquery 使用小技巧
  • 2019-9
  • 法拉利虚拟学院2010 服务器,法拉利虚拟学院2010
  • vscode pylint 错误_将实际未错误的py库添加到pylint白名单
  • 科学计算工具NumPy(3):ndarray的元素处理
  • 工程师在工作电脑存 64G 不雅文件,被公司开除后索赔 41 万,结果…
  • linux批量创建用户和密码
  • newinsets用法java_Java XYPlot.setInsets方法代碼示例
  • js常用阻止冒泡事件
  • 气泡图在开源监控工具中的应用效果
  • 各类型土地利用图例_划重点!国土空间总体规划——土地利用
  • php 启动服务器监听
  • dubbo简单示例
  • 【设计模式】 模式PK:策略模式VS状态模式
  • [iptables]Redhat 7.2下使用iptables实现NAT
  • Ubuntu13.10:[3]如何开启SSH SERVER服务
  • CSS小技巧——CSS滚动条美化
  • JS实现-页面数据无限加载
  • 阿里巴巴分布式服务框架 Dubbo
  • 最新DOS大全
  • Django View(视图系统)
  • 阿里大鱼.net core 发送短信
  • 程序员入错行怎么办?
  • 两张超级大表join优化
  • 第九天函数
  • Linux软件安装-----apache安装
  • HDU 5988 最小费用流
  • Sorenson Capital:值得投资的 5 种 AI 技术
  • 《看透springmvc源码分析与实践》读书笔记一
  • 正式开课!如何学习相机模型与标定?(单目+双目+鱼眼+深度相机)
  • Arm芯片的新革命在缓缓上演
  • nagios自写插件—check_file
  • python3 错误 Max retries exceeded with url 解决方法
  • 行为模式之Template Method模式
  • 通过Spark进行ALS离线和Stream实时推荐