进程同步模拟设计 生产者和消费者问题

进程同步模拟设计--生产者和消费者问题 进程调度同步异步

 class Producer implements Runnable
{
private Semaphore mutexfullempty;
private Buffer buf;
String name;
public Producer（String nameSemaphore mutexSemaphore fullSemaphore emptyBuffer buf）
{
this.name = name;
this.mutex = mutex;
this.full = full;
this.empty = empty;
this.buf = buf;
}
public void run（）
{
while（true）
{
empty.p（）;
mutex.p（）;
System.out.println（name+“ inserts a new product into “+buf.nextEmptyIndex）;
buf.nextEmptyIndex = （buf.nextEmptyIndex+1）%buf.size;
mutex.v（）;
full.v（）; 
try 
{
Thread.sleep（1000）;  //必须捕获异常
} 
catch （InterruptedException e） 
{ 
e.printStackTrace（）;
}
}
}
}

class Customer implements Runnable
{
private Semaphore mutexfullempty;
private Buffer buf;
String name;
public Customer（String nameSemaphore mutexSemaphore fullSemaphore emptyBuffer buf）{
this.mutex = mutex;
this.full = full;
this.empty = empty;
this.buf = buf;
this.name = name;
}
public void run（）
{
while（true）
{
full.p（）;
mutex.p（）;
S

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       2868  2010-01-22 21:38  Test.java

----------- ---------  ---------- -----  ----

                 2868                    1