010.多线程-线程间通信

package cn.qbz.thread;

/**
 * 线程间通信
 */
public class ConnectThreadTest {

    public static void main(String[] args) {
        Student student = new Student();
        ProduceTest produceTest = new ProduceTest(student);
        ConsumerTest consumerTest = new ConsumerTest(student);

        produceTest.start();
        consumerTest.start();

    }
}

class ProduceTest extends Thread {
    private Student student;

    public ProduceTest(Student student) {
        this.student = student;
    }

    @Override
    public void run() {
        int num = 1;
        while (true) {
            synchronized (student) {
                //如果可以生产，生产者生产
                if (student.getCanProduce()) {
                    if (num == 1) {
                        student.setAge(6);
                        student.setName("小王");
                        num = 0;
                    } else {
                        student.setName("老王");
                        student.setAge(99);
                        num = 1;
                    }

                    //重置生产者不可以生产
                    student.setCanProduce(false);
                }

                student.notifyAll();
                try {
                    student.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

class ConsumerTest extends Thread {
    private Student student;

    public ConsumerTest(Student student) {
        this.student = student;
    }

    @Override
    public void run() {
        while (true) {
            synchronized (student) {
                //如果不可以生产，进行消费
                if (!student.getCanProduce()) {
                    //重置生产者可以生产
                    student.setCanProduce(true);
                    System.out.println(student.toString());
                }

                student.notifyAll();
                try {
                    student.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

class Student {
    private String name;
    private Integer age;
    private Boolean canProduce = false;

    public Boolean getCanProduce() {
        return canProduce;
    }

    public void setCanProduce(Boolean canProduce) {
        this.canProduce = canProduce;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        return "Student{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}