黑马程序员技术交流社区

标题: 关于多线程之间通信的问题 [打印本页]

---

作者: lxww    时间: 2013-3-19 19:38
标题: 关于多线程之间通信的问题


class Demo2_Exercise1 {

public static void main(String[] args) {
  final Printer p1 = new Printer();
  final Printer p2 = new Printer();
  
  new Thread("线程1："){
   public void run() {
    for (int i = 1; i <= 3; i++)
     try{
      p1.print();
     }catch(Exception e){
      e.printStackTrace();
     }
   }
  }.start();
  
  new Thread("线程2："){
   public void run() {
    for (int i = 1; i <= 3; i++)
     try{
      p2.print();
     }catch(Exception e){
      e.printStackTrace();
     }
   }
  }.start();
}
  
}
class Printer{
public synchronized void print() throws Exception {
  for (int i = 1; i <= 3; i++)
  System.out.println(Thread.currentThread().getName()+ i);
  System.out.println();
}
}

以上代码怎么实现以下运行效果：不能使随机得到的，要确保每次都是得到这个结果。请求高手指点！（重点：在主函数内实现）
线程1: 1
线程1: 2
线程1: 3

线程2: 1
线程2: 2
线程2: 3

线程1: 1
线程1: 2
线程1: 3

线程2: 1
线程2: 2
线程2: 3
  
线程1: 1
线程1: 2
线程1: 3

线程2: 1
线程2: 2
线程2: 3

---

作者: 张宝    时间: 2013-3-19 19:46


/*
        线程1: 1
        线程1: 2
        线程1: 3
        
        线程2: 1
        线程2: 2
        线程2: 3
        
        
        
        线程1: 1
        线程1: 2
        线程1: 3
        
        线程2: 1
        线程2: 2
        线程2: 3
        
        
        
        线程1: 1
        线程1: 2
        线程1: 3
        
        线程2: 1
        线程2: 2
        线程2: 3
        
        
        
*/
class Demo2_Exercise 1{
        
        public static void main(String[] args) {
                final Printer p = new Printer();
               
                new Thread(){
                        public void run() {
                                for (int i = 1; i <= 3; i++)
                                        try {
                                                p.print1();
                                        } catch(Exception e) {
                                                e.printStackTrace();        
                                        }
                        }        
                }.start();
               
                new Thread(){
                        public void run() {
                                for (int i = 1; i <= 3; i++)
                                        try {
                                                p.print2();
                                        } catch(Exception e) {
                                                e.printStackTrace();        
                                        }
                        }        
                }.start();
        }
               
}

class Printer {
        private int flag = 1;
        
        public synchronized void print1() throws Exception {
                if (flag != 1)
                        wait();
                for (int i = 1; i <= 3; i++)
                        System.out.println("线程1: " + i);
                System.out.println();
                flag = 2;
                notify();
        }
        
        public synchronized void print2() throws Exception {
                if (flag != 2)
                        wait();
                for (int i = 1; i <= 3; i++)
                        System.out.println("线程2: " + i);
                System.out.println();
                flag = 1;
                notify();
        }        
}

---

作者: 杨博    时间: 2013-3-19 19:50

1. class Demo2_Exercise {
   
2.        
   
3.         public static void main(String[] args) {
   
4.                 final Printer p = new Printer();
   
5.                
   
6.                 new Thread(){
   
7.                         public void run() {
   
8.                                 for (int i = 1; i <= 3; i++)
   
9.                                         try {
   
10.                                                 p.print1();
    
11.                                         } catch(Exception e) {
    
12.                                                 e.printStackTrace();       
    
13.                                         }
    
14.                         }       
    
15.                 }.start();
    
16.                
    
17.                 new Thread(){
    
18.                         public void run() {
    
19.                                 for (int i = 1; i <= 3; i++)
    
20.                                         try {
    
21.                                                 p.print2();
    
22.                                         } catch(Exception e) {
    
23.                                                 e.printStackTrace();       
    
24.                                         }
    
25.                         }       
    
26.                 }.start();
    
27.         }
    
28.                
    
29. }
    
30. 
    
31. class Printer {
    
32.         private int flag = 1;
    
33.        
    
34.         public synchronized void print1() throws Exception {
    
35.                 if (flag != 1)
    
36.                         wait();
    
37.                 for (int i = 1; i <= 3; i++)
    
38.                         System.out.println("线程1: " + i);
    
39.                 System.out.println();
    
40.                 flag = 2;
    
41.                 notify();
    
42.         }
    
43.        
    
44.         public synchronized void print2() throws Exception {
    
45.                 if (flag != 2)
    
46.                         wait();
    
47.                 for (int i = 1; i <= 3; i++)
    
48.                         System.out.println("线程2: " + i);
    
49.                 System.out.println();
    
50.                 flag = 1;
    
51.                 notify();
    
52.         }       
    
53. }

复制代码

线程等待, 就调用wait()

notify()方法是随机唤醒一个线程

---

作者: 黑马17期-闫东东    时间: 2013-3-19 20:46
第一种：synchronized
class Printer {
        boolean flag=false;
        public  synchronized void print1() {
                while(flag)
                        try{wait();}catch(Exception e){}
                for (int i = 1; i <= 3; i++)
                        System.out.println("线程1: " + i);
                System.out.println();
                flag=true;
                notifyAll();
        }
       
        public  synchronized void print2() {
                while(!flag)
                try{wait();}catch(Exception e){}
                for (int i = 1; i <= 3; i++)
                        System.out.println("线程2: " + i);
                System.out.println();
                flag=false;
                notifyAll();
        }       
}

第二种：  JDK1.5后，用lock锁

class Print

{        private ReentrantLock lock=new ReentrantLock();
        private Condition con_1=lock.newCondition();
        private Condition con_2=lock.newCondition();
       
        int flag=1;
        public  void print1() throws InterruptedException {
                lock.lock();
                try{while(flag!=1)
                        con_1.await();
                for(int x=1;x<=3;x++){
                        System.out.println("线程一："+x);
                        System.out.println();
                }
                flag=2;
                con_2.signal();}
                finally{lock.unlock();}
        }
        public  void print2() throws InterruptedException {
                lock.lock();
                while(flag!=2)
                        con_2.await();
                for(int x=1;x<=3;x++){
                        System.out.println("线程二："+x);
                        System.out.println();
                }
                flag=1;
                con_1.signal();
                lock.unlock();
        }

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2