线程交替运行

Posted 2020-09-12

package threadtest;  
  
public class Test1 {  
    /* 
     * 两个线程，一个打印1-100的奇数，一个打印1-100的偶数；要求：线程1打印5个之后，线程2开始打印，线程2打印5个之后，线程1再开始打印，以此循环。 
     */  
    private static int state = 1;  
    private static int num1 = 1;  
    private static int num2 = 2;  
      
    public static void main(String[] args) {  
        // TODO Auto-generated method stub  
        final Test1 t = new Test1();  
        new Thread(new Runnable(){  
            @Override  
            public void run(){  
                while(num1<100){  
                    //两个线程都用t对象作为锁，保证每个交替期间只有一个线程在打印  
                    synchronized(t){  
                         // 如果state!=1, 说明此时尚未轮到线程1打印, 线程1将调用t的wait()方法, 直到下次被唤醒    
                        if(state!=1){  
                            try{  
                                t.wait();  
                            }catch(InterruptedException e){  
                                e.printStackTrace();  
                            }  
                        }  
                        // 当state=1时, 轮到线程1打印5次数字  
                        for(int j=0;j<5;j++){  
                            System.out.println(num1);  
                            num1 +=2;  
                        }  
                        // 线程1打印完成后, 将state赋值为2, 表示接下来将轮到线程2打印    
                        state = 2;    
                        // notifyAll()方法唤醒在t上wait的线程2, 同时线程1将退出同步代码块, 释放t锁    
                        t.notifyAll();    
                    }  
                }  
            }  
        }).start();  
          
        new Thread(new Runnable(){  
            @Override  
            public void run(){  
                while(num2<100){  
                    synchronized(t){  
                        if(state!=2){  
                            try{  
                                t.wait();  
                            }catch(InterruptedException e){  
                                e.printStackTrace();  
                            }  
                        }  
                          
                        for(int i=0;i<5;i++){  
                            System.out.println(num2);  
                            num2 +=2;  
                        }  
                          
                        state=1;  
                        t.notifyAll();  
                    }  
                                                              
                }                 
            }  
        }).start();       
    }  
}