/**
*        对于多个生产者和消费者,为什么要定义while判断标记?
*        原因：让被唤醒的线程再一次判断标记。
*
*        为什么定义notifyAll()?
*        因为需要唤醒对方线程,只用notify()，容易出现只唤醒本方线程的情况,导致程序中的所有线程都等待。
*/

1. class Resource
   
2. {
   
3.         private String name;
   
4.         private int count = 1;
   
5.         private boolean flag = false;
   
6. 
   
7.         public synchronized void set(String name)
   
8.         {
   
9.                 while(flag)
   
10.                         try{
    
11.                                 wait();
    
12.                         }catch(Exception e){
    
13.                                
    
14.                         }
    
15. 
    
16.                 this.name = name+"--"+count++;
    
17. 
    
18.                 System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
    
19.                 flag = true;
    
20.                 this.notifyAll();
    
21.         }
    
22. 
    
23.         public synchronized void out()
    
24.         {
    
25.                 while(!flag)
    
26.                         try{
    
27.                                 wait();
    
28.                         }catch(Exception e){
    
29.                                
    
30.                         }
    
31.                 System.out.println(Thread.currentThread().getName()+"...消费者........."+this.name);
    
32.                 flag = false;
    
33.                 this.notifyAll();
    
34.         }
    
35. }
    
36. 
    
37. class Producer implements Runnable
    
38. {
    
39.         private Resource res;
    
40.         Producer(Resource res)
    
41.         {
    
42.                 this.res = res;
    
43.         }
    
44.         public void run()
    
45.         {
    
46.                 while(true)
    
47.                 {
    
48.                         res.set("+商品+");
    
49.                 }
    
50.         }
    
51. }
    
52. 
    
53. class Consumer implements Runnable
    
54. {
    
55.         private Resource res;
    
56. 
    
57.         Consumer(Resource res)
    
58.         {
    
59.                 this.res = res;
    
60.         }
    
61.         public void run()
    
62.         {
    
63.                 while(true)
    
64.                 {
    
65.                         res.out();
    
66.                 }
    
67.         }
    
68. }
    
69. 
    
70. class ProducerConsumerDemo
    
71. {
    
72.         public static void main(String[] args)
    
73.         {
    
74.                 Resource r = new Resource();
    
75. 
    
76.                 Producer pro = new Producer(r);
    
77.                 Consumer con = new Consumer(r);
    
78. 
    
79.                 Thread t1 = new Thread(pro);
    
80.                 Thread t2 = new Thread(pro);
    
81.                 Thread t3 = new Thread(con);
    
82.                 Thread t4 = new Thread(con);
    
83. 
    
84.                 t1.start();
    
85.                 t2.start();
    
86.                 t3.start();
    
87.                 t4.start();
    
88. 
    
89.         }
    
90. }

复制代码

/**
*        对于多个生产者和消费者,为什么要定义while判断标记?
*        原因：让被唤醒的线程再一次判断标记。
*
*        为什么定义notifyAll()?
*        因为需要唤醒对方线程,只用notify()，容易出现只唤醒本方线程的情况,导致程序中的所有线程都等待。
*/

1. class Resource
   
2. {
   
3.         private String name;
   
4.         private int count = 1;
   
5.         private boolean flag = false;
   
6. 
   
7.         public synchronized void set(String name)
   
8.         {
   
9.                 while(flag)
   
10.                         try{
    
11.                                 wait();
    
12.                         }catch(Exception e){
    
13.                                
    
14.                         }
    
15. 
    
16.                 this.name = name+"--"+count++;
    
17. 
    
18.                 System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
    
19.                 flag = true;
    
20.                 this.notifyAll();
    
21.         }
    
22. 
    
23.         public synchronized void out()
    
24.         {
    
25.                 while(!flag)
    
26.                         try{
    
27.                                 wait();
    
28.                         }catch(Exception e){
    
29.                                
    
30.                         }
    
31.                 System.out.println(Thread.currentThread().getName()+"...消费者........."+this.name);
    
32.                 flag = false;
    
33.                 this.notifyAll();
    
34.         }
    
35. }
    
36. 
    
37. class Producer implements Runnable
    
38. {
    
39.         private Resource res;
    
40.         Producer(Resource res)
    
41.         {
    
42.                 this.res = res;
    
43.         }
    
44.         public void run()
    
45.         {
    
46.                 while(true)
    
47.                 {
    
48.                         res.set("+商品+");
    
49.                 }
    
50.         }
    
51. }
    
52. 
    
53. class Consumer implements Runnable
    
54. {
    
55.         private Resource res;
    
56. 
    
57.         Consumer(Resource res)
    
58.         {
    
59.                 this.res = res;
    
60.         }
    
61.         public void run()
    
62.         {
    
63.                 while(true)
    
64.                 {
    
65.                         res.out();
    
66.                 }
    
67.         }
    
68. }
    
69. 
    
70. class ProducerConsumerDemo
    
71. {
    
72.         public static void main(String[] args)
    
73.         {
    
74.                 Resource r = new Resource();
    
75. 
    
76.                 Producer pro = new Producer(r);
    
77.                 Consumer con = new Consumer(r);
    
78. 
    
79.                 Thread t1 = new Thread(pro);
    
80.                 Thread t2 = new Thread(pro);
    
81.                 Thread t3 = new Thread(con);
    
82.                 Thread t4 = new Thread(con);
    
83. 
    
84.                 t1.start();
    
85.                 t2.start();
    
86.                 t3.start();
    
87.                 t4.start();
    
88. 
    
89.         }
    
90. }

复制代码