1. public class 线程的例子之四线程的通讯问题 {
   
2.         public static void main(String[] args) {
   
3.                 Person p = new Person();
   
4.         Thread a = new Thread(new productor(p), "生产者");
   
5.         Thread b = new Thread(new Consumer(p), "消费者");
   
6.         a.start();
   
7.         b.start();
   
8.         }
   
9. 
   
10. }
    
11. 
    
12. class Person {
    
13.         private String name;
    
14.         private String  sex;
    
15.         Boolean flag = false;
    
16.          Person(String name,String sex){
    
17.                 this.name = name;
    
18.                 this.sex = sex;
    
19.         }
    
20.         public Person() {
    
21.                 // TODO Auto-generated constructor stub
    
22.         }
    
23.         public void setNmae(String name){
    
24.                 this.name = name;
    
25.         }
    
26.         public void setSex(String  sex){
    
27.                 this.sex = sex;
    
28.         }
    
29.         public String getName(){
    
30.                 return this.name;
    
31.                
    
32.         }
    
33.         public String getSex(){
    
34.                 return this.sex;
    
35.                
    
36.         }
    
37.        
    
38. }
    
39. 
    
40. class productor implements Runnable {
    
41.    int i;
    
42.         Person p;
    
43.        
    
44.         productor(Person p){
    
45.                 this.p = p;
    
46.         }
    
47.         @Override
    
48.         public void run() {
    
49.                 synchronized (p) {
    
50.                         while(p.flag == true){
    
51.                                 try {
    
52.                                         p.wait();
    
53.                                 } catch (InterruptedException e) {
    
54.                                         // TODO Auto-generated catch block
    
55.                                         e.printStackTrace();
    
56.                                 }
    
57.                         }
    
58.                                   if(i%2 == 0){
    
59.                                      p.setNmae("小红");
    
60.                                      p.setSex("女");
    
61.                                    
    
62.                                      System.out.println(Thread.currentThread().getName()+"生产了"+p.getName()+p.getSex());}
    
63.                      
    
64.              
    
65.                                         else
    
66.                                         { p.setNmae("小明");
    
67.                                  p.setSex("男");
    
68.                                          System.out.println(Thread.currentThread().getName()+"生产了"+p.getName()+p.getSex());}
    
69.                                   i++;
    
70.                                p.flag  = true;
    
71.                                p.notifyAll();
    
72.                         }
    
73.                
    
74.                         }
    
75.                 }
    
76.    
    
77.        
    
78.        
    
79. 
    
80. 
    
81. class Consumer implements Runnable{
    
82.         Person p;
    
83.         Consumer(Person p){
    
84.                 this.p = p;
    
85.         }
    
86.         @Override
    
87.         public void run() {
    
88.                 // TODO Auto-generated method stub
    
89.         synchronized (p) {
    
90.                 while(p.flag == false){
    
91.                 try {
    
92.                         p.wait();
    
93.                 } catch (InterruptedException e) {
    
94.                         // TODO Auto-generated catch block
    
95.                         e.printStackTrace();
    
96.                 }
    
97.                 }
    
98.        
    
99.                
    
100.                
     
101.                  System.out.println(Thread.currentThread().getName()+"消费了"+p.getName()+p.getSex());
     
102.                  
     
103.                  p.flag = false;
     
104.                  p.notifyAll();
     
105.        
     
106.                
     
107.         }       
     
108.         }
     
109.        
     
110. }
     

复制代码

:):):):):)