java 多线程 2

package com.imooc.base;

public class Stage extends Thread {

    public static void main(String[] args) {
        new Stage().run();
    }
    public void run(){
        
        System.out.println("欢迎观看隋唐演义！");
        
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e1) {
            e1.printStackTrace();
        }
        
        System.out.println("大幕徐徐拉开");
        
        ArmyRunnable armyTaskOfSuiDynasty = new ArmyRunnable();
        ArmyRunnable armyTaskOfRevolt = new ArmyRunnable();
        
        Thread armyOfSuiDynasty = new Thread(armyTaskOfSuiDynasty,"隋军");
        Thread armyOfRevolt = new Thread(armyTaskOfRevolt,"农民起义军");
        
        armyOfSuiDynasty.start();
        armyOfRevolt.start();
        
        try {
            Thread.sleep(50);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        armyTaskOfSuiDynasty.keepRunning = false;
        armyTaskOfRevolt.keepRunning = false;
        
        try {
            armyOfRevolt.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        System.out.println("正当双方激战正酣，半路杀出了个程咬金");
        
        Thread mrCheng = new KeyPersonThread();
        mrCheng.setName("程咬金");
        
        System.out.println("程咬金的理想就是结束战争，使百姓安居乐业！");
        
        armyTaskOfSuiDynasty.keepRunning = false;
        armyTaskOfRevolt.keepRunning = false;        
        
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        mrCheng.start();
        
        try {
            mrCheng.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        
        System.out.println("战争结束，人民安居乐业，程先生实现了自己的人生梦想！");
        System.out.println("谢谢观看");
    }
}

package com.imooc.base;

public class KeyPersonThread extends Thread {
    public void run(){
        System.out.println(Thread.currentThread().getName()+"开始了战斗！");
        
        for(int i=0;i<10;i++){
            System.out.println(Thread.currentThread().getName()+"左突右杀，攻击隋军。。。");
        }
        
        System.out.println(Thread.currentThread().getName()+"结束了战斗！");
    }
}

package com.imooc.base;

public class ArmyRunnable implements Runnable {
    //volatile保证了线程可以正确的读取其他线程写入的值
    //可见性 参考JMM,happens-before原则
    volatile boolean keepRunning = true;

    public void run() {
        while(keepRunning){
            for(int i=0;i<5;i++){
                System.out.println(Thread.currentThread().getName()+"进攻方{"+ i +"}");
                
                Thread.yield();
            }
            
        }
        System.out.println(Thread.currentThread().getName()+"结束了战斗！");
    }

}