1. class Resource{
   
2.         private String name;
   
3.         private int count = 1;
   
4.         private boolean flag = false;
   
5.        
   
6.         public synchronized void set(String name) {
   
7.                 while(flag){
   
8.                         try {
   
9.                                 this.wait();
   
10.                         } catch (InterruptedException e) {
    
11.                                 e.printStackTrace();
    
12.                         }
    
13.                 }
    
14.                 this.name = name+"..."+count++;
    
15.                 System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
    
16.                 flag = true;
    
17.                 this.notifyAll();
    
18.         }
    
19.        
    
20.         public synchronized void out(){
    
21.                 while(!flag){   //当处于等待状态的线程被唤醒时，应该再进行一次标志的判断，故而将if更换为while
    
22.                         try {
    
23.                                 this.wait();   
    
24.                         } catch (InterruptedException e) {
    
25.                                 e.printStackTrace();
    
26.                         }
    
27.                 }
    
28.                 System.out.println(Thread.currentThread().getName()+".....消费者...."+this.name);
    
29.                 flag = false;
    
30.                 this.notifyAll(); //因为在等待的线程池中，先进入线程池中的会先唤醒，所以需要用notifyAll唤醒所有的线程
    
31.         }
    
32. }
    
33. 
    
34. class Producer implements Runnable{
    
35.     private Resource res;
    
36.        
    
37.     public Producer(Resource res) {
    
38.             this.res = res;
    
39.         }
    
40.         public void run() {
    
41.                 while(true){
    
42.                         res.set("+商品+");
    
43.                 }
    
44.         }
    
45. }
    
46. 
    
47. class Consumer implements Runnable{
    
48.         private Resource res;
    
49.        
    
50.         public Consumer(Resource res) {
    
51.                 this.res = res;
    
52.         }
    
53.        
    
54.         public void run() {
    
55.                 while(true){
    
56.                         res.out();
    
57.                 }
    
58.         }
    
59. }
    
60. 
    
61. public class ProducerConsumerDemo {
    
62. 
    
63.         public static void main(String[] args) {
    
64.                 Resource r = new Resource();
    
65.                 /*
    
66.                  * 当开启的线程超过两个时，这段代码会出现问题
    
67.                  *
    
68.                  */
    
69.                 //new Thread(new Producer(r)).start(); //代码优化的写法
    
70.                 Producer pro = new Producer(r);
    
71.                 Consumer con = new Consumer(r);
    
72.                
    
73.                 Thread t1 = new Thread(pro);
    
74.                 Thread t2 = new Thread(pro);
    
75.                 Thread t3 = new Thread(con);
    
76.                 Thread t4 = new Thread(con);
    
77.                
    
78.                 t1.start();
    
79.                 t2.start();
    
80.                 t3.start();
    
81.                 t4.start();
    
82.         }
    
83. }

复制代码

在上边的代码中，类Resource里面有一个while循环，我不是很理解它是怎么结束这个循环的，求大神给指点一下

是通过 flag = false 结束循环的~

结束run方法就可以结束线程。在Consumer和Producer的run方法中，可以定义标记，当标记为假是run方法就结束，或者直接给定循环次数。你写true不好结束的。