- 1、本文档共9页,可阅读全部内容。
- 2、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
- 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
查看更多
操作系统哲学家问题实验报告课件
实验报告三
实验名称: 一、调试验证“有限缓冲”经典同步问题
二、利用Java同步解决“哲学家进餐”问题
日期:2015-11-5 班级:13级计科 学号: 姓名:
实验目的
了解信号的使用
正确使用同步机制的方法
消费者进程的互斥与同步
解决“哲学家进餐”
调试验证“有限缓冲”经典同步问题
利用Java同步解决“哲学家进餐”问题
项目要求与分析
“有限缓冲经典同步问题
描述
有一群生产者进程在生产产品,此产品提供给消费者去消费。为使生产者和消费者进程能并发执行,在它们之间设置一个具有n个缓冲池,生产者进程可将它所生产的产品放入一个缓冲池中,消费者进程可从一个缓冲区取得一个产品消费。分析
设两个同步信号量:一个说明空缓冲区的数目,用empty表示,初值为有界缓冲区的大小N,另一个说明已用缓冲区的数目,用full表示,初值为0。由于 在执行生产活动和消费活动中要对有界缓冲区进行操作。有界缓冲区是一个临界资源,必须互斥使用,所以另外还需要设置一个互斥信号量mutex,其初值为1。哲学家进餐问题
描述
所有的哲学家都同时筷子,看到右侧筷子不可用,都放下左侧筷子,等一会儿,又同时拿起左侧筷子,如此这般,永远重复。对于情况,即的都在无限制运行,但是都无法得到任何进展,即出现饿死所有的哲学家都吃不上饭。
拿起的筷子,右面的筷子是否可用。如果,放下左侧的筷子,等一段时间后再重复整个过程。
当出现以下情形,在某一瞬间,的哲学家都同时启用这个算法拿起左侧的筷子,而看到右侧筷子都不可用,又都放下左侧筷子,等一会儿,又同时拿起筷子永远重复下去。对于情况,所有的都在运行,但却都无法取得进展,即出现饿死,所有的哲学家都吃不上饭
解决死锁问题:为了避免死锁,哲学家三状态:思考,饥饿(),进食,并且拿起两只筷子,不拿。
1.“有限缓冲经典同步问题。实现代码
实现
public class BoundeBuffer implements Buffer
{ private static final int BUFFER_SIZE=5;
private Object[] buffer;
private int in,out;
private Semaphore mutex;
private Semaphore empty;
private Semaphore full;
public BoundeBuffer()
{
in=0;
out=0;
buffer=new Object[BUFFER_SIZE];
mutex=new Semaphore(1);
empty=new Semaphore(BUFFER_SIZE);
full=new Semaphore(0);
}
public void insert(Object item)
{
try
{
empty.acquire();
mutex.acquire();
buffer[in]=item;
in=(in+1)%BUFFER_SIZE;
mutex.release();
full.release();
}catch(InterruptedException e)
{e.printStackTrace();}
}
public Object remove()
{
try {
full.acquire();
mutex.acquire();
} catch (InterruptedException e)
{
e.printStackTrace();
}
Object item=buffer[out];
out=(out+1)%BUFFER_SIZE;
mutex.release();
empty.release();
return item;
}
//生产者实现
public class Producer implements Runnable
{
private Buffer buffer;
public Producer(Buffer buffer)
{
this.buffer=buffer;
}
public void run()
{
Date message;
while(true)
{
SleepUtilities.nap();
message=new Date();
System.out.println(生产者 产生了 +message);
buffer.insert(message);
文档评论(0)