java线程之线程通信控制

在上篇我们看到，A线程往公共资源库（对象）提供了一条数据，然后B线程从库中提取了数据并打印出来。

实际项目中，我们不可能只往库中提供一条数据，而且库的大小也不会是无穷大的，那么我们就会有这样一

个需求：A线程提供了一定的数据量后就暂停，等待B线程全部取走之后（因为B再不来取的话，库就装不下

了），A线程再往其中添加数据，如此往复。这里存在两种方法；

1.资源库对象的wait()方法和notify()方法/notifyAll()方法

public class Share {
    String name;
    String sex;
    //用empty来表示库中是否有数据
    boolean empty = true;

    // 线程A的任务，提供数据
    synchronized public void product(String name, String sex) {
        try {
            while(!empty) {
                //当库中数据不为空时，A线程不能向其添加数据，小憩一会儿
                this.wait();
            }
            //当库中数据为空时，A线程向其添加数据
            this.name = name;
            this.sex = sex;
            //添加完成之后，更改库中数据状态为不空,并唤醒其他线程来拿数据
            empty=false;
            this.notifyAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }

    // 线程B的任务，提取（显示）数据
    synchronized public void show() {
        try {
            while(empty) {
                //当库中数据为空时，B线程不能获取数据，小憩一会儿
                this.wait();
            }
            //当库中数据不为空时，B线程获取数据并打印
            System.out.println("姓名：" + this.name + "性别：" + this.sex);
            //拿完数据之后，更改库中数据状态为空,并唤醒其他线程继续写数据
            empty=true;
            this.notifyAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

wait()方法和notifyAll()方法只能由同步监听器对象来调用，就是这里说的资源库对象。

2.同步锁（Lock）和Condition接口

之前讲线程同步时有说到同步锁的方法，这种方法是没有同步监听器对象的，那么上面的wait()等方法就不能用了，

但是不用担心，java5在推出同步锁的时候也为其通信控制提供了一个方法获得Condition对象，来实现通信控制

public class Share {
    String name;
    String sex;
    //创建锁
    final Lock lock = new ReentrantLock();
    //创建Condition对象
    Condition condition = lock.newCondition();
    // 用empty来表示库中是否有数据
    boolean empty = true;

    // 线程A的任务，提供数据
    public void product(String name, String sex) {
        lock.lock();//上锁
        try {
            while (!empty) {
                // 当库中数据不为空时，A线程不能向其添加数据，小憩一会儿
                condition.await();
            }
            // 当库中数据为空时，A线程向其添加数据
            this.name = name;
            this.sex = sex;
            // 添加完成之后，更改库中数据状态为不空,并唤醒其他线程来拿数据
            empty = false;
            condition.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        lock.unlock();//解锁
    }

    // 线程B的任务，提取（显示）数据
     public void show() {
         lock.lock();//上锁
        try {
            while (empty) {
                // 当库中数据为空时，B线程不能获取数据，小憩一会儿
                condition.await();
            }
            // 当库中数据不为空时，B线程获取数据并打印
            System.out.println("姓名：" + this.name + "性别：" + this.sex);
            // 拿完数据之后，更改库中数据状态为空,并唤醒其他线程继续写数据
            empty = true;
            condition.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        condition.signalAll();//解锁
    }
}