1. package demo;
   
2. 
   
3. public class ProducerAndConsuDemo {
   
4. 
   
5.         /**
   
6.          * 模拟生产者和消费者
   
7.          */
   
8.         public static void main(String[] args) {
   
9.                 Resource r = new Resource();
   
10.                 for(int i = 1;i<4;i++){
    
11.                         new Thread(new Pro(r)).start();
    
12.                         new Thread(new Consu(r)).start();
    
13.                 }
    
14. 
    
15.         }
    
16. 
    
17. }
    
18. class Resource{
    
19.         private String name;
    
20.         private int count = 0;
    
21.         private boolean flag = false;
    
22.        
    
23.         public void produce(){
    
24.                 synchronized(this){
    
25.                         while(flag){
    
26.                                 try {
    
27.                                         Thread.sleep(10);
    
28.                                         this.wait();
    
29.                                 } catch (InterruptedException e) {
    
30.                                         e.printStackTrace();
    
31.                                 }
    
32.                         }
    
33.                         count++;
    
34.                         System.out.println(Thread.currentThread().getName()+"...生产"+count);
    
35.                         flag = flag^true;
    
36.                         this.notifyAll();
    
37.                 }
    
38.         }
    
39.         public void sell(){
    
40.                 synchronized(this){
    
41.                         while(!flag){
    
42.                                 try {
    
43.                                         Thread.sleep(50);
    
44.                                         this.wait();
    
45.                                 } catch (InterruptedException e) {
    
46.                                         e.printStackTrace();
    
47.                                 }
    
48.                         }
    
49.                         System.out.println(Thread.currentThread().getName()+"...消费"+count);
    
50.                         flag = flag^true;
    
51.                         this.notifyAll();
    
52.                 }
    
53.         }
    
54. }
    
55. class Pro implements Runnable{
    
56.         private Resource r;
    
57. 
    
58.         public Pro(Resource r) {
    
59.                 super();
    
60.                 this.r = r;
    
61.         }
    
62. 
    
63.         @Override
    
64.         public void run() {
    
65.                 while(true){
    
66.                         r.produce();
    
67.                 }
    
68.         }
    
69. }
    
70. class Consu implements Runnable{
    
71.         private Resource r;
    
72. 
    
73.         public Consu(Resource r) {
    
74.                 super();
    
75.                 this.r = r;
    
76.         }
    
77. 
    
78.         @Override
    
79.         public void run() {
    
80.                 while(true){
    
81.                         r.sell();
    
82.                 }
    
83.         }
    
84. }

复制代码

1. Thread-0...生产1
   
2. Thread-5...消费1
   
3. Thread-4...生产2
   
4. Thread-3...消费2
   
5. Thread-2...生产3
   
6. Thread-1...消费3
   
7. Thread-2...生产4
   
8. Thread-3...消费4
   
9. Thread-4...生产5
   
10. Thread-5...消费5

复制代码