生产者－消费者.java

生产者－消费者的JAVA小程序

class stack
{int sip=0;
 String data[]=new String[6];
 public synchronized void push(String str)
  {while(sip==data.length)
    {try
       {this.wait();
       }
      catch(InterruptedException e){}
    
    }
   this.notify();
   data[sip]=str;
   sip++;
  }
 public synchronized String pop()
  {while(sip==0)
   {try
       {this.wait();
        }
    catch(InterruptedException e){}
   }
  this.notify();
  sip--;
  return data[sip];
  }
}

class Producer implements Runnable
{stack stackOne;
 public Producer(stack s)
 {stackOne=s;
 }
 public void run()
 {String strTemp=null;
  for(int i=0;i<8;i++)
   {strTemp=String.valueOf(i+1);
    stackOne.push(strTemp);
    System.out.println("Produced:"+strTemp);
    try
     {Thread.sleep((int)(Math.random()*100));
     }catch(InterruptedException e){}
   }
  }
}

class Consumer implements Runnable
{stack stackOne;
 public Consumer(stack s)
 {stackOne=s;
 } 
 public void run()
 {String strTemp=null;
  for(int i=0;i<8;i++)
  {strTemp=stackOne.pop();
   System.out.println("Consumed:"+strTemp);
   try
     {Thread.sleep((int)(Math.random()*100));
     }catch(InterruptedException e){}
  }
 }
}

public class stackTest
{public static void main(String args[])
  {stack s1=new stack();
   Runnable producer=new Producer(s1);
   Runnable consumer=new Consumer(s1);
   Thread p=new Thread(producer);]
   Thread c=new Thread(consumer);
   p.start();
   c.start();
  }
}