class Resource

{

        private String name;

        private int count=1;

        private boolean flag =false;

        public synchronized void set(String name)

        {

          if(flag)

                  try{this.wait();}catch(Exception a){}

          this.name=name+"--"+count++;

         

          System.out.println(Thread.currentThread().getName()+"...生产者...."+this.name);

          flag=true;

          this.notify();

        }

        public synchronized void out()

        {

          if(!flag)

         try{this.wait();}catch(Exception a){}

      System.out.println(Thread.currentThread().getName()+"...消费者...."+this.name);

      flag=false;

          this.notify();

        }

}

//---------------------------------

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()

        {

          res.out();

        }

}

//------------------------------------

class ProduceConsumerDemo
{

        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(con);

                t1.start();

                t2.start();

        }

}

如图，你的t2线程没有放到循环里

哦，谢谢

难得一见的帖