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

复制代码

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

复制代码