1. class Res
   
2. {
   
3.         private String name;
   
4.         private int count = 1;
   
5. 
   
6.         //定义标记。
   
7.         private boolean flag;
   
8.         //提供了给商品赋值的方法。
   
9.         public synchronized void set(String name)
   
10.         {
    
11.                 if(flag)//判断标记为true，执行wait。等待。为false。就生产。
    
12.                         try{this.wait();}catch(InterruptedException e){}
    
13.                 this.name  = name + "--" + count;
    
14. 
    
15.                 count++;
    
16. 
    
17.                 System.out.println(Thread.currentThread().getName()+"...生产者....."+this.name);
    
18.                 //生成完毕，将标记改为true。
    
19.                 flag = true;
    
20. 
    
21.                 //唤醒消费者。
    
22.                 this.notify();
    
23.         }
    
24. 
    
25.         //提供一个获取商品的方法。
    
26.         public synchronized void get()
    
27.         {
    
28.                 if(!flag)
    
29.                         try{this.wait();}catch(InterruptedException e){}
    
30.                 System.out.println(Thread.currentThread().getName()+".......消费者....."+this.name);
    
31. 
    
32.                 //将标记改为false。
    
33.                 flag = false;
    
34.                 //唤醒生产者。
    
35.                 this.notify();
    
36.         }
    
37. }
    
38. 
    
39. 
    
40. //生成者。
    
41. class Producer implements Runnable
    
42. {
    
43.         private Res r;
    
44.         Producer(Res r)
    
45.         {
    
46.                 this.r = r;
    
47.         }
    
48.         public void run()
    
49.         {
    
50.                 while(true)
    
51.                         r.set("面包");
    
52.         }
    
53. }
    
54. 
    
55. //消费者
    
56. class Consumer implements Runnable
    
57. {
    
58.         private Res r;
    
59.         Consumer(Res r)
    
60.         {
    
61.                 this.r = r;
    
62.         }
    
63.         public void run()
    
64.         {        
    
65.                 while(true)
    
66.                         r.get();
    
67.         }
    
68. }
    
69. 
    
70. 
    
71. 
    
72. 
    
73. class  ProducerConsumerDemo2
    
74. {
    
75.         public static void main(String[] args)
    
76.         {
    
77.                 //1,创建资源。
    
78.                 Res r = new Res();
    
79.                 //2，创建两个任务。
    
80.                 Producer pro = new Producer(r);
    
81.                 Consumer con = new Consumer(r);
    
82. 
    
83.                 //3,创建线程。
    
84.                 Thread t1 = new Thread(pro);
    
85.                 Thread t2 = new Thread(con);
    
86. 
    
87.                 t1.start();
    
88.                 t2.start();
    
89.         }
    
90. }

复制代码

首先回答你的问题：Producer和Consumer类里面的run方法的while(true)做了无限循环。

然后你这个代码是有问题的，当你创建多个producer对象和Consumer对象之后你就会发现问题所在。解决方法是使用JDK5.0更新的一个新特性Lock类。

楼上正答

控制循环是在run方法的while循环中，与同步没有关系，同步只是保证了资源的唯一性和动作的互斥性！