1. class Goods
   
2. {
   
3. private String name;
   
4. private int count = 0;
   
5. private boolean flag = false;
   
6. 
   
7. public synchronized void set(String name)
   
8. {
   
9. while(flag)//线程被唤醒的时候都进一次判断，如用if只能判断一次
   
10. try{wait();}catch(Exception e){} //此处只做简单处理，会抛出interrupt异常，暂时不会处理
    
11. this.name = name + "--" + count++;
    
12. System.out.println(Thread.currentThread().getName() + "....生产者" + this.name);
    
13. flag = true;
    
14. notifyAll();//唤醒线程池里的线程
    
15. }
    
16. public synchronized void out()
    
17. {
    
18. while(!flag)
    
19. try{wait();}catch(Exception e){}
    
20. System.out.println(Thread.currentThread().getName() + "-------------消费者" + this.name);
    
21. flag = false;
    
22. notifyAll();
    
23. }
    
24. }
    
25. 
    
26. class Producer implements Runnable
    
27. {
    
28. private Goods g;
    
29. public Producer(Goods g)
    
30. {
    
31. this.g = g;
    
32. }
    
33. 
    
34. public void run()
    
35. {
    
36. while(true)
    
37. {
    
38. g.set("##商品##");
    
39. }
    
40. }
    
41. }
    
42. 
    
43. class Consumer implements Runnable
    
44. {
    
45. private Goods g;
    
46. public Consumer(Goods g)
    
47. {
    
48. this.g = g;
    
49. }
    
50. public void run()
    
51. {
    
52. while(true)
    
53. {
    
54. g.out();
    
55. }
    
56. }
    
57. }

复制代码

1. class Test
   
2. {
   
3.         public static void main(String[] args)
   
4.         {
   
5.                 Goods g = new Goods();
   
6.                 Producer pro = new Producer(g);
   
7.                 Consumer consumer = new Consumer(g);
   
8. //4个生产，2个消费
   
9.                 new Thread(pro).start();
   
10.                 new Thread(pro).start();
    
11.                 new Thread(pro).start();
    
12.                 new Thread(pro).start();
    
13.                 new Thread(consumer).start();
    
14.                 new Thread(consumer).start();
    
15.         }
    
16. }

复制代码

1.关于wait()使用while循环，因为线程在这被唤醒之后，需要第一时间判断所操作资源的状态，所以只能使用while来强制线程被唤醒就进判断
2.关于notifyAll()，因为正常循环中是生产的完成动作后唤醒消费的线程，但是现有机制下无法唤醒指定的线程，所以运行中容易造成唤醒的是同一边的线程，然后全部线程进入wait()状态，因此，唤醒全部线程是比较行之有效的方法。

1. class Goods
   
2. {
   
3. private String name;
   
4. private int count = 0;
   
5. private boolean flag = false;
   
6. 
   
7. public synchronized void set(String name)
   
8. {
   
9. while(flag)//线程被唤醒的时候都进一次判断，如用if只能判断一次
   
10. try{wait();}catch(Exception e){} //此处只做简单处理，会抛出interrupt异常，暂时不会处理
    
11. this.name = name + "--" + count++;
    
12. System.out.println(Thread.currentThread().getName() + "....生产者" + this.name);
    
13. flag = true;
    
14. notifyAll();//唤醒线程池里的线程
    
15. }
    
16. public synchronized void out()
    
17. {
    
18. while(!flag)
    
19. try{wait();}catch(Exception e){}
    
20. System.out.println(Thread.currentThread().getName() + "-------------消费者" + this.name);
    
21. flag = false;
    
22. notifyAll();
    
23. }
    
24. }
    
25. 
    
26. class Producer implements Runnable
    
27. {
    
28. private Goods g;
    
29. public Producer(Goods g)
    
30. {
    
31. this.g = g;
    
32. }
    
33. 
    
34. public void run()
    
35. {
    
36. while(true)
    
37. {
    
38. g.set("##商品##");
    
39. }
    
40. }
    
41. }
    
42. 
    
43. class Consumer implements Runnable
    
44. {
    
45. private Goods g;
    
46. public Consumer(Goods g)
    
47. {
    
48. this.g = g;
    
49. }
    
50. public void run()
    
51. {
    
52. while(true)
    
53. {
    
54. g.out();
    
55. }
    
56. }
    
57. }

复制代码

1. class Test
   
2. {
   
3.         public static void main(String[] args)
   
4.         {
   
5.                 Goods g = new Goods();
   
6.                 Producer pro = new Producer(g);
   
7.                 Consumer consumer = new Consumer(g);
   
8. //4个生产，2个消费
   
9.                 new Thread(pro).start();
   
10.                 new Thread(pro).start();
    
11.                 new Thread(pro).start();
    
12.                 new Thread(pro).start();
    
13.                 new Thread(consumer).start();
    
14.                 new Thread(consumer).start();
    
15.         }
    
16. }

复制代码

1.关于wait()使用while循环，因为线程在这被唤醒之后，需要第一时间判断所操作资源的状态，所以只能使用while来强制线程被唤醒就进判断
2.关于notifyAll()，因为正常循环中是生产的完成动作后唤醒消费的线程，但是现有机制下无法唤醒指定的线程，所以运行中容易造成唤醒的是同一边的线程，然后全部线程进入wait()状态，因此，唤醒全部线程是比较行之有效的方法。