[Java知识库]Java多线程 04：wait方法 和 notify方法（生产者和消费者模式）

一、关于Object类中的 wait 和 notify 方法

1. wait 和 notify 方法不是线程对象的方法，是java中任何一个java对象都拥有的方法，因为这个是Object类中自带的方法。
2. wait() 和 notify() 方法的作用：

   Object o = new Object();

   • o.wait()： 让正在o对象上活动的线程进入无期限等待状态，直到被唤醒为止。
   • o.notify()： 唤醒正在o对象上等待的线程。
     —— notifyAll()方法：这个方法是唤醒o对象上处于等待的所有线程。
     

二、生产者和消费者模式

1. 使用 wait() 和 notify() 方法实现“生产者和消费者模式”。

   • 什么是“生产者和消费者模式”？
     —— 生产线程负责生产，消费线程负责消费。生产线程和消费线程要达到均衡。
     注：这是一种特殊的业务需求，在这种特殊的情况下需要使用到 wait() 和 notify() 方法。
   • wait和notify方法不是线程对象的方法，是普通java对象都有的方法。
   • wait方法和notify方法建立在线程同步的基础之上。因为多线程要同时操作同一个对象。有线程安全问题。
   • wait 和 notify 方法的作用：
     • wait方法作用： o.wait()让正在o对象上活动的线程t进入等待状态，并且释放掉t线程之前占有的o对象的锁。
     • notify方法作用： o.notify()让正在o对象上等待的线程唤醒，只是通知，不会释放o对象上之前占有的锁。
       

2. 模拟生产者和消费者模式

   /*
   模拟生产者和消费者模式
   假设List集合是仓库，只能存储1个数据
   做到生产一个数据消费一个数据
    */
   public class ThreadTest07 {
       public static void main(String[] args) {
           //创建一个仓库
           List list = new ArrayList();
           //生产线程
           Thread t1 = new Thread(new Produce(list),"生产者线程");
           //消费线程
           Thread t2 = new Thread(new Consume(list),"消费者线程");
           //启动线程
           t1.start();
           t2.start();
       }
   }
   
   class Produce implements Runnable {
       //仓库
       private List list;
   
       public Produce(List list) {
           this.list = list;
       }
   
       @Override
       public void run() {
           //一直生产
           while (true) {
               synchronized (list) {
                   if (list.size() > 0) {//仓库满了
                       try {
   //                        list.notifyAll();//唤醒
                           list.wait();// 当前线程进入等待状态，并且释放Produce之前占有的list集合的锁。
                       } catch (InterruptedException e) {
                           e.printStackTrace();
                       }
                   }
                   //如果能运行到此处，证明仓库未满，开始生产
                   Object o = new Object();
                   list.add(o);
                   System.out.println(Thread.currentThread().getName() + "--->" + o);
                   //唤醒
                   list.notifyAll();//唤醒
               }
           }
       }
   }
   
   class Consume implements Runnable {
       //仓库
       private List list;
   
       public Consume(List list) {
           this.list = list;
       }
       @Override
       public void run() {
           //一直消费
           while (true) {
               synchronized (list) {
                   if (list.size() == 0) {//仓库空了
                       try {
   //                        list.notifyAll();//唤醒
                           list.wait();// 当前线程进入等待状态，并且释放Consume之前占有的list集合的锁。
                       } catch (InterruptedException e) {
                           e.printStackTrace();
                       }
                   }
                   //如果能运行到此处，证明仓库已满，开始消费
                   Object o = list.remove(0);
                   System.out.println(Thread.currentThread().getName() + "--->" + o);
                   //唤醒
                   list.notifyAll();//唤醒
               }
           }
       }
   }