java基础知识回顾之java Thread类学习（七）--java多线程通信等待唤醒机制（wait和notify,notifyAll）

class Res{
    String name;
    String sex;
    boolean flag = false;
}

class Input implements Runnable{
    Object obj = new Object();
    private Res r ;

    public Input(Res r){//通过构造方法初始化资源，把Res传递进来，一构造对象，资源被初始化
        this.r = r;
    }

    public void run(){
        int x= 0;
        while(true){
            synchronized(r){//同步代码块,锁为r
                if(r.flag){//如果资源里面有一个姓名和名字了，input线程就冻结，释放执行权，释放执行资格，释放锁
                    try {
                        r.wait();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                    if(x == 0){//切换x，通过模2进行切换
                        r.name="peter";
                        r.sex="man";
                    }else{
                        r.name="李明";
                        r.sex="男男男男";
                    }
                    x = (x+1)%2;//取模运算，模2=0，取名字为Mike,性别为man，不等于0，则取小红，女女女女
                    r.flag = true;//当存入一个，标志变为true，输入线程进入等待，处于冻结状态，等待输出线程输出
                    r.notify();//唤醒线程池中的其它线程，唤醒第一个等待的输出线程
            }
        }
    }
    
}
class OutPut implements Runnable{
    Object obj = new Object();
    private Res r;
    public OutPut(Res r){
        this.r  = r;
    }
    public void run() {
        
        while(true){
            synchronized(r){
                if(!r.flag)
                    try {
                        r.wait();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    //如果r.flag=true,说明资源Res里面有一个东西，输出里面名字和性别
                    System.out.println(r.name+ "......"+r.sex);
                    r.flag=false;//当输出一个，标志改为false，这时输出线程进入线程池进行等待，直到被唤醒
                    r.notify();//唤醒输入线程，导致当前线程等待
            }
        }
    }
    
}
public class ThreadorThreadSpeak {

    /**
     * @param args
     */
    public static void main(String[] args) {
        //创建资源
        Res r = new Res();//比喻为煤资源
        //创建任务
        Input in = new Input(r);
        OutPut out = new OutPut(r);
        //创建线程
        Thread t1 = new Thread(in);//输入线程
        Thread t2 = new Thread(out);//输出线程
        //开启线程
        t1.start();
        t2.start();
    }

}

class Resource
{
    private String name;
    private String sex;
    private boolean flag = false;

    public synchronized void set(String name,String sex)
    {
        if(flag)
            try{this.wait();}catch(InterruptedException e){}
        this.name = name;
        this.sex = sex;
        flag = true;
        this.notify();
    }

    public synchronized void out()
    {
        if(!flag)
            try{this.wait();}catch(InterruptedException e){}
        System.out.println(name+"...+...."+sex);
        flag = false;
        notify();
    }
}


//输入
class Input implements Runnable
{
    Resource r ;
    Input(Resource r)
    {
        this.r = r;
    }
    public void run()
    {
        int x = 0;
        while(true)
        {
　　　　　　　//取2模进行切换
            if(x==0)
            {
                r.set("peter","nan");
            }
            else
            {
                r.set("李明","男男男男");
            }
            x = (x+1)%2;
        }
    }
}
//输出
class Output implements Runnable
{

    Resource r;
    Output(Resource r)
    {
        this.r = r;
    }

    public void run()
    {
        while(true)
        {
            r.out();
        }
    }
}



class  ResourceDemo3
{
    public static void main(String[] args) 
    {
        //创建资源。
        Resource r = new Resource();
        //创建任务。
        Input in = new Input(r);
        Output out = new Output(r);
        //创建线程，执行路径。
        Thread t1 = new Thread(in);
        Thread t2 = new Thread(out);
        //开启线程
        t1.start();
        t2.start();
    }
}