线程间的通信

package com.cn;

class Test{
    public static void main(String [] args){
        Q q = new Q();
        new Thread(new Producer(q)).start();
        new Thread(new Consumer(q)).start();
    }
}

class Q{
    String name = "unknow";
    String sex = "unknow";
    boolean bFull = false;
    public synchronized void put(String name,String sex){
        if(bFull)
            try {
                wait();
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        this.name = name;
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        this.sex = sex;
        bFull = true;
        notify();
    }
    public synchronized void get(){
        if(!bFull)
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        System.out.print(name);
        System.out.println(":"+sex);
        bFull = false;
        notify();
    }
}

class Producer implements Runnable{
    Q q;
    public Producer(Q q){
        this.q = q;
    }
    public void run(){
        int i = 0;
        while(true){
            if(i==0){
                q.put("zhangsan", "male");
            }else{
                q.put("lisi", "famale");
            }
            i = (i+1)%2;
        }
    }
}

class Consumer implements Runnable{
    Q q;
    public Consumer(Q q){
        this.q = q;
    }
    public void run(){
        while(true){
            q.get();
        }
    }
}

保证了生产者生产了一个，消费者才可以去取一个，缓冲区存在已经生产的一个时生产者不会再生产，而是通知并等待消费者去取，在缓冲区没有事，消费者也不会去取，而是通知并等待生产者去生产。