巴中网站建设天仁云二手房地产中介网站建设

4、关于 Object 类中的 wait 和 notify 方法。（生产者和消费者模式！）
第一：wait 和 notify 方法不是线程对象的方法，是 java 中任何一个 java 对象都有的方法，因为这两个方法是 Object 类中自带的。
wait 方法和 notify 方法不是通过线程对象调用的。
第二：wait() 方法作用？
Object o = new Object();
o.wait();
表示：让正在 o 对象上活动的线程进入等待状态，无期限等待，直到被唤醒为止。
o.wait(); 方法的调用，会让“当前线程（正在 o 对象上活动的线程）”进入等待状态。
第三：notify方法作用？
Object o = new Object();
o.notify();
表示：唤醒正在 o 对象上等待的线程。

notifyAll() 方法：
这个方法是唤醒 o 对象上处于等待的所有线程。

例：
package com.su.test.threadtest;

import java.util.ArrayList;
import java.util.List;

/**

• @author : sumeiping
• @date : 2022-02-01 16:41
• 1、使用 wait 方法和 notify 方法实现“生产者和消费者模式”
• 2、什么是“生产者和消费者模式”

•  生产线程负责生产，消费线程负责消费。
  

•  生产线程和消费线程要达到均衡。
  

•  这是一种特殊的业务需求，在这种特殊的情况下要使用 wait 方法和 notify 方法。
  

• 3、wait 和 notify 方法不是线程对象的方法，是普通 java 对象都有的方法。java.lang.Object 根类
• 4、wait 方法和 notify 方法建立在线程同步的基础之上。因为多线程要同时操作一个仓库。有线程安全问题。
• 5、wait 方法作用：o.wait() 让正在 o 对象上活动的线程 t 进入等待状态，并且释放掉 t 线程之前占有的 o 对象的锁。
• 6、notify 方法作用：o.notify() 让正在 o 对象上等待的线程唤醒，只是通知，不会释放 o 对象上之前占有的锁。
• 7、模拟这样一个需求：

•  仓库我们采用 List 集合。
  

•  List 集合中假设只能存储 1 个元素。
  

•  1 个元素就表示仓库满了。
  

•  如果 List 集合中元素个数是 0，就表示仓库空了。
  

•  保证 List 集合中永远都是最多存储 1 个元素。
  

•  必须做到这种效果：生产 1 个消费 1 个。
  

*/
public class WaitNotify {
public static void main(String[] args) {
// 创建一个仓库对象，共享的。
List list = new ArrayList();

    // 创建2个线程对象// 生产者线程对象Thread t1 = new Thread(new Producer(list));t1.setName("生产者线程");// 消费者线程对象Thread t2 = new Thread(new Consumer(list));t2.setName("消费者线程");// 启动线程t1.start();t2.start();/*** 生产者线程--->java.lang.Object@47a2a66c* 消费者线程--->java.lang.Object@47a2a66c* 仓库已经空了* 生产者线程--->java.lang.Object@496550e8* 消费者线程--->java.lang.Object@496550e8* 仓库已经空了* 生产者线程--->java.lang.Object@4d5acd1c* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@4d5acd1c* 仓库已经空了* 生产者线程--->java.lang.Object@8585ad3* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@8585ad3* 生产者线程--->java.lang.Object@5a9b1c72* 消费者线程--->java.lang.Object@5a9b1c72* 生产者线程--->java.lang.Object@399af5d9* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@399af5d9* 生产者线程--->java.lang.Object@22b3eddb* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@22b3eddb* 仓库已经空了* 生产者线程--->java.lang.Object@6877a59c* ..........*/
}

}
// 生产线程
class Producer implements Runnable{
// 仓库
private List list;
public Producer(){}

public Producer(List list) {this.list = list;
}@Override
public void run() {// 一直生产（使用死循环来模拟一直生产）while (true){// 给仓库对象list加锁synchronized (list){if (list.size() > 0){   // 大于 0，说明仓库中已经有 1 个元素了。System.out.println("仓库已经有1个元素了");try {list.wait();    // 当线程进入等待状态，并且释放 Producer 之前占有的 list 集合的锁。} catch (InterruptedException e) {e.printStackTrace();}}// 程序执行到这来说明仓库是空的，可以生产Object obj = new Object();list.add(obj);System.out.println(Thread.currentThread().getName() + "--->" + obj);try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 唤醒消费者进行消费//list.notify();list.notifyAll();}}
}

}
// 消费线程
class Consumer implements Runnable{
private List list;
public Consumer(){}

public Consumer(List list){this.list = list;
}@Override
public void run() {// 一直消费while (true){synchronized (list){if (list.size() == 0){System.out.println("仓库已经空了");try {list.wait();    // 仓库已经空了。消费者线程等待，释放掉 list 集合的锁} catch (InterruptedException e) {e.printStackTrace();}}// 程序执行到这里说明仓库中有数据，可以消费Object obj = list.remove(0);System.out.println(Thread.currentThread().getName() + "--->" + obj);try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 唤醒生产者进行生产//list.notify();list.notifyAll();}}
}

}