线程通信

有一个数据存储空间,划分为两部分,一部分用于存储人的姓名,另一部分用于存储人的性别;

我们的应用包含两个线程,一个线程不停向数据存储空间添加数据(生产者),另一个线程从数据空间取出数据(消费者);

因为线程的不确定性，存在于以下两种情况：

若生产者线程刚向存储空间添加了人的姓名还没添加人的性别，CPU就切换到了消费者线程，消费者线程把姓名和上一个人的性别联系到一起；

生产者放了若干数据，消费者才开始取数据，或者是消费者取完一个数据，还没等到生产者放入新的数据，又重复的取出已取过的数据；

生产者和消费者

wait():让当前线程放弃监视器进入等待，直到其他线程调用同一个监视器并调用notify()或notifyAll()为止。

notify():唤醒在同一对象监听器中调用wait方法的第一个线程。

notifyAll():唤醒在同一对象监听器中调用wait方法的所有线程。

这三个方法只能让同步监听器调用:

在同步方法中:      谁调用

在同步代码块中:   谁调用

wait()、notify()、notifyAll()，这三个方法属于Object不属于 Thread，这三个方法必须由同步监视对象来调用，两种情况：

              1.synchronized修饰的方法，因为该类的默认实例(this)就是同步监视器，所以可以在同步方法中调用这三个方法;

              2.synchronized修饰的同步代码块，同步监视器是括号里的对象，所以必须使用该对象调用这三个方法;

可要是我们使用的是Lock对象来保证同步的,系统中不存在隐式的同步监视器对象,那么就不能使用者三个方法了,那该咋办呢?

              此时,Lock代替了同步方法或同步代码块,Condition代替了同步监视器的功能;

                     Condition对象通过Lock对象的newCondition()方法创建;

                     里面方法包括:

                            await(): 等价于同步监听器的wait()方法;

                            signal(): 等价于同步监听器的notify()方法;

                            signalAll(): 等价于同步监听器的notifyAll()方法;

下面还有。。。

例子：设置属性
容易出现的问题是：
名字和性别不对应！

线程通信，很好！
package july7;

class Person{
    private String name;
    private String sex;
    private Boolean isimpty = Boolean.TRUE;//内存区为空！
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
   
    public void set(String name,String sex){
        synchronized (this) {
            while(!isimpty.equals(Boolean.TRUE)){//不为空的话等待消费者消费！
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            this.name = name;//为空的话生产者创造！
            this.sex = sex;
            isimpty = Boolean.FALSE;//创造结束后修改属性！
            this.notifyAll();
        }
    }
   
    public void get(){
        synchronized (this) {
            while(!isimpty.equals(Boolean.FALSE)){
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("姓名"+getName()+ ",  "+"性别"+getSex());
            isimpty = Boolean.TRUE;
            this.notifyAll();
        }
    }
}

class Producer implements Runnable{
    private Person p;
   
    public Producer(Person p) {
        super();
        this.p = p;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            if( i % 2 == 0){
                p.set("aa", "男");
            }else{
                p.set("cc", "女");
            }
        }
    }
}

class Consumer implements Runnable{
    private Person p;
   
    public Consumer(Person p) {
        super();
        this.p = p;
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            p.get();
        }
    }
}

public class Demo9 {
    public static void main(String[] args) {
        Person p = new Person();
      
        new Thread(new Producer(p)).start();
        new Thread(new Consumer(p)).start();
    }
}