多线程通信【生产消费案例】

忘是亡心i 2022-06-12 09:39 172阅读 0赞

### 介绍： ###

在多线程环境下，虽然，我们能够让两个线程安全的隔离的执行锁范围内所包含的代码块，但是还有个问题就是一个线程会在一个时间段类执行代码块很多次，但是我们的需求是让一个线程锁范围所包含的代码块在抢到CPU执行片后只执行一次，我们该怎么实现呢？？？

### 等待和激活。 ###

那么在这种情况下，就非常需要两个东西了：等待和激活。

notify();
    wait()；
    
    注意：在wait()后，再次通过notify()激活线程时，该线程的执行还是从wait()后第一行开始执行。
    
    你知道wait()和sleep()方法的区别吗？？
    答：wait()会释放锁，而sleep()不会释放锁。

### 资源类： ###

/**
     * Created by FireLang on 2017-07-20.
     */
    public class Student {
        
        private String mName;
        private Integer mAge;
        private boolean mIsEat = false;
    
        public String getName() {
            return mName;
        }
    
        public boolean isEat() {
            return mIsEat;
        }
    
        public void setEat(boolean eat) {
            mIsEat = eat;
        }
    
        public void setName(String name) {
            mName = name;
        }
    
        public Integer getAge() {
            return mAge;
        }
    
        public void setAge(Integer age) {
            mAge = age;
        }
    }

### 生产者： ###

/**
     * Created by FireLang on 2017-07-20.
     */
    public class SetStudent implements Runnable {
        
        private Student mStudent;
        private int mNum = 0;
    
        public SetStudent(Student student) {
            mStudent = student;
        }
    
        @Override
        public void run() {
            while (true) {
                synchronized (mStudent) {
                    if (mStudent.isEat()) {
                        try {
                            mStudent.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
    
                    if (mNum % 2 == 0) {
                        mStudent.setName("Joy");
                        mStudent.setAge(18);
                    } else {
                        mStudent.setName("FireLang");
                        mStudent.setAge(19);
                    }
                    mNum++;
    
                    mStudent.setEat(true);
                    mStudent.notify();
                }
            }
        }
    
    }

### 消费者： ###

/**
     * Created by FireLang on 2017-07-20.
     */
    public class GetStudent implements Runnable {
        
        private Student mStudent;
    
        public GetStudent(Student student) {
            mStudent = student;
        }
    
        @Override
        public void run() {
            while (true) {
                synchronized (mStudent) {
                    if (!mStudent.isEat()) {
                        try {
                            mStudent.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
    
                    System.out.println(mStudent.getName() + "--->" + mStudent.getAge());
    
                    mStudent.setEat(false);
                    mStudent.notify();
                }
            }
        }
    }

### 测试类： ###

/**
     * Created by FireLang on 2017-07-20.
     */
    public class StudentDemo {
        
        public static void main(String[] args) {
            Student student = new Student();
    
            GetStudent getStudent = new GetStudent(student);
            SetStudent setStudent = new SetStudent(student);
    
            Thread t1 = new Thread(getStudent);
            Thread t2 = new Thread(setStudent);
    
            t1.start();
            t2.start();
        }
    }

最后的输出就是，你一次，我一次，你一次，我一次。

下面就涉及到线程的执行状况了。

### 线程的状态转换图及常见执行情况 ###

![这里写图片描述][SouthEast]

[SouthEast]: /images/20220612/c3c1df1512c149c0aadb8fd24e77aace.png