06_Java多線程、線程間通訊

 1 //線程通訊: 取mike, 取麗麗
 2 public class Demo2 {
 3 
 4     public static void main(String[] args) {
 5         Person p = new Person();
 6         new Thread(new Input(p)).start();
 7         new Thread(new Output(p)).start();
 8     }
 9 
10 }
11 
12 class Person{
13     private String name ;
14     private String sex ;
15     private boolean flag = false;
16     
17     public synchronized void set(String name, String sex){
18         //flag爲true,表示已存在
19         if(flag){
20             try {wait();}catch (InterruptedException e) {e.printStackTrace();}
21         }
22         //flag爲false,表示沒人可加
23         this.name = name;
24         this.sex = sex;
25         flag = true;
26         this.notify();
27     }
28     
29     public synchronized void out(){
30         //flag爲false,表示無人無法取
31         if(!flag){
32             try {wait();}catch (InterruptedException e) {e.printStackTrace();}
33         }
34         //flag爲true,表示有人能夠取出
35         System.out.println(toString());    
36         flag = false;
37         this.notify();        
38     }
39     
40     public String toString(){
41         return "姓名:"+name+"性別:"+sex;
42     }
43 }
44 
45 class Input implements Runnable{
46     private Person p;
47     
48     Input(Person p){
49         this.p = p;
50     }
51     
52     public void run(){
53         boolean flag = false;
54         while(true){    
55                 if(flag){
56                     p.set("likai","男");
57                     flag = false;
58                 }
59                 else{
60                     p.set("tangll","女");    
61                     flag = true;
62                 }    
63         }
64     }
65 }
66 
67 class Output implements Runnable{
68     private Person p;
69     
70     Output(Person p){
71         this.p = p;
72     }
73     
74     public void run(){
75         while(true){
76             p.out();
77         }
78     }
79 }

 1 public class Demo3 {
 2 
 3     public static void main(String[] args) {
 4         Bridge b = new Bridge();
 5         for(int i=1;i<6;i++){
 6             new Thread(new Person(b,"由北向南第"+i+"人")).start();
 7         }
 8         
 9         for(int i=1;i<7;i++){
10             new Thread(new Person(b,"由南向北第"+i+"人")).start();
11         }
12     }
13 }
14 
15 class Bridge{
16     private String name;
17     private boolean flag;
18     public synchronized void UpBridge(){
19         if(flag){
20             try {
21                 wait();
22             } catch (InterruptedException e) {            
23                 e.printStackTrace();
24             }
25         }
26         flag = true;
27         
28     }
29     public synchronized void DownBridge(){
30         flag = false;
31         notifyAll();
32     }
33 }
34 
35 class Person implements Runnable{
36     private Bridge bridge;
37     private String pName;
38     
39     Person(Bridge bridge, String pName){
40         this.bridge = bridge;
41         this.pName = pName;
42     }
43 
44     public void run() {        
45         bridge.UpBridge();
46         try{
47             Thread.sleep(80);
48         }catch(InterruptedException e){}
49         bridge.DownBridge();
50         System.out.println(pName);
51     }
52     
53 }