class ProducerConsumerDemo
{
public static void main(String[] args)
{
  Resource r=new Resource();
  Producer pro=new Producer(r);
  Consumer con=new Consumer(r);
  Thread t1=new Thread(pro);
  Thread t2=new Thread(pro);
  Thread t3=new Thread(con);
  Thread t4=new Thread(con);
  t1.start();
  t2.start();
  t3.start();
  t4.start();
}
}
class Resource
{
private String name;
private int count=1;
private boolean flag=false;
public synchronized void set(String name)    //同步
{
  while(flag)   //如果多线程操作一个动作，必须是while才行
  //if(flag)    用if在这不行      
   try{this.wait();}catch(Exception e){}
  this.name=name+"----"+count++;
  System.out.println(Thread.currentThread().getName()+"-生产者-"+this.name);
  flag=true;
  this.notifyAll();   //如果用notify()  会全部睡眠状态
}
public synchronized void out()                   //同步
{
  while(!flag)   //如果多线程操作一个动作，必须是while才行
  //if(!flag)    用if在这不行
   try{this.wait();}catch(Exception e){}
  System.out.println(Thread.currentThread().getName()+"---消费者---"+this.name);
  flag=false;
  this.notifyAll();
}
}
class Producer implements Runnable
{
private Resource res;
Producer(Resource res)
{
  this.res=res;
}
public void run()
{
  while(true)
  {
   res.set("+商品+");
  }
}
}
class Consumer implements Runnable
{
private Resource res;
Consumer(Resource res)
{
  this.res=res;
}
public void run()
{
  while(true)
  {
   res.out();
  }
}
}


求详解为什么要用while（flag）   和notifyAll（）
就是t1  t2  t3  t4 他们怎么执行的？

用while循环是为了重复判断标记，用notifyAll()主要是为了唤醒对方线程，关于t1  t2  t3  t4的运行用文字不太好描述，建议再看看毕向东老师的这个问题的讲解！