- 1、本文档共11页,可阅读全部内容。
- 2、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
- 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
- 5、该文档为VIP文档,如果想要下载,成为VIP会员后,下载免费。
- 6、成为VIP后,下载本文档将扣除1次下载权益。下载后,不支持退款、换文档。如有疑问请联系我们。
- 7、成为VIP后,您将拥有八大权益,权益包括:VIP文档下载权益、阅读免打扰、文档格式转换、高级专利检索、专属身份标志、高级客服、多端互通、版权登记。
- 8、VIP文档为合作方或网友上传,每下载1次, 网站将根据用户上传文档的质量评分、类型等,对文档贡献者给予高额补贴、流量扶持。如果你也想贡献VIP文档。上传文档
查看更多
生产吆拖颜em问题是从操作系统中许多实际同步问题
生产者和消费者问题是从操作系统中的许多实际同步问题中抽象出来的具有 代表性的问题。它反映了操作系统中典型的同步例子。 生产者进程(进程由多个线程组成)生产信息,例如它可以是计算进程。消费 者进程使用信息,它可以是输出打印进程。由于生产者和消费者彼此独立,且运 行速度不确定,所以很可能出现生产者已产生了信息而消费者却没有来得及接受 信息这种情况。为此,需要引入由一个或者若干个存储单元组成的临时存储区, 以便存放生产者所产生的信息,平滑进程间由于速度不确定所带来的问题。这个临时存储区叫做缓冲区,通常用一维数组来表示。 由一个或若干个存储单元组成的缓冲区叫作“有穷缓冲区”。下面我们来分 析一下有穷缓冲的生产者和消费者的例子。 假设有多个生产者和多个消费者,它们共享一个具有n个存储单元的有穷缓冲 区Buffer(0……n-1),这是一个环形队列。其队尾指针Rear指向当前信息应存放 的位置(Buffer[Rear]),队首指针Front指向当前取出信息的位置(Buffer[front ])。生产者进程总是把信息存放在Buffer[Rear]中,消费者进程则总是从Buffer [Rear]中取出信息。如果想使生产者进程和消费者进程协调合作,则必须使它们 遵循如下规则: 1) 只要缓冲区有存储单元,生产者都可往其中存放信息;当缓冲区已满时, 若任意生产者提出写要求,则都必须等待; 2) 只要缓冲区中有消息可取,消费者都可从缓冲区中取出消息;当缓冲区为空时,若任意消费者想取出信息,则必须等待; 3) 生产者们和消费者们不能同时读、写缓冲区。 用JAVA 实现“生产者-消费者”问题的代码如下: class MonitorTest{ static int produce_speed=200; static int consume_speed=200; public static void main (String [] args){ if(args.length0) produce_speed=Integer.parseInt(args[0]); if(args.length1) consume_speed=Integer.parseInt(args[1]); Monitor monitor=new Monitor(); new Producer(monitor,produce_speed); new Consumer(monitor,consume_speed); try{ Thread.sleep(4000); }catch(InterruptedException e){} System.exit(0); } } class Monitor { int Buffer_Length=10; int[] Buffer=new int[Buffer_Length]; int Item; int Count=0,Rear=0,Front=0; //get buffer synchronized int get(){ if(Count ==0) try{ wait(); }catch(InterruptedException e){} Item=Buffer[Front]; Count--; Front=(Front+1)%Buffer_Length; System.out.println(Got:+Item); notify(); return Item; } //set buffer synchronized void set(int value){ if(Count==Buffer_Length) try{ wait(); }catch(InterruptedException e){} Buffer[Rear]=value; Count++; Rear=(Rear+1)%Buffer_Length; System.out.println(Set:+value); notify(); } } class Producer implements Runnable{ Monitor monitor; int speed;
Producer(Monitor monitor,int speed){
文档评论(0)